New methods: QueryBuilder - Support create query

Nhom06_QuanLyWhimsiBooks/src/exampleUsage/QueryBuilder_Example.java

@@ -0,0 +1,64 @@
+package exampleUsage;
+
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.util.Date;
+
+import bus.NhaCungCap_BUS;
+import connectDB.ConnectDB;
+import dao.DanhMuc_DAO;
+import entities.DanhMuc;
+import utilities.QueryBuilder;
+
+public class QueryBuilder_Example {
+	public static void main(String[] args) {
+
+		// Thông thường tạo query truy vấn
+		// SELECT * FROM NhanVien WHERE tienLuong < 1000000 OR ngayVaoLam > '2023-11-20'
+
+		// Đó là khi bạn đã biết những con số này tồn tại
+		// SELECT * FROM NhanVien WHERE tienLuong < ? OR ngayVaoLam > ?
+		// Nhưng trường hợp bị null thì sao? Giả sử Date ngayVaoLam = null. Lúc này setDate sẽ lỗi
+
+		//
+		// SELECT * FROM NhanVien WHERE tienLuong < ? OR ngayVaoLam > null
+
+		// Để tạo query tự động biết data có tồn tại hay không, đây là giải pháp.
+
+		// Tuy nhiên truy vấn phức tạp hơn sẽ rất khó sử dụng.
+
+		// Hàm này chỉ sử dụng khi bạn cần tìm kiếm nâng cao.
+		QueryBuilder query = new QueryBuilder("SELECT * FROM NhanVien ? ORDER BY id");
+		try {
+
+			// Tiền lương < 1000000
+			query.addParameter(QueryBuilder.Enum_DataType.DOUBLE, "tienLuong", "<", 100000);
+
+			// Ngày vào làm nhỏ hơn ngày hiện tại
+			query.addParameter(QueryBuilder.Enum_DataType.DATE, "ngayVaoLam", "<", new Date());
+
+			// Tìm họ tên chứa chữ Bảo
+			query.addParameter(QueryBuilder.Enum_DataType.STRING, "hoTen", "%?%", "Bảo");
+
+			// Tìm họ tên bắt đầu là Bảo
+			query.addParameter(QueryBuilder.Enum_DataType.STRING, "hoTen", "?%", "Bảo");
+
+
+
+			// Trường hợp 1: Tạo ra query kiểu chuỗi
+			System.out.println(query.generateQuery("OR")[1]);
+
+			// Trường hợp 2: Connect lên database, tự động set PreparedStament
+			//Giả sử muốn lấy thông tin nhân viên từ query trên, nhưng muốn chỉ chọn 1 trong 2
+			// Do thoả mãn 1 trong 2 query trên, ta dùng OR thay vì AND
+
+
+			//PreparedStatement pstm = query.setParamsForPrepairedStament(ConnectDB.getConnection(),"OR");
+			//ResultSet rs = pstm.executeQuery();
+
+		} catch (Exception e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+	}
+}

Nhom06_QuanLyWhimsiBooks/src/utilities/QueryBuilder.java

@@ -0,0 +1,221 @@
+package utilities;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.util.ArrayList;
+import java.util.Date;
+
+public class QueryBuilder {
+	private String query;
+	public static enum Enum_DataType {
+		STRING,
+		INTEGER,
+		DOUBLE,
+		FLOAT,
+		DATE,
+		TIMESTAMP,
+		BOOLEAN
+	}
+	private ArrayList<Object[]> params;
+
+
+	public String getQuery() {
+		return query;
+	}
+	public void setQuery(String query) {
+		this.query = query;
+	}
+	public ArrayList<Object[]> getParams() {
+		return params;
+	}
+	public void setParams(ArrayList<Object[]> params) {
+		this.params = params;
+	}
+
+	/**
+	 * Tạo query builder, truyền vào một chuỗi query.
+	 * Hiện đang beta, chỉ có thể tạo query select
+	 * 
+	 * @param query 
+	 * <b>SELECT ... FROM ...? .....</b>
+	 * <br>EX original query: <b>SELECT * FROM NhaSach WHERE id = ? ORDER BY id DESC</b>
+	 * <br> Write it into: 
+	 * <b>SELECT * FROM NhaSach ? ORDER BY id DESC. </b>
+	 * @param params ArrayList<Object[]>. Object[] needs follow this {datatype, colname, condition, value}
+	 */
+	public QueryBuilder(String query, ArrayList<Object[]> params) {
+		super();
+		this.query = query;
+		if (params != null)
+			this.params = params;
+		else
+			params = new ArrayList<Object[]>();
+	}
+
+	/**
+	 * Tạo query builder, truyền vào một chuỗi query.
+	 * Hiện đang beta, chỉ có thể tạo query select
+	 * 
+	 * @param query 
+	 * <b>SELECT ... FROM ...? .....</b>
+	 * <br>EX original query: <b>SELECT * FROM NhaSach WHERE id = ? ORDER BY id DESC</b>
+	 * <br> Write it into: 
+	 * <b>SELECT * FROM NhaSach ? ORDER BY id DESC. </b>
+	 */
+	public QueryBuilder(String query) {
+		super();
+		this.query = query;
+		params = new ArrayList<Object[]>();
+	}
+
+	/**
+	 * Tạo ra một parameter
+	 *  
+	 */
+	public Object[] generateParameter( Enum_DataType dataType, String columnName, String condition, Object value) {
+		if (columnName.isBlank() || condition.isBlank())
+			return null;
+		Object[] obj = {dataType, columnName, condition, value};
+		return obj;
+	}
+
+	/**
+	 * Thêm parameter vào query
+	 * <br>
+	 * Hỗ trợ toán tử '<', '>', '=', '>=', '<='
+	 * <br>
+	 * Kiểu chuỗi có thêm %. Ví dụ query '%a' sẽ được để ở condition
+	 * có dạng '%a'.
+	 * <br> Nếu tìm %a + chuỗi người dùng nhập, bạn sẽ có '%a?'
+	 *  
+	 */
+	public void addParameter( Enum_DataType dataType, String columnName, String condition, Object value) throws Exception{
+		Object[] obj = generateParameter(dataType, columnName, condition, value);
+		if (obj == null) {
+			throw new Exception("Khởi tạo parameter thất bại");
+		}
+		params.add(obj);
+	}
+
+	/**
+	 * Truyền vào <b> conditionAll </b> là một phép toán tử giữa các param như <b>AND, OR</b>
+	 */
+	public Object[] generateQuery(String conditionsAll) {
+
+		String tempQuery = getQuery();
+		String paramsQuery = "WHERE";
+		int numParamsQuery = 0;
+		try {
+			for (Object[] x : params) {
+				String tempCondition = (String) x[2];
+				String tempStr = "";
+				if ((Enum_DataType) x[0] == Enum_DataType.STRING && tempCondition.contains("%")) {
+					if (x[3] == null)
+						continue;
+					tempStr = (String) x[2];
+					if (tempStr.length() < 1)
+						continue;
+					paramsQuery += (numParamsQuery++ < 1) ? " " + ((String) x[1]  + " = " )
+							: " " + conditionsAll + " " + ((String) x[1]  + " = " );
+
+					paramsQuery += "CONCAT('" +  tempStr.charAt(0) + "'";
+					for (int j = 1; j < tempCondition.length(); j++) {
+						paramsQuery += ", '" +  tempStr.charAt(j) + "'";
+					}
+					paramsQuery += ")";
+				}else
+
+				if (x[3] != null) {
+					paramsQuery += (numParamsQuery++ < 1) ? " " + ((String) x[1] + " " + (String) x[2] + " ?")
+							: " " + conditionsAll + " " + ((String) x[1] + " " + (String) x[2] + " ?");
+				}
+			}
+			if (numParamsQuery > 0)
+				tempQuery = tempQuery.replace("?", paramsQuery);
+			Object[] obj = {numParamsQuery, tempQuery};
+			return obj;
+		}
+		catch (Exception e){
+			return null;
+		}
+	}
+
+	/**
+	 * Tự động set parameters, build theo dữ liệu lấy từ object
+	 * <br>
+	 * Thay vì phải tự kiểm tra dữ liệu có tồn tại hay không để set thì chức năng này sẽ làm thay bạn
+	 * @param conn
+	 * @param conditionForAll
+	 * @return
+	 */
+	public PreparedStatement setParamsForPrepairedStament(Connection conn, String conditionForAll) {
+		PreparedStatement pstm = null;
+		int tempCol = 0;
+		try {
+		Object[] obj = generateQuery(conditionForAll);
+		if (obj == null)
+			return null;
+		String tempQuery = (String) obj[1];
+		int numParamsQuery = (int) obj[0];
+		pstm = conn.prepareStatement(tempQuery);
+		if (numParamsQuery < 1)
+			return pstm;
+
+		for (Object[] x : params) {
+
+			if (x[3] == null) {
+				continue;
+			}
+			switch ((Enum_DataType) x[0]) {
+				case BOOLEAN -> {
+					pstm.setBoolean(++numParamsQuery, (boolean) x[3]);
+				}
+				case DATE -> {
+					pstm.setDate(++numParamsQuery, new java.sql.Date(((Date) x[3]).getTime()));
+				}
+				case DOUBLE -> {
+					pstm.setDouble(++numParamsQuery, (double) x[3]);
+				}
+				case FLOAT -> {
+					pstm.setFloat(++numParamsQuery, (float) x[3]);
+				}
+				case INTEGER -> {
+					pstm.setInt(++numParamsQuery, (int) x[3]);
+				}
+				case STRING -> {
+					pstm.setString(++numParamsQuery, (String) x[3]);
+				}
+				case TIMESTAMP -> {
+					pstm.setTimestamp(++numParamsQuery,  new java.sql.Timestamp(((Date) x[3]).getTime()));
+				}
+				default -> {
+					return null;
+				}
+
+			}
+
+		}
+
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+
+		return pstm;
+
+
+	}
+
+	public QueryBuilder() {
+		super();
+		params = new ArrayList<Object[]>();
+	}
+	@Override
+	public String toString() {
+		return "QueryBuilder [query=" + query + ", params=" + params + "]";
+	}
+
+
+
+
+
+}