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

在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); // 开启事务
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);
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(及其子类)触发事务回滚。
例如:
@Service
public class UserService {
@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)
总结关键点
处理 SQLException 并回滚事务的核心在于:
- 关闭 auto-commit 以开启事务边界
- 在 catch 块中调用 rollback() 防止脏写
- 利用 try-with-resources 管理数据库资源
- 在框架中合理使用声明式事务提升代码可维护性
基本上就这些。只要把握住“异常发生即回滚”的原则,就能有效保障数据库操作的原子性和一致性。










