1. 前言

  在本人開發的一個系統中需要提供註冊和登陸系統，自然需要有使用者管理，對使用者需要進行基礎的增刪改查，DAO是常用的設計模式之一，對資料訪問進行抽象，可以大大減低不同的資料庫之間移植的工作量，本文主要根據本人實現自己DAO模型的過程，講述DAO設計模式以及本人是如何使用DAO實現對資料的訪問的。

2. DAO設計模式

  DAO全程是Data Access Object，是J2EE核心模式之一，主要用於上層應用程式與持久化機制之間的中間層，對於底層的資料庫持久化，其各部分關係答題如下：
使用DAO的好處是可以使上下的各個模組相對獨立，只要DAO的介面不變化，即使上層的應用程式碼或者底層的持久層的實現頻繁變化，相互之間幾乎沒有影響。 使用DAO設計模式的時候需要注意的是儘量不要讓底層的實現洩露給上層，DAO的核心是DAO介面（interface），DAO由以下幾個部分組成：     DatabaseConnection： 專門負責資料庫的開啟與關閉的類。     VO：主要由屬性、setter、getter方法組成，VO類中的屬性與表中的欄位相對應，每個VO類的物件都表示表中的一條記錄。     DAO：主要定義操作的介面，定義一系列資料庫的原子性操作標準，如增加、修改、刪除、插入、按照ID查詢等。     Impl：DAO介面的真實實現類，完成具體的資料庫操作，但是不負責資料庫的開啟和關閉。     Proxy：代理實現類，主要完成資料庫的開啟和關閉，並且呼叫真實實現類物件的操作。     Factory：工廠類，通過工廠類取得一個DAO 的例項化物件。

3. 編碼實現

    下面我們實現一個對使用者進行增刪改查的DAO樣例，各個包的含義如下：      ebs.dao.factory: 裡面主要存放獲取資料庫連線例項的工廠類      ebs.dao.proxy:   DAO的代理實現      ebs.dao.user:    DAO的實現      ebs.dbc.DBConnection: 主要存放資料庫連線相關的實現類      ebs.system.vo: 主要存放VO類的實現      即，如下：       資料庫表User結構如下:
下面講解程式碼的具體實現，DAO模式的核心是DAO介面的設計，首先看一下底層資料庫連線的實現： 首先，在IDBConnection.java中實現資料庫連線的介面：

package ebs.dbc.DBConnection;

import java.sql.Connection;

public interface IDBConnection {
	public Connection getConnection();
	public void close() throws Exception;
}
 

介面可以有多種實現，由於目前我用的是MySQL資料庫所以我按照MySQL的API實現對應的資料庫連線類，後續移植到Oracle等資料庫上的時候只要替換這個類的實現就OK了，上層的應用程式無需修改，因為上層是通過介面IDBConnection來操作資料庫連線的。 MySQLDBConnection.java 實現如下：

package ebs.dbc.DBConnection;

import java.sql.Connection;
import java.sql.DriverManager;

public class MySQLDBConnection implements IDBConnection {
	public static final String DBDRIVER = "org.gjt.mm.mysql.Driver";
	public static final String DBURL = "jdbc:mysql://localhost:3306/mldn";
	public static final String DBUSER = "root";
	public static final String DBPASSWD = "root";
	private Connection conn = null;
	
	public MySQLDBConnection() throws Exception {
		try {
			Class.forName(DBDRIVER);
			this.conn = DriverManager.getConnection(DBURL, DBUSER, DBPASSWD);
		} catch (Exception e) {
			throw e;
		}
	}
	
	public Connection getConnection() {
		return this.conn;
	}
	
	public void close() throws Exception {
		if (this.conn != null) {
			try {
				this.conn.close();
			} catch (Exception e) {
				throw e;
			}
		} 
	}
}

下面是資料庫的工廠類，通過工廠類可以獲取資料庫的連線例項： DBConnectionFactory.java

package ebs.dao.factory;

import ebs.dbc.DBConnection.MySQLDBConnection;

public class DBConnectionFactory {
	private static MySQLDBConnection dbc = null;
	public static MySQLDBConnection getDatabaseConnection() throws Exception {
		if (dbc == null) {
			try {
				dbc = new MySQLDBConnection();
			} catch (Exception e) {
				throw e;
			}
		}
		return dbc;
	}
}

上面基本上就是資料庫連線實現的全部了，下面要實現使用者操作相關的DAO，首先實現VO類User.java:

package ebs.system.vo;

import java.util.Date;

public class User {
	
	private int id;
	private String username;
	private String nickname;
	private String email;
	private Date reg_time;
	private String passwd;
	
	public int getId() {
		return id;
	}
	public void setId(int id) {
		this.id = id;
	}
	public String getUsername() {
		return username;
	}
	public void setUsername(String username) {
		this.username = username;
	}
	public String getNickname() {
		return nickname;
	}
	public void setNickname(String nickname) {
		this.nickname = nickname;
	}
	public String getEmail() {
		return email;
	}
	public void setEmail(String email) {
		this.email = email;
	}
	public Date getReg_time() {
		return reg_time;
	}
	public void setReg_time(Date reg_time) {
		this.reg_time = reg_time;
	}
	public String getPasswd() {
		return passwd;
	}
	public void setPasswd(String passwd) {
		this.passwd = passwd;
	}
}

下面要定義的就是DAO的核心，DAO介面，要設計好自己打算在DAO中提供哪些服務， IUserDAO.java:

package ebs.dao.user;

import java.util.List;

import ebs.system.vo.User;

public interface IUserDAO {
	
	public boolean doCreate(User user) throws Exception;

	public boolean doDelete(int id) throws Exception;

	public boolean doModify(User user) throws Exception;

	public List<User> findAll(String keyWord) throws Exception;

	public User findById(int id) throws Exception;
}

下面實現這個介面， UserDAOImpl.java:

package ebs.dao.user;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

import ebs.system.vo.User;

public class UserDAOImpl implements IUserDAO {

	private Connection conn = null;
	private PreparedStatement pstmt = null;
	
	public UserDAOImpl(Connection conn) {
		this.conn = conn;
	}
	
	@Override
	public boolean doCreate(User user) throws Exception {
		boolean flag = false;
		String sql = "INSERT INTO user(username, nickname, email, reg_time, passwd) VALUES(?, ?, ?, ?, ?);";
		this.pstmt = this.conn.prepareStatement(sql);
		this.pstmt.setString(1, user.getUsername());
		this.pstmt.setString(2, user.getNickname());
		this.pstmt.setString(3, user.getEmail());
		this.pstmt.setDate(4, new java.sql.Date(System.currentTimeMillis()));
		this.pstmt.setString(5, user.getPasswd());
		if (this.pstmt.executeUpdate() > 0) {
			flag = true;
		}
		this.pstmt.close();
		return flag;
	}

	@Override
	public boolean doDelete(int id) throws Exception {
		boolean flag = false;
		String sql = "DELETE FROM user WHERE id=?";
		this.pstmt = this.conn.prepareStatement(sql);
		this.pstmt.setInt(1, id);
		if (this.pstmt.executeUpdate(sql) > 0) {
			flag = true;
		}
		this.pstmt.close();
		return flag; 
	}

	@Override
	public boolean doModify(User user) throws Exception {
		boolean flag = false;
		String sql = "UPDATE USER SET username=?, nickname=?, email=?, passwd=? WHERE id=?;";
		this.pstmt = this.conn.prepareStatement(sql);
		this.pstmt.setString(1, user.getUsername());
		this.pstmt.setString(2, user.getNickname());
		this.pstmt.setString(3, user.getEmail());
		this.pstmt.setString(4, user.getPasswd());
		this.pstmt.setInt(5, user.getId());
		if(this.pstmt.executeUpdate(sql) > 0) {
			flag = true;
		}
		this.pstmt.close();
		return flag;
	}

	@Override
	public List<User> findAll(String keyWord) throws Exception {
		List<User> userlist = new ArrayList<User>();
		String sql = "SELECT username, nickname, email, reg_time, passwd FROM user WHERE username LIKE ? OR nickname LIKE ?;";
		this.pstmt = this.conn.prepareStatement(sql);
		this.pstmt.setString(1, keyWord);
		this.pstmt.setString(2, keyWord);
		ResultSet rs = this.pstmt.executeQuery(sql);
		User user = null;
		while(rs.next()) {
			user = new User();
			user.setUsername(rs.getString(1));
			user.setNickname(rs.getString(2));
			user.setEmail(rs.getString(3));
			user.setReg_time(rs.getDate(4));
			user.setPasswd(rs.getString(5));
			userlist.add(user);
		}
		this.pstmt.close();		
		return userlist;
	}

	@Override
	public User findById(int id) throws Exception {
		User user = null;
		String sql = "SELECT username, nickname, email, reg_time, passwd FROM user WHERE id=?;";
		this.pstmt = this.conn.prepareStatement(sql);
		this.pstmt.setInt(1, id);
		ResultSet rs = this.pstmt.executeQuery(sql);
		if(rs.next()) {
			user.setUsername(rs.getString(1));
			user.setNickname(rs.getString(2));
			user.setEmail(rs.getString(3));
			user.setReg_time(rs.getDate(4));
			user.setPasswd(rs.getString(5));
		}
		this.pstmt.close();
		return user;
	}

}

下面是DAO的代理類的實現，代理類其實是包裝了DAO的真實實現類，UserDAOProxy.java:

package ebs.dao.proxy;

import java.util.List;

import ebs.dao.factory.DBConnectionFactory;
import ebs.dao.user.IUserDAO;
import ebs.dao.user.UserDAOImpl;
import ebs.dbc.DBConnection.IDBConnection;
import ebs.system.vo.User;

public class UserDAOProxy implements IUserDAO {
	
	private <strong>IDBConnection</strong> dbc = null;
	private <strong>IUserDAO</strong> user = null;
	public UserDAOProxy() throws Exception {
		this.dbc = (IDBConnection)DBConnectionFactory.getDatabaseConnection();
		this.user = new UserDAOImpl(dbc.getConnection());
	}

	@Override
	public boolean doCreate(User user) throws Exception {
		boolean flag = false;
		try {
			flag = this.user.doCreate(user);
		} catch (Exception e) {
			throw e;
		} finally {
			this.dbc.close();
		} 
		return flag;
	}

	@Override
	public boolean doDelete(int id) throws Exception {
		boolean flag = false;
		try {
			flag = this.user.doDelete(id);
		} catch (Exception e) {
			throw e;
		} finally {
			this.dbc.close();
		}
		return flag;
	}

	@Override
	public boolean doModify(User user) throws Exception {
		boolean flag = false;
		try {
			flag = this.user.doModify(user);
		} catch (Exception e) {
			throw e;
		} finally {
			this.dbc.close();
		}
		return flag;
	}

	@Override
	public List<User> findAll(String keyWord) throws Exception {
		List<User> userlist = null;
		try {
			userlist = this.user.findAll(keyWord);
		} catch (Exception e) {
			throw e;
		} finally {
			this.dbc.close();
		}
		return userlist;
	}

	@Override
	public User findById(int id) throws Exception {
		User user = null;
		try {
			user = this.user.findById(id);
		} catch (Exception e) {
			throw e;
		} finally {
			this.dbc.close();
		}
		return null;
	}
}

這類需要仔細檢視的是DAO是如何獲取資料庫連線的，以及如何獲取DAO的真實實現的例項的。

4. 參考資料