一、什么是Dao设计模式
Dao设计模式封装了操作具体数据库的细节，对业务层提供操作数据库的接口，因此降低了业务层代码与具体数据库之间的耦合，有利于人员分工，增加了程序的可移植性。
Dao设计模式中主要包含这5个模块：
1、VO类：VO（Value Object）即值对象，每一个值对象对应一张数据库表，便于我们传递数据。
2、Dao接口：Dao接口定义了操作数据库的方法，业务层通过调用这些方法来操作数据库。
3、Dao实现类：操作数据库的方法的具体实现，封装了操作数据库的细节。
4、Dao工厂类：用于代替new操作，进一步降低业务层与数据层之间的耦合。
5、数据库连接类：封装了连接数据库、关闭数据库等常用的操作，减少重复编码。
下面我们应用Dao设计模式来实现一个简单的转账操作，加深对其的理解。
二、Dao设计模式实现
首先，我们创建vo、dao、factory、util包来分别存放Dao设计模式5个模块的代码。因为我们使用的是JDBC连接MySQL数据库，所以还需要创建一个lib包存放并引用JDBC驱动。除此之外，我们还需要创建一个test包进行代码的测试。创建好后的目录结构如下：
接着设计一张user表，表中包含了用户基本信息和余额，并插入一些数据。
根据user表在vo包中创建VO类user.java。
package vo; public class User { private int id; private String username; private int sum; 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 int getSum() {
return sum;
} public void setSum(int sum) {
this.sum = sum;
} @Override
public String toString() {
return "User [id=" + id + ", username=" + username + ", sum=" + sum + "]";
} }
在util包中创建数据库连接类JDBC.java。
package util; import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement; public class JDBC {
//获取数据库链接
public static Connection getConnection() {
Connection con = null;
try {
String url = "jdbc:mysql://localhost:3306/user?serverTimezone=Asia/Shanghai";
Class.forName("com.mysql.cj.jdbc.Driver");
con = DriverManager.getConnection(url, "root", "root");
} catch (Exception e) {
e.printStackTrace();
}
return con;
}
//关闭资源
public static void close(Connection con, Statement st, ResultSet rs) {
try {
if (rs != null) {
rs.close();
}
if (st != null) {
st.close();
}
if (con != null) {
con.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
经过分析，该转账系统需要两类数据库操作，分别是“查询用户信息”和“更新用户余额”。因此我们在dao包中创建IUserDao.java接口并定义这两种方法。
package dao; import java.sql.Connection;
import java.sql.SQLException; import vo.User; public interface IUserDao {
//根据用户名查找用户信息
public User selectUserByName(Connection con, User user);
//根据用户名更新用户余额
public int updateSumByName(Connection con, User user) throws SQLException;
}
接着在dao包中创建该接口的实现类UserDaoImpl.java，实现这两种方法。
package dao; import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException; import util.JDBC;
import vo.User; public class UserDaoImpl implements IUserDao { @Override
public User selectUserByName(Connection con, User user) {
String sql = "select * from user where username = ?";
PreparedStatement pStatement = null;
ResultSet rs = null;
try {
pStatement = con.prepareStatement(sql);
pStatement.setString(1, user.getUsername());
rs = pStatement.executeQuery();
if (rs.next()) {
user.setId(rs.getInt("id"));
user.setUsername(rs.getString("username"));
user.setSum(rs.getInt("sum"));
return user;
}
} catch (SQLException e) {
e.printStackTrace();
}finally {
JDBC.close(null, pStatement, rs);
}
return null;
} @Override
public int updateSumByName(Connection con, User user) throws SQLException {
String sql = "update user set sum = ? where username = ?";
PreparedStatement pStatement = null;
try {
pStatement = con.prepareStatement(sql);
pStatement.setInt(1, user.getSum());
pStatement.setString(2, user.getUsername());
return pStatement.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
//抛出异常，便于进行事务处理
throw e;
}finally {
JDBC.close(null, pStatement, null);
}
}
}
最后，我们还需要在factory包中创建Dao工厂类DaoFactory.java。
package factory; import dao.IUserDao;
import dao.UserDaoImpl; public class DaoFactory {
public static IUserDao getUserDao() {
return new UserDaoImpl();
}
}
到这里，转账系统的Dao层就设计好了。我们在test包中创建Main.java进行测试。
package test; import java.sql.Connection;
import java.sql.SQLException; import dao.IUserDao;
import factory.DaoFactory;
import util.JDBC;
import vo.User; public class Main { public static void main(String[] args) {
Connection con = JDBC.getConnection();
IUserDao userDao = DaoFactory.getUserDao();
//被转账的用户
User user_in = new User();
user_in.setUsername("ysy");
user_in = userDao.selectUserByName(con, user_in);
System.out.println(user_in);
//转账的用户
User user_out = new User();
user_out.setUsername("管理员");
user_out = userDao.selectUserByName(con, user_out);
System.out.println(user_out);
//转账30元
user_in.setSum(user_in.getSum() + 30);
user_out.setSum(user_out.getSum() - 30);
//事务处理
try {
con.setAutoCommit(false);
userDao.updateSumByName(con, user_in);
userDao.updateSumByName(con, user_out);
con.commit();
} catch (Exception e) {
e.printStackTrace();
try {
con.rollback();
} catch (SQLException e1) {
e1.printStackTrace();
}
}
//查询转账结果
user_in = userDao.selectUserByName(con, user_in);
System.out.println(user_in);
user_out = userDao.selectUserByName(con, user_out);
System.out.println(user_out);
JDBC.close(con, null, null);
}
}
执行结果如下：
最终的目录结构如下：
