1. 程式人生 > >五、DAO設計模式

五、DAO設計模式

1.DAO: Data Access Object

why:實現功能的模組化,更有利於程式碼的維護和升級。

DAO可被子類繼承或直接使用。

what:訪問資料資訊的類,包含了對資料的CRUD(creat,read,update,delete),而不包含任何業務相關的資訊。

how:使用JDBC編寫DAO可能會包含的方法:

//INSERT,UPDATE,DELETE 操作都可以包含在其中
void update(String sql,Object ... args)
//查詢一條記錄,返回對應的物件
<T> T get(Class<T> clazz,String sql,Object ... args)
//查詢多條記錄,返回對應物件的集合
<T> List<T> getFroList(Class<T> clazz,String sql,Object ... args)
//返回某條記錄的某一個欄位的值或一個統計的值(平均數等)
<E> E getForValue(String sql,Object ... args)

2.BeanUtils:操作JAVA中bean的一個外部jar包

可以代替自己通過反射進行對物件屬性賦值的類,在上一篇部落格最後提到過。

http://commons.apache.org/ 來下載所需要的jar包

但BeanUtils jar包不能單獨使用,需要配合logging與log4j來使用(都能通過apache官網下載)

1)   BeanUtils相關包

commons-beanutils-1.8.3.jar

(2)   Logic4j相關包 

commons-logging.jar

log4j.jar

目前測試可以使用的BeanUtils依賴包版本是:

BeanUtil-1.9.3 +

Collection-3.2.2 +

logging-1.2

當Collection版本為4.2的時候發現會報異常,用3.2.2完美解決問題

將三個jar包都匯入到專案的構建路徑中,便可以使用BeanUtils 去操作Bean

 

BeanUtils的setProperty(object,name,value)方法需要的引數分別是

Object=載入類的物件

Name=類屬性的名稱

Value=所賦的值;

BeanUtils的getProperty(object,name)方法的返回值是String型別,所以可以直接輸出;

3.JAVA類的屬性

1).在JAVA EE 中,JAVA 類的屬性通過 getter,setter 來定義:get(set)方法,去除get(set)方法後,後字母小寫即為 JAVA 類的屬性名

2)以前的屬性,即成員變數,稱為欄位

4.DAO設計模式

在DAO類中的方法如下

1)增刪改通用方法

// INSERT, UPDATE, DELETE 操作都可以包含在其中
	public void update(String sql, Object... args) {
		Connection connection = null;
		PreparedStatement preparedStatement = null;

		try {
			connection = JDBCTools.getConnection();
			preparedStatement = connection.prepareStatement(sql);

			for (int i = 0; i < args.length; i++) {
				preparedStatement.setObject(i + 1, args[i]);
			}

			preparedStatement.executeUpdate();
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			JDBCTools.releaseDB(null, preparedStatement, connection);
		}
	}

2)查詢(一條記錄或者多條記錄)

// 查詢一條記錄, 返回對應的物件
	public <T> T get(Class<T> clazz, String sql, Object... args) {
		List<T> result = getForList(clazz, sql, args);
		if(result.size() > 0){
			return result.get(0);
		}
		
		return null;
	}

	/**
	 * 傳入 SQL 語句和 Class 物件, 返回 SQL 語句查詢到的記錄對應的 Class 類的物件的集合
	 * @param clazz: 物件的型別
	 * @param sql: SQL 語句
	 * @param args: 填充 SQL 語句的佔位符的可變引數. 
	 * @return
	 */
	public <T> List<T> getForList(Class<T> clazz, 
			String sql, Object... args) {

		List<T> list = new ArrayList<>();

		Connection connection = null;
		PreparedStatement preparedStatement = null;
		ResultSet resultSet = null;

		try {
			//1. 得到結果集
			connection = JDBCTools.getConnection();
			preparedStatement = connection.prepareStatement(sql);

			for (int i = 0; i < args.length; i++) {
				preparedStatement.setObject(i + 1, args[i]);
			}

			resultSet = preparedStatement.executeQuery();
			
			//2. 處理結果集, 得到 Map 的 List, 其中一個 Map 物件
			//就是一條記錄. Map 的 key 為 reusltSet 中列的別名, Map 的 value
			//為列的值. 
			List<Map<String, Object>> values = 
					handleResultSetToMapList(resultSet);
			
			//3. 把 Map 的 List 轉為 clazz 對應的 List
			//其中 Map 的 key 即為 clazz 對應的物件的 propertyName, 
			//而 Map 的 value 即為 clazz 對應的物件的 propertyValue
			list = transfterMapListToBeanList(clazz, values);

		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			JDBCTools.releaseDB(resultSet, preparedStatement, connection);
		}

		return list;
	}

	public <T> List<T> transfterMapListToBeanList(Class<T> clazz,
			List<Map<String, Object>> values) throws InstantiationException,
			IllegalAccessException, InvocationTargetException {

		List<T> result = new ArrayList<>();

		T bean = null;

		if (values.size() > 0) {
			for (Map<String, Object> m : values) {
				bean = clazz.newInstance();
				for (Map.Entry<String, Object> entry : m.entrySet()) {
					String propertyName = entry.getKey();
					Object value = entry.getValue();

					BeanUtils.setProperty(bean, propertyName, value);
				}
				// 13. 把 Object 物件放入到 list 中.
				result.add(bean);
			}
		}

		return result;
	}

	/**
	 * 處理結果集, 得到 Map 的一個 List, 其中一個 Map 物件對應一條記錄
	 * 
	 * @param resultSet
	 * @return
	 * @throws SQLException
	 */
	public List<Map<String, Object>> handleResultSetToMapList(
			ResultSet resultSet) throws SQLException {
		// 5. 準備一個 List<Map<String, Object>>:
		// 鍵: 存放列的別名, 值: 存放列的值. 其中一個 Map 物件對應著一條記錄
		List<Map<String, Object>> values = new ArrayList<>();

		List<String> columnLabels = getColumnLabels(resultSet);
		Map<String, Object> map = null;

		// 7. 處理 ResultSet, 使用 while 迴圈
		while (resultSet.next()) {
			map = new HashMap<>();

			for (String columnLabel : columnLabels) {
				Object value = resultSet.getObject(columnLabel);
				map.put(columnLabel, value);
			}

			// 11. 把一條記錄的一個 Map 物件放入 5 準備的 List 中
			values.add(map);
		}
		return values;
	}
/**
	 * 獲取結果集的 ColumnLabel 對應的 List
	 * 
	 * @param rs
	 * @return
	 * @throws SQLException
	 */
	private List<String> getColumnLabels(ResultSet rs) throws SQLException {
		List<String> labels = new ArrayList<>();

		ResultSetMetaData rsmd = rs.getMetaData();
		for (int i = 0; i < rsmd.getColumnCount(); i++) {
			labels.add(rsmd.getColumnLabel(i + 1));
		}

		return labels;
	}

3)返回一個值

// 返回某條記錄的某一個欄位的值 或 一個統計的值(一共有多少條記錄等.)
	public <E> E getForValue(String sql, Object... args) {
		
		//1. 得到結果集: 該結果集應該只有一行, 且只有一列
		Connection connection = null;
		PreparedStatement preparedStatement = null;
		ResultSet resultSet = null;

		try {
			//1. 得到結果集
			connection = JDBCTools.getConnection();
			preparedStatement = connection.prepareStatement(sql);

			for (int i = 0; i < args.length; i++) {
				preparedStatement.setObject(i + 1, args[i]);
			}

			resultSet = preparedStatement.executeQuery();
			
			if(resultSet.next()){
				return (E) resultSet.getObject(1);
			}
		} catch(Exception ex){
			ex.printStackTrace();
		} finally{
			JDBCTools.releaseDB(resultSet, preparedStatement, connection);
		}
		//2. 取得結果
		
		return null;
	}