DAO设计模式实现数据库的增删改查（进一步封装JDBC工具类）
一、DAO模式简介
DAO即Data Access Object，数据访问接口。数据访问：故名思义就是与数据库打交道。夹在业务逻辑与数据库资源中间。
DAO模式实际上是两个模式的组合，即Data Accessor (数据访问者)模式和 Active Domain Object(领域对象)模式。Data Accessor 模式实现了数据访问和业务逻辑的分离；Active Domain Object 模式实现了业务数据的对象化封装。
需要注意的是，DAO设计模式是Java EE中的设计模式，而非Java SE中的23种设计模式。
二、实现DAO模式
一个典型的DAO实现有下列几个组件：
- 一个DAO接口;
- 一个实现DAO接口的具体类;
- 数据传递对象(DTO)：有些时候叫做值对象(VO)或领域模型（domain）
这种实现模式就是一个套路，记熟就好了。不过在这之前，如果有不明白的地方，还是要回顾一下之前几篇博文中的知识：PreparedStatement接口重构增删改查、封装JDBC工具类。好了，下面直接上代码。
三、代码实现
我们一下面的这张数据表为例：
新建Java工程文件DaoTest01，最终的工程文件结构如下：
- DBUtils：初步封装的JDBC工具类；
- db-config.properties：属性文件，方便修改配置信息；
- Person类就是领域模型，表示是对它（数据库表）进行增删改查。
- PersonDao接口：专门对Person类进行操作（例如增删改查）的接口。注：这里不直接写操作类，是因为接口利于维护，可以在这里写上公共的代码。一个领域模型对应一个Dao接口。
- PeronDaoImpl类：实现上面的PeronDao接口
步骤如下：
注：第（1）、（2）步操作和上一篇博文是一模一样的，这里只是为了保证本篇文章的完整性，所以重新写一下。
（1）先新建一个DBUtils工具类：（package com.util.db）
1 package com.util.db;
2
3 import java.sql.Connection;
4 import java.sql.DriverManager;
5 import java.sql.ResultSet;
6 import java.sql.SQLException;
7 import java.sql.Statement;
8 import java.util.ResourceBundle;
9
10 /**
11 * 数据库操作工具类
12 * @author lamp
13 *
14 */
15 public class DBUtils {
16
17 //数据库连接地址
18 public static String URL;
19 //用户名
20 public static String USERNAME;
21 //密码
22 public static String PASSWORD;
23 //mysql的驱动类
24 public static String DRIVER;
25
26 private static ResourceBundle rb = ResourceBundle.getBundle("com.util.db.db-config");
27
28 private DBUtils(){}
29
30 //使用静态块加载驱动程序
31 static{
32 URL = rb.getString("jdbc.url");
33 USERNAME = rb.getString("jdbc.username");
34 PASSWORD = rb.getString("jdbc.password");
35 DRIVER = rb.getString("jdbc.driver");
36 try {
37 Class.forName(DRIVER);
38 } catch (ClassNotFoundException e) {
39 e.printStackTrace();
40 }
41 }
42 //定义一个获取数据库连接的方法
43 public static Connection getConnection(){
44 Connection conn = null;
45 try {
46 conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
47 } catch (SQLException e) {
48 e.printStackTrace();
49 System.out.println("获取连接失败");
50 }
51 return conn;
52 }
53
54 /**
55 * 关闭数据库连接
56 * @param rs
57 * @param stat
58 * @param conn
59 */
60 public static void close(ResultSet rs,Statement stat,Connection conn){
61 try {
62 if(rs!=null)rs.close();
63 if(stat!=null)stat.close();
64 if(conn!=null)conn.close();
65 } catch (SQLException e) {
66 e.printStackTrace();
67 }
68 }
69
70 }
注意：26行中，注意获取属性文件的包名是否正确。稍后会定义这个属性文件。
28行：既然是工具类，一般不要实例化，此时可以采用单例设计模式，或者将构造方法私有化。
26行：很明显可以看到，我们是将连接数据库的URL、用户名，密码等信息编写在一个属性文件（jdbc.properties）中，稍后再来定义这个属性文件。
31行：为避免重复代码，使用静态代码块：只会在类加载的时候执行一次。
42行：定义一个获取数据库连接的方法
60行：关闭数据库连接
（2）接下来新建一个属性文件，new-->file，命名为：db-config.properties，代码如下：
jdbc.url=jdbc:mysql://localhost:3306/jdbcdb jdbc.username=root jdbc.password=smyh jdbc.driver=com.mysql.jdbc.Driver
以后如果需要修改配置信息，只需要在这里改就行了。注意在上面的DBUtils类中是怎么来调用这个配置信息的。
紧接着新建文件，定义好Person类：(package com.vae.domain)
1 package com.vae.domain;
2
3 public class Person {
4 private int id;
5 private String name;
6 private int age;
7 private String description;
8 public int getId() {
9 return id;
10 }
11 public void setId(int id) {
12 this.id = id;
13 }
14 public String getName() {
15 return name;
16 }
17 public void setName(String name) {
18 this.name = name;
19 }
20 public int getAge() {
21 return age;
22 }
23 public void setAge(int age) {
24 this.age = age;
25 }
26 public String getDescription() {
27 return description;
28 }
29 public void setDescription(String description) {
30 this.description = description;
31 }
32 public Person(int id, String name, int age, String description) {
33 super();
34 this.id = id;
35 this.name = name;
36 this.age = age;
37 this.description = description;
38 }
39 public Person(String name, int age, String description) {
40 super();
41 this.name = name;
42 this.age = age;
43 this.description = description;
44 }
45 public Person() {
46 super();
47 // TODO Auto-generated constructor stub
48 }
49 @Override
50 public String toString() {
51 return "Person [id=" + id + ", name=" + name + ", age=" + age
52 + ", description=" + description + "]";
53 }
54
55
56 }
这个Person类就是领域模型，表示是对它进行增删改查。
（3）定义PersonDao接口：专门对Person类进行操作（例如增删改查）的接口(package com.vae.dao)
package com.vae.dao;
import java.sql.SQLException;
import java.util.List;
import com.vae.domain.Person;
public interface PersonDao {
//添加方法
public void add(Person p)throws SQLException;
//更新方法
public void update(Person p)throws SQLException;
//删除方法
public void delete(int id)throws SQLException;
//查找方法
public Person findById(int id)throws SQLException;
//查找所有
public List<Person> findAll()throws SQLException;
}
（4）定义PeronDaoImpl实现类 ，实现上面的PeronDao接口（package com.vae.dao.impl）
1 package com.vae.dao.impl;
2
3 import java.sql.Connection;
4 import java.sql.PreparedStatement;
5 import java.sql.ResultSet;
6 import java.sql.SQLException;
7 import java.util.ArrayList;
8 import java.util.List;
9
10 import com.util.db.DBUtils;
11 import com.vae.dao.PersonDao;
12 import com.vae.domain.Person;
13
14 /**
15 * PersonDao的具体实现类
16 * @author lamp
17 *
18 */
19 public class PersonDaoImpl implements PersonDao{
20
21 /**
22 * 实现添加方法
23 */
24 @Override
25 public void add(Person p) throws SQLException {
26 Connection conn = null;
27 PreparedStatement ps = null;
28 String sql = "insert into person(name,age,description)values(?,?,?)";
29 try{
30 conn = DBUtils.getConnection();
31 ps = conn.prepareStatement(sql);
32 ps.setString(1, p.getName());
33 ps.setInt(2, p.getAge());
34 ps.setString(3, p.getDescription());
35 ps.executeUpdate();
36 }catch(SQLException e){
37 e.printStackTrace();
38 throw new SQLException("添加数据失败");
39 }finally{
40 DBUtils.close(null, ps, conn);
41 }
42 }
43
44 /**
45 * 更新方法
46 */
47 @Override
48 public void update(Person p) throws SQLException {
49 Connection conn = null;
50 PreparedStatement ps = null;
51 String sql = "update person set name=?,age=?,description=? where id=?";
52 try{
53 conn = DBUtils.getConnection();
54 ps = conn.prepareStatement(sql);
55 ps.setString(1, p.getName());
56 ps.setInt(2, p.getAge());
57 ps.setString(3, p.getDescription());
58 ps.setInt(4, p.getId());
59 ps.executeUpdate();
60 }catch(SQLException e){
61 e.printStackTrace();
62 throw new SQLException("更新数据失败");
63 }finally{
64 DBUtils.close(null, ps, conn);
65 }
66 }
67
68 /**
69 * 删除方法
70 */
71 @Override
72 public void delete(int id) throws SQLException {
73 Connection conn = null;
74 PreparedStatement ps = null;
75 String sql = "delete from person where id=?";
76 try{
77 conn = DBUtils.getConnection();
78 ps = conn.prepareStatement(sql);
79 ps.setInt(1,id);
80 ps.executeUpdate();
81 }catch(SQLException e){
82 e.printStackTrace();
83 throw new SQLException(" 删除数据失败");
84 }finally{
85 DBUtils.close(null, ps, conn);
86 }
87 }
88
89 /**
90 * 根据ID查询一个对象
91 */
92 @Override
93 public Person findById(int id) throws SQLException {
94 Connection conn = null;
95 PreparedStatement ps = null;
96 ResultSet rs = null;
97 Person p = null;
98 String sql = "select name,age,description from person where id=?";
99 try{
100 conn = DBUtils.getConnection();
101 ps = conn.prepareStatement(sql);
102 ps.setInt(1, id);
103 rs = ps.executeQuery();
104 if(rs.next()){
105 p = new Person();
106 p.setId(id);
107 p.setName(rs.getString(1));
108 p.setAge(rs.getInt(2));
109 p.setDescription(rs.getString(3));
110 }
111 }catch(SQLException e){
112 e.printStackTrace();
113 throw new SQLException("根据ID查询数据失败");
114 }finally{
115 DBUtils.close(rs, ps, conn);
116 }
117 return p;
118 }
119
120 /**
121 * 查询所有数据
122 */
123 @Override
124 public List<Person> findAll() throws SQLException {
125 Connection conn = null;
126 PreparedStatement ps = null;
127 ResultSet rs = null;
128 Person p = null;
129 List<Person> persons = new ArrayList<Person>();
130 String sql = "select id,name,age,description from person";
131 try{
132 conn = DBUtils.getConnection();
133 ps = conn.prepareStatement(sql);
134 rs = ps.executeQuery();
135 while(rs.next()){
136 p = new Person();
137 p.setId(rs.getInt(1));
138 p.setName(rs.getString(2));
139 p.setAge(rs.getInt(3));
140 p.setDescription(rs.getString(4));
141 persons.add(p);
142 }
143 }catch(SQLException e){
144 e.printStackTrace();
145 throw new SQLException("查询所有数据失败");
146 }finally{
147 DBUtils.close(rs, ps, conn);
148 }
149 return persons;
150 }
151
152 }