当前位置：首页 > 文章列表 > 文章 > java教程 > Java捕获SQLException与事务回滚技巧

Java捕获SQLException与事务回滚技巧

2025-12-14 11:29:46 0浏览收藏

在文章实战开发的过程中，我们经常会遇到一些这样那样的问题，然后要卡好半天，等问题解决了才发现原来一些细节知识点还是没有掌握好。今天golang学习网就整理分享《Java捕获SQLException与事务回滚方法》，聊聊，希望可以帮助到正在努力赚钱的你。

发生异常时回滚事务是保障数据一致性的关键。在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 状态或关闭连接

示例代码：

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)