【java】DAO编程思想

博主：本当迷
发布时间：2022 年 07 月 16 日
1147 次浏览
1 条评论
8049字数
分类： java

### 介绍

* BaseDAO主要用来与数据库的交互操作
* StudentDAO是一个接口，用来规范StudentDAOImpl这个类的功能实现
* StudantDAOImpl用来继承BaseDAO类并且实现StudentDAO接口

![](https://www.bdmcom.cn/usr/uploads/2022/07/2788833116.png)

### BaseDAO

```JAVA
package daoUpgrade;

import util.JDBCUtils;

import java.lang.reflect.Field;
import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;

/**
 * @code Description 封装了针对于数据表的增删改(dao基础班的升级版)
 * @code author 本当迷
 * @code date 2022/7/15-18:42
 */

public abstract class BaseDAO <T>{
    private Class<T> clazz = null;
    {
        final Type genericSuperclass = this.getClass().getGenericSuperclass();
        final ParameterizedType parameterizedType = (ParameterizedType) genericSuperclass;
        // 获取了父类的泛型
        final Type[] typeArguments = parameterizedType.getActualTypeArguments();
        // 泛型的第一个参数
        clazz = (Class<T>) typeArguments[0];
    }

public <E> E getValue(Connection conn, String sql, Object ...args) {
        PreparedStatement ps = null;
        ResultSet rs = null;
        try {
            // 预编译sql
            ps = conn.prepareStatement(sql);

// 填充占位符
            for(int i = 0; i < args.length; i++){
                ps.setObject(i+1, args[i]);
            }

// 执行
            rs = ps.executeQuery();
            if(rs.next()){
                return (E) rs.getObject(1);
            }
        } catch (SQLException e) {
            throw new RuntimeException(e);
        } finally {
            // 资源关闭
            JDBCUtils.closeResource(null, ps, rs);
        }
        return null;
    }

// 通用的增删改操作
    public int getUpdate(Connection conn, String sql, Object ...args) {
        PreparedStatement ps = null;

try {

// sql预编译
            ps = conn.prepareStatement(sql);

// 填充sql占位符
            for(int i = 0; i < args.length; i++){
                ps.setObject(i+1, args[i]);
            }

// 执行sql语句
            return ps.executeUpdate();

} catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            // 关闭资源
            JDBCUtils.closeResource(null, ps);
        }
    }

// 通用的查询:用于返回数据表中的多条记录构成的集合
    public List<T> getForList(Connection conn, String sql, Object ...args) {

PreparedStatement ps = null;
        ResultSet rs = null;

try {

// 预编译sql语句
            ps = conn.prepareStatement(sql);
            for(int i = 0; i < args.length; i++){
                ps.setObject(i + 1, args[i]);
            }

// 获取结果集
            rs = ps.executeQuery();

// 获取元数据
            final ResultSetMetaData metaData = rs.getMetaData();
            // 获取字段的数量
            final int columnCount = metaData.getColumnCount();

final ArrayList<T> list = new ArrayList<>();
            while (rs.next()){
                // 获取对象的一个实例对象
                final T t = clazz.getConstructor().newInstance();
                for(int i = 0; i < columnCount; i++){
                    // 获取字段具体的值
                    final Object objectValue = rs.getObject(i + 1);

// 获取字段的别名
                    final String columnLabel = metaData.getColumnLabel(i + 1);

// 利用反射给对象赋值
                    final Field field = clazz.getDeclaredField(columnLabel);
                    field.setAccessible(true);
                    field.set(t, objectValue);
                }
                list.add(t);

}
            return list;
        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            // 关闭资源
            JDBCUtils.closeResource(null, ps, rs);
        }

}

// 针对于不同的表的通用的查询操作，返回表中的一条记录
    public T getInstance(Connection conn, String sql, Object ...args) {

PreparedStatement ps = null;
        ResultSet rs = null;
        try {

// 2.预编译sql语句，得到prepareStatement对象
            ps = conn.prepareStatement(sql);

// 3.填充占位符
            for(int i = 0; i < args.length; i++){
                ps.setObject(i+1, args[i]);
            }

// 执行executeQuery（），得到结果集
            rs = ps.executeQuery();

// 获取结果集元数据：ResultSetMetaData
            final ResultSetMetaData rsmd = rs.getMetaData();

// 通过ResultSetMetaData获取结果集中的列数
            final int columnCount = rsmd.getColumnCount();

if(rs.next()){
                final T t = clazz.getConstructor().newInstance();

// 处理结果集一行数据中的每一列
                for(int i = 0; i < columnCount; i++){
                    // 获取列值
                    final Object columValue = rs.getObject(i + 1);

// 获取每个列的别名
                    final String columnLabel = rsmd.getColumnLabel(i + 1);

// 给cust对象指定columnName属性，赋值为columValue,通过反射
                    final Field field = clazz.getDeclaredField(columnLabel);
                    field.setAccessible(true);
                    field.set(t, columValue);
                }

return t;
            }
        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            JDBCUtils.closeResource(null, ps, rs);
        }
        return null;

}

```

### StudentDAO

```java
package daoUpgrade;

import bean.Customer;

import java.sql.Connection;
import java.sql.Date;
import java.util.List;

/**
 * @code Description
 * @code author 本当迷
 * @code date 2022/7/15-19:30
 */
public interface CustomerDAO {

// 将 cust 对象添加到数据库中
    void insert(Connection conn, Customer cust);

// 针对指定的id，删除表中的一条记录
    void deleteById(Connection conn, int id);

// 针对内存中的 cust 对象, 修改数据表中指定的记录
    void updateById(Connection conn, Customer cust);

// 针对指定的id查询对应的Customer信息
    Customer getCustomerById(Connection conn, int id);

// 查询所有记录构成的集合
    List<Customer> getAll(Connection conn);

// 返回数据表中的数据的条目数
    Long getCount(Connection conn);

// 返回数据表中最大的生日
    Date getMaxBirth(Connection conn);

}

```

### StudentDAOImpl

```java
package daoUpgrade;

import bean.Customer;

import java.sql.Connection;
import java.sql.Date;
import java.util.List;

/**
 * @code Description
 * @code author 本当迷
 * @code date 2022/7/15-19:42
 */
public class CustomerDAOImpl extends BaseDAO<Customer> implements CustomerDAO {

@Override
    public void insert(Connection conn, Customer cust) {
        String sql = "insert into customers (name, email, birth) values (?, ?, ?)";
        getUpdate(conn, sql, cust.getName(),cust.getEmail(), cust.getBirth());
    }

@Override
    public void deleteById(Connection conn, int id) {
        String sql = "delete from customers where id = ?";
        getUpdate(conn, sql, id);
    }

@Override
    public void updateById(Connection conn, Customer cust) {
        String sql = "update customers set name = ?, email = ?, birth = ? where id = ?";
        getUpdate(conn, sql, cust.getName(), cust.getEmail(), cust.getBirth(), cust.getId());
    }

@Override
    public Customer getCustomerById(Connection conn, int id) {
        String sql = "select id, name, email, birth from customers where id = ?";
        return getInstance(conn, sql, id);
    }

@Override
    public List<Customer> getAll(Connection conn) {
        String sql = "select id, name, email, birth from customers";
        return  getForList(conn, sql);
    }

@Override
    public Long getCount(Connection conn) {
        String sql = "select count(*) from customers";
        return getValue(conn, sql);

}

@Override
    public Date getMaxBirth(Connection conn) {
        String sql = "select max(birth) from customers";
        return getValue(conn, sql);
    }

}

```

最后修改：2022 年 07 月 16 日

如果文章有用，请随意打赏。

1 条评论

rantrism
July 25th, 2022 at 04:15 pm

您好～我是腾讯云开发者社区的运营，关注了您分享的技术博客，觉得内容很棒，我们诚挚邀请您加入腾讯云自媒体分享计划。完整福利和申请地址请见：https://cloud.tencent.com/developer/support-plan 作者申请此计划后将作者的文章进行搬迁同步到社区的专栏下，你只需要简单填写一下表单申请即可，我们会给作者提供包括流量、云服务器等，另外还有些周边礼物。

回复

发表评论取消回复
使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款

评论 *

私密评论

名称 *

🎲

邮箱 *

地址

【java】DAO编程思想

本当迷 • 2022 年 07 月 16 日