BaseDao之JDBC封装、增、删、改、查操作（超详细！）

2024-04-18 12:05:23

文章目录

- BaseDao介绍
- - BaseDao的核心特性
  - BaseDao基本操作特点
- JDBC封装增，删，改，查

BaseDao介绍

BaseDao是一种在Java开发中常用的数据访问对象（Data Access Object）模式的实现，它主要用于简化数据库操作，提高开发效率和代码的可维护性。BaseDao通常与ORM（对象关系映射）框架如MyBatis结合使用，以提供一套标准的数据库操作方法，如增删改查等。

BaseDao的核心特性

标准数据库操作方法：BaseDao提供了一系列标准的数据库操作方法，如insert、update、delete、select等，这些方法通常与数据库表一一对应，使得开发者可以直接调用接口中的方法来操作数据库，而无需关心具体的SQL语句实现。
简化SQL编写：通过BaseDao，开发者无需手写mapper.xml文件或手动编写SQL语句，BaseDao会自动根据接口方法和实体类属性生成相应的SQL语句，极大地减少了手动编写SQL的工作量。
支持复杂查询：BaseDao支持复杂查询的构建，如分页查询、条件查询等，以满足业务逻辑的各种需求。它通常利用注解处理器或代码生成技术在编译时自动生成Query类，这些Query类提供流式调用的方式，帮助开发者更直观方便地构建查询条件。
逻辑删除功能：BaseDao支持逻辑删除，即在删除操作时，不是物理删除记录，而是更新一个删除标记字段，这样被删除的记录仍然存在于数据库中，但不会被查询出来。
分库分表支持：BaseDao内置了分库分表功能，支持指定键分键和自定义分库分表算法，框架自动根据算法选择库表。同时也兼容第三方分库分表组件。
代码生成：BaseDao提供工具通过数据库表结构自动生成Entity类，提高开发效率。
字节码增强：采用字节码增强技术提高框架性能和效率，相比传统的反射调用方式性能表现显著提升。

BaseDao基本操作特点

BaseDao（基础数据访问对象）是一种常见的设计模式，用于在软件开发中提供数据库操作的抽象层。BaseDao的设计旨在简化数据库访问逻辑，减少代码冗余，并提高数据访问层的可维护性和可扩展性。以下是BaseDao基本操作的特点：

封装性
BaseDao封装了所有与数据库交互的细节，包括连接的创建与关闭、SQL语句的执行、参数的绑定和结果集的映射等。这种封装性使得上层业务逻辑不需要关心底层的数据库实现，只需调用BaseDao提供的方法即可完成数据操作。
通用性
BaseDao通常包含了一组通用的数据操作方法，如增删改查（CRUD）。这些方法可以应用于任何数据表或实体类，而不需要为每个数据表单独编写代码。通用性使得BaseDao可以作为多个数据访问层的基类或接口。
可扩展性
BaseDao的设计允许开发者通过继承或实现接口来扩展新的功能。例如，可以添加新的操作方法来处理特定业务逻辑的需求，或者覆盖已有方法以实现特定的数据处理逻辑。
灵活性
由于BaseDao提供了方法的模板，开发者可以根据需要选择合适的数据库访问技术（如JDBC、Hibernate、MyBatis等）来实现这些方法。这种灵活性使得BaseDao可以适应不同的项目需求和技术栈。
易于维护
BaseDao的封装和通用性使得数据访问层的代码更加简洁和易于维护。当数据库访问逻辑发生变化时，只需修改BaseDao中的相应方法，而不需要修改每个数据访问对象。
错误处理和日志记录
BaseDao通常会包含错误处理和日志记录的逻辑，以确保数据库操作的稳定性和可追踪性。这有助于及时发现和解决数据库访问过程中的问题。
事务管理
BaseDao可以集成事务管理功能，确保数据操作的原子性、一致性、隔离性和持久性（ACID属性）。通过BaseDao，开发者可以更容易地管理事务边界，实现复杂的业务逻辑。
性能优化
BaseDao可以通过缓存、连接池等技术来优化数据库访问性能。例如，可以重用数据库连接，减少连接创建和关闭的开销；可以通过缓存常用数据，减少对数据库的频繁访问。
数据映射
BaseDao可以集成对象关系映射（ORM）框架，如Hibernate或MyBatis，来简化Java对象和数据库记录之间的映射。这样可以减少手动编写SQL语句的工作量，并提高代码的可读性和可维护性。

BaseDao通过提供一套标准化和可复用的数据访问接口，使得数据库操作更加简单、高效和可靠。它是现代Java企业应用架构中不可或缺的一部分。

JDBC封装增，删，改，查

代码：

public class BaseDao {
    // 数据库驱动字符串
    private static final String driver = "com.mysql.cj.jdbc.Driver";
    // 连接URL字符串
    private static final String url = "jdbc:mysql://localhost:3306/workClothingDB";
    // 数据库用户名
    private static final String name = "root";
    // 数据库密码
    private static final String password = "sasa";

    // 连接对象
    private static Connection conn = null;
    // 预处理对象
    private static PreparedStatement pre = null;
    // 结果集对象
    private static ResultSet rs = null;


    /**
     * 获取连接的数据库对象
     * @return 返回获取到的数据库对象
     */
    public static Connection getConnection(){
        try {
            Class.forName(driver);
            conn = DriverManager.getConnection(url, name, password);
        } catch (ClassNotFoundException | SQLException e) {
            throw new RuntimeException(e);
        }
        return conn;
    }

    /**
     * 释放资源
     * @param rs    结果集对象
     * @param pre   预处理对象
     * @param conn  连接数据库对象
     */
    public static void closeAll(ResultSet rs, PreparedStatement pre, Connection conn){
        try {
            if (rs != null){
                rs.close();
            }
            if (pre != null){
                pre.close();
            }
            if (conn != null){
                conn.close();
            }
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }

    }

    /**
     * 增，删，改操作
     * @param sql   传入增，删，改的sql语句
     * @param objects   传入sql语句需要的数据，位置与sql需要的数据位置保持一致
     * @return  返回受影响的行数
     */
    public static int executeUpdate(String sql, Object... objects) {
        int row = 0;
        conn = getConnection();
        try {
            pre = conn.prepareStatement(sql);
            // 传入需要的参数
            for (int i = 0; i < objects.length; i++) {
                pre.setObject(i + 1, objects[i]);
            }
            row = pre.executeUpdate();
        } catch (Exception e){
            throw new RuntimeException(e);
        }finally {
            closeAll(null, pre, conn);
        }
        return row;
    }

    /**
     * 执行查询操作并返回结果集
     * @param sql       传入的sql语句
     * @param objects   传入sql语句需要的数据，位置与sql需要的数据位置保持一致
     * @return          返回查询的结果集
     */
    public static ResultSet executeQuery(String sql, Object... objects) {
        try {
            conn = getConnection();
            pre = conn.prepareStatement(sql);
            // 传入需要的参数
            for (int i = 0; i < objects.length; i++) {
                pre.setObject(i + 1, objects[i]);
            }
            rs = pre.executeQuery();
        } catch (SQLException e) {
            throw new RuntimeException(e);
        } finally {
            closeAll(rs, pre, conn);
        }
        return rs;
    }
}

在这个封装类中，我们定义了几个静态方法来处理数据库操作：

getConnection()：用于获取数据库连接。
executeQuery(String sql, Object... objects)：用于执行查询操作，返回ResultSet对象。
executeUpdate(String sql, Object... objects)：用于执行更新操作（如插入、更新、删除），返回受影响的行数。
closeAll(ResultSet rs, PreparedStatement pre, Connection conn)：用于关闭数据库资源，防止资源泄露。

使用这个封装类可以简化数据库操作的代码，使得代码更加简洁和易于维护。同时，通过异常处理和资源管理，可以确保数据库操作的稳定性和资源的正确释放。

，返回受影响的行数。

closeAll(ResultSet rs, PreparedStatement pre, Connection conn)：用于关闭数据库资源，防止资源泄露。

请注意，这个示例仅用于演示基本的JDBC封装，实际应用中可能需要根据项目需求进行更多的定制和优化，例如添加事务管理、连接池管理、日志记录等。此外，为了提高性能和安全性，建议使用连接池来管理数据库连接，而不是每次操作都创建和关闭新的连接。

码农公寓

文章目录

BaseDao介绍

BaseDao的核心特性

BaseDao基本操作特点

JDBC封装增，删，改，查

相关文章