Dao设计模式简单实现

一、什么是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);
    }
}

　　执行结果如下：

　　最终的目录结构如下：