在Java中如何捕获SQLException并回滚事务_数据库异常处理与事务回滚解析-java教程-PHP中文网

在Java中如何捕获SQLException并回滚事务_数据库异常处理与事务回滚解析

P粉602998670

发布： 2025-12-05 10:29:03

原创

968人浏览过

发生异常时回滚事务是保障数据一致性的关键。在Java中处理SQLException需先关闭auto-commit以开启事务，执行SQL操作后若成功则commit，若捕获SQLException则调用rollback防止部分更新；通过try-with-resources确保资源释放；结合Spring的@Transactional注解可实现声明式事务管理，自动触发回滚，提升代码可维护性。

在java中如何捕获sqlexception并回滚事务_数据库异常处理与事务回滚解析

在Java中处理数据库操作时，SQLException 是最常见的异常类型之一。当执行SQL语句发生错误（如连接失败、语法错误、主键冲突等）时，JDBC会抛出 SQLException。为了保证数据一致性，通常需要在捕获该异常后立即回滚事务，防止部分更新导致的数据不一致问题。

使用 try-catch 捕获 SQLException 并手动回滚

在使用 JDBC 手动管理事务时，应通过 Connection 对象控制事务的提交与回滚。默认情况下，Connection 处于自动提交模式（auto-commit = true），每条SQL语句都会立即提交。要实现事务控制，必须先关闭自动提交。

基本流程如下：

调用 connection.setAutoCommit(false) 关闭自动提交
执行多个相关SQL操作
若全部成功，调用 connection.commit() 提交事务
若发生 SQLException，进入 catch 块并调用 connection.rollback() 回滚
无论成功或失败，最终恢复 auto-commit 状态或关闭连接

示例代码：

立即学习“Java免费学习笔记（深入）”；

Connection conn = null;
try {
    conn = dataSource.getConnection();
    conn.setAutoCommit(false); // 开启事务
<pre class='brush:java;toolbar:false;'>PreparedStatement ps1 = conn.prepareStatement("INSERT INTO users(name, age) VALUES (?, ?)");
ps1.setString(1, "Alice");
ps1.setInt(2, 25);
ps1.executeUpdate();

PreparedStatement ps2 = conn.prepareStatement("UPDATE accounts SET balance = balance - ? WHERE user_id = ?");
ps2.setDouble(1, 100.0);
ps2.setInt(2, 1);
ps2.executeUpdate();

conn.commit(); // 提交事务

登录后复制

} catch (SQLException e) { if (conn != null) { try { conn.rollback(); // 发生异常时回滚 } catch (SQLException ex) { ex.printStackTrace(); } } e.printStackTrace(); // 记录异常信息 } finally { if (conn != null) { try { conn.setAutoCommit(true); // 恢复默认状态 conn.close(); } catch (SQLException e) { e.printStackTrace(); } } }

确保资源释放与异常传递

在实际开发中，除了回滚事务，还需注意资源的正确释放。使用 try-with-resources 可以自动关闭 PreparedStatement 和 ResultSet，减少资源泄漏风险。

改进后的写法：

try (Connection conn = dataSource.getConnection()) {
    conn.setAutoCommit(false);
<pre class='brush:java;toolbar:false;'>try (PreparedStatement ps1 = conn.prepareStatement("...");
     PreparedStatement ps2 = conn.prepareStatement("...")) {

    // 执行SQL操作
    ps1.executeUpdate();
    ps2.executeUpdate();

    conn.commit(); // 提交
} catch (SQLException e) {
    conn.rollback(); // 回滚
    throw e; // 可选择重新抛出以便上层处理
}

登录后复制

} catch (SQLException e) { e.printStackTrace(); }

结合 Spring 框架的声明式事务管理

在企业级应用中，通常使用 Spring 的事务管理机制来简化异常处理和回滚逻辑。通过 @Transactional 注解，可以自动将 SQLException（及其子类）触发事务回滚。

AiTxt 文案助手

AiTxt 利用 Ai 帮助你生成您想要的一切文案，提升你的工作效率。

查看详情

例如：

@Service
public class UserService {
<pre class='brush:java;toolbar:false;'>@Autowired
private JdbcTemplate jdbcTemplate;

@Transactional
public void transferMoney(int fromId, int toId, double amount) {
    jdbcTemplate.update("UPDATE accounts SET balance = balance - ? WHERE id = ?", amount, fromId);
    // 模拟异常
    // int x = 1 / 0;
    jdbcTemplate.update("UPDATE accounts SET balance = balance + ? WHERE id = ?", amount, toId);
}

登录后复制

}

当方法内抛出 RuntimeException（包括 SQLException 被包装后的 DataAccessException）时，Spring 会自动回滚事务。若希望检查型异常也触发回滚，可配置 rollbackFor 属性：

@Transactional(rollbackFor = Exception.class)