Java通过JDBC 进行Dao层的封装

前言

前面有一章节，我专门讲解了Java通过JDBC 进行MySQL数据库操作，这主要讲解了MySQL数据库的连接和简单的操作，但是在真正的Java项目中，我们要不断的和数据库打交道，为了提高数据库操作的执行效率和增加代码的复用性，将重新封装一个Dao层，也就是数据访问层 ，用来访问数据库实现数据的持久化。

Dao层设计

Dao层操作通用的步骤：

• 1.写SQL语句
• 2.获取连接
• 3.创建stmt
• 4.执行sql

a)更新 
String sql = “delete from admin where id=?””; 
String sql = “insert into admin (userName,pwd) values (?,?)” 
public void update(String sql, Object[] paramValues);

b)查询 
String sql = “select * from admin”; 
String sql = “select * from admin where id=? And pwd =?”; 
// 传入的什么类型的对象，就封装为什么类型 
// 要求： 列的名称，要与指定类型的对象的属性名称一样 
Public List query (String sql , Object[] paramValues , Class clazz); 
T t; // 对象赋值

• 5.关闭/异常

编写BaseDao，自己写的所有的Dao都继承此类

其中JDBCUtil类在上篇博文Java通过JDBC 进行MySQL数据库操作中有详细介绍，这里就比说了。

/**
 * 通用的dao，自己写的所有的dao都继承此类;
 * 此类定义了2个通用的方法：
 *  1. 更新
 *  2. 查询
 * @author Charlie.chen
 *
 */
public class BaseDao {

    // 初始化参数
    private Connection con;
    private PreparedStatement pstmt;
    private ResultSet rs;


    /**
     * 查询的通用方法
     * @param sql
     * @param paramsValue
     */
    public <T> List<T> query(String sql, Object[] paramsValue,Class<T> clazz){

        try {
            // 返回的集合
            List<T> list = new ArrayList<T>();
            // 对象
            T t = null;

            // 1. 获取连接
            con = JdbcUtil.getConnection();
            // 2. 创建stmt对象
            pstmt = con.prepareStatement(sql);
            // 3. 获取占位符参数的个数， 并设置每个参数的值
            int count = pstmt.getParameterMetaData().getParameterCount();
            if (paramsValue != null && paramsValue.length > 0) {
                for (int i=0; i<paramsValue.length; i++) {
                    pstmt.setObject(i+1, paramsValue[i]);
                }
            }
            // 4. 执行查询
            rs = pstmt.executeQuery();
            // 5. 获取结果集元数据
            ResultSetMetaData rsmd = rs.getMetaData();
            // ---> 获取列的个数
            int columnCount = rsmd.getColumnCount();

            // 6. 遍历rs
            while (rs.next()) {
                // 要封装的对象
                t = clazz.newInstance();

                // 7. 遍历每一行的每一列, 封装数据
                for (int i=0; i<columnCount; i++) {
                    // 获取每一列的列名称
                    String columnName = rsmd.getColumnName(i + 1);
                                        // 获取每一列的列名称, 对应的值
                    Object value = rs.getObject(columnName);
                    // 封装： 设置到t对象的属性中  【BeanUtils组件】
                    BeanUtils.copyProperty(t, columnName, value);               
                }

                // 把封装完毕的对象，添加到list集合中
                list.add(t);
            }

            return list;
        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            JdbcUtil.closeAll(con, pstmt, rs);
        }
    }



    /**
     * 更新的通用方法
     * @param sql   更新的sql语句(update/insert/delete)
     * @param paramsValue  sql语句中占位符对应的值(如果没有占位符，传入null)
     */
    public void update(String sql,Object[] paramsValue){

        try {
            // 获取连接
            con = JdbcUtil.getConnection();
            // 创建执行命令的stmt对象
            pstmt = con.prepareStatement(sql);
            // 参数元数据： 得到占位符参数的个数
            int count = pstmt.getParameterMetaData().getParameterCount();

            // 设置占位符参数的值
            if (paramsValue != null && paramsValue.length > 0) {
                // 循环给参数赋值
                for(int i=0;i<count;i++) {
                    pstmt.setObject(i+1, paramsValue[i]);
                }
            }
            // 执行更新
            pstmt.executeUpdate();

        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            JdbcUtil.closeAll(con, pstmt, null);
        }
}

编写实际操作的Dao类继承自BaseDao

public class AdminDao extends BaseDao {

    // 删除
    public void delete(int id) {
        String sql = "delete from admin where id=?";
        Object[] paramsValue = {id};
        super.update(sql, paramsValue);
    }

    // 插入
    public void insert(Admin admin) {
        String sql = "insert into admin (userName,pwd) values (?,?)";
        Object[] paramsValue = {admin.getUserName(),admin.getPwd()};
        super.update(sql, paramsValue);
    }

    // 查询全部
    public List<Admin> getAll(){
        String sql = "select * from admin";
        List<Admin> list = super.query(sql, null, Admin.class);
        return list;
    }

    // 根据条件查询(主键)
    public Admin findById(int id){
        String sql = "select * from admin where id=?";
        List<Admin> list = super.query(sql, new Object[]{id}, Admin.class);
        return  (list!=null&&list.size()>0) ? list.get(0) : null;
    }
}

JavaBean类

/**
 * 1. bean类设计
 * @author Charlie.chen
 *
 */
public class Admin {

    private int id;
    private String userName;
    private String pwd;
    private int age;
    private Date birth;


    public Date getBirth() {
        return birth;
    }
    public void setBirth(Date birth) {
        this.birth = birth;
    }
    public int getAge() {
        return age;
    }
    public void setAge(int age) {
        this.age = age;
    }
    public String getPwd() {
        return pwd;
    }
    public void setPwd(String pwd) {
        this.pwd = pwd;
    }
    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;
    }
    @Override
    public String toString() {
        return "Admin [age=" + age + ", birth=" + birth + ", id=" + id
                + ", pwd=" + pwd + ", userName=" + userName + "]";
    }   
}