Java 中怎么在自定义 JDBC 模板工具类中使用泛型和回调函数规范事务管理代码块-java教程-PHP中文网

java中可通过自定义泛型jdbc模板类封装事务管理、资源释放与sql执行逻辑，支持connectioncallback等回调接口实现类型安全与解耦；核心方法executeintransaction统一处理连接获取、事务控制及异常回滚，并确保资源关闭。

java 中怎么在自定义 jdbc 模板工具类中使用泛型和回调函数规范事务管理代码块

在 Java 中，通过自定义 JDBC 模板工具类结合泛型和回调函数（如 ConnectionCallback 或 PreparedStatementCallback），可以将事务管理、资源释放、SQL 执行等重复逻辑抽离，同时保持类型安全与业务代码解耦。核心思路是：用泛型统一返回类型，用函数式接口封装需在事务中执行的数据库操作，由模板类统一控制连接获取、事务开启/提交/回滚、异常处理与资源关闭。

定义回调函数接口（支持泛型返回）

为适配不同 SQL 操作的返回值（如 Integer、List<user></user>、Boolean 等），定义一个泛型回调接口：

public interface ConnectionCallback<t> {
    T doInConnection(Connection con) throws SQLException;
}</t>

该接口只暴露 Connection，由调用方自行创建 Statement/PreparedStatement，适合需要精细控制（如批量、多语句、存储过程）的场景。也可按需补充 PreparedStatementCallback<t></t> 或 ResultSetExtractor<t></t> 等更细粒度接口。

实现带事务管理的 JDBC 模板主方法

模板类（如 JdbcTemplate）提供一个核心方法 executeInTransaction，负责：

Alibabacloud Sdk Client Initialization For Java

在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。

下载

从数据源获取连接，并设置 autoCommit = false
执行回调逻辑，捕获所有 SQLException
成功则提交事务，失败则回滚
无论成败都确保连接关闭（使用 try-with-resources 或 finally）

public <t> T executeInTransaction(ConnectionCallback<t> action) throws SQLException {
    try (Connection con = dataSource.getConnection()) {
        con.setAutoCommit(false);
        try {
            T result = action.doInConnection(con);
            con.commit();
            return result;
        } catch (SQLException e) {
            con.rollback();
            throw e;
        }
    }
}</t></t>

使用示例：插入并返回主键、查询列表、更新计数

业务代码只需关注 SQL 和结果映射，无需写样板事务代码：

插入并获取生成的主键：

Long userId = template.executeInTransaction(con -> {
    String sql = "INSERT INTO user(name, email) VALUES (?, ?)";
    try (PreparedStatement ps = con.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS)) {
        ps.setString(1, "Alice");
        ps.setString(2, "a@example.com");
        int affected = ps.executeUpdate();
        if (affected == 0) throw new SQLException("Insert failed");
        try (ResultSet rs = ps.getGeneratedKeys()) {
            return rs.next() ? rs.getLong(1) : null;
        }
    }
});

查询用户列表（泛型自动推导为 List<user></user>）：

List<user> users = template.executeInTransaction(con -> {
    String sql = "SELECT id, name, email FROM user WHERE status = ?";
    try (PreparedStatement ps = con.prepareStatement(sql)) {
        ps.setInt(1, 1);
        try (ResultSet rs = ps.executeQuery()) {
            List<user> list = new ArrayList();
            while (rs.next()) {
                list.add(new User(rs.getLong("id"), rs.getString("name"), rs.getString("email")));
            }
            return list;
        }
    }
});</user></user>

更新并返回影响行数（泛型为 Integer）：

int count = template.executeInTransaction(con -> {
    String sql = "UPDATE user SET status = ? WHERE id IN (?)";
    try (PreparedStatement ps = con.prepareStatement(sql)) {
        ps.setInt(1, 0);
        ps.setLong(2, 1001L);
        return ps.executeUpdate();
    }
});