Java JDBC事务案例如何控制

wen java案例 2026-06-30 22

Java JDBC事务案例如何控制：从入门到实战的完整指南

📖 目录导读

什么是JDBC事务？为什么需要控制它？
JDBC事务控制的核心API与原理
手动事务案例：银行转账的经典实现
事务隔离级别与并发问题解析
事务回滚与保存点的进阶用法
常见错误与最佳实践问答
构建健壮的数据库操作

什么是JDBC事务？为什么需要控制它？

Q：JDBC事务和普通SQL事务有什么区别？
A：JDBC事务是Java程序通过JDBC API对数据库事务进行编程控制的方式，与直接写SQL相比，JDBC事务允许你在Java代码中灵活地绑定多个数据库操作，确保它们要么全部成功，要么全部失败。

Java JDBC事务案例如何控制

举个典型场景：用户A向用户B转账1000元，这个业务需要两条SQL：

减少A账户余额
增加B账户余额

如果不用事务,第一条执行成功而第二条失败，钱就凭空消失了。JDBC事务通过commit和rollback机制保证数据一致性，这是任何金融、电商系统的基石。

JDBC事务控制的核心API与原理

JDBC事务控制主要依靠Connection对象的三个方法：

setAutoCommit(false)：关闭自动提交，启动手动事务
commit()：提交事务，所有操作生效
rollback()：回滚事务，撤销所有操作

原理分析：默认情况下，每个SQL语句执行后自动提交（autoCommit=true），手动事务模式下，JDBC将多条SQL暂存在数据库会话的工作区，直到调用commit()才写入磁盘；若调用rollback()，则工作区的数据会被丢弃。

注意：Connection是事务的边界，同一个Connection实例才能共享同一个事务会话。

手动事务案例：银行转账的经典实现

下面是一个完整的Java JDBC转账案例，包含异常处理和资源释放。

public class TransferService {
    public void transfer(String fromAccount, String toAccount, double amount) {
        String sqlReduce = "UPDATE account SET balance = balance - ? WHERE account_no = ?";
        String sqlAdd = "UPDATE account SET balance = balance + ? WHERE account_no = ?";
        try (Connection conn = DataSource.getConnection()) {
            // 1. 关闭自动提交
            conn.setAutoCommit(false);
            try (PreparedStatement ps1 = conn.prepareStatement(sqlReduce);
                 PreparedStatement ps2 = conn.prepareStatement(sqlAdd)) {
                // 2. 减少转出账户
                ps1.setDouble(1, amount);
                ps1.setString(2, fromAccount);
                ps1.executeUpdate();
                // 模拟异常（测试回滚）
                if (amount > 5000) {
                    throw new RuntimeException("单次转账不得超过5000");
                }
                // 3. 增加转入账户
                ps2.setDouble(1, amount);
                ps2.setString(2, toAccount);
                ps2.executeUpdate();
                // 4. 提交事务
                conn.commit();
                System.out.println("转账成功");
            } catch (Exception e) {
                // 5. 回滚事务
                conn.rollback();
                System.err.println("转账失败，已回滚：" + e.getMessage());
                throw e;  // 重新抛出调用方处理
            }
        } catch (SQLException e) {
            // 连接异常处理
            e.printStackTrace();
        }
    }
}

关键点：

setAutoCommit(false)必须在执行任何SQL之前调用
try-with-resources确保PreparedStatement自动关闭
异常发生时,rollback()必须在catch块中显式执行

事务隔离级别与并发问题解析

Q：并发情况下，事务会遇到哪些问题？
A：主要有脏读、不可重复读、幻读三种，JDBC提供了5种隔离级别来控制：

TRANSACTION_READ_UNCOMMITTED（最低，几乎不用）
TRANSACTION_READ_COMMITTED（默认，防止脏读）
TRANSACTION_REPEATABLE_READ（防止脏读+不可重复读）
TRANSACTION_SERIALIZABLE（最高，防止所有问题，但性能最差）

设置方式：conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);

实际建议：大多数业务系统使用READ_COMMITTED即可，若涉及金融对账可使用REPEATABLE_READ，但不建议使用SERIALIZABLE，除非数据量很小且要求绝对精确。

事务回滚与保存点的进阶用法

Q：如何只回滚部分操作，而不是全部？
A：使用Savepoint（保存点），它允许你在事务中设置标记点，回滚时只退回到某个保存点。

conn.setAutoCommit(false);
Savepoint sp1 = conn.setSavepoint("step1");
// ... 执行操作A
Savepoint sp2 = conn.setSavepoint("step2");
// ... 执行操作B（可能失败）
if (someCondition) {
    conn.rollback(sp2);  // 回滚到sp2，操作A依然有效
}
conn.commit();  // 提交操作A

典型应用：批量数据导入时，设置每1000条一个保存点，某批次失败只回滚该批次，不影响已导入的数据。