java jdbc 实现数据恢复的核心做法是关闭自动提交并调用 connection.rollback()。默认情况下 jdbc 连接处于自动提交模式，每条 sql 执行后都会立即生效且无法撤销。通过 connection.setautocommit(false) 开启事务控制，在业务逻辑全部完成后调用 commit()，若在执行过程中捕获到异常则调用 rollback() 将数据库状态回退到事务开始前的样子。
如何正确配置事务边界
要确保数据一致性，必须在获取连接后立即禁用自动提交，并将所有相关的增删改操作包裹在 try-catch 块中。一旦某个步骤失败，程序进入 catch 分支执行回滚，从而保证要么所有操作都成功，要么没有任何操作生效。这种机制避免了部分更新导致的数据不一致问题。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class TransactionDemo {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/test";
String user = "root";
String password = "password";
try (Connection conn = DriverManager.getConnection(url, user, password)) {
// 1. 关闭自动提交
conn.setAutoCommit(false);
try {
// 2. 执行多个更新操作
String sql1 = "UPDATE accounts SET balance = balance - 100 WHERE id = 1";
String sql2 = "UPDATE accounts SET balance = balance + 100 WHERE id = 2";
try (PreparedStatement ps1 = conn.prepareStatement(sql1);
PreparedStatement ps2 = conn.prepareStatement(sql2)) {
ps1.executeUpdate();
ps2.executeUpdate();
// 3. 全部成功，提交事务
conn.commit();
System.out.println("Transaction committed successfully.");
} catch (SQLException e) {
// 4. 发生错误，回滚事务
conn.rollback();
System.err.println("Transaction rolled back due to error: " + e.getMessage());
throw e;
}
} catch (SQLException e) {
conn.rollback();
System.err.println("Outer rollback: " + e.getMessage());
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
上述代码展示了标准的 JDBC 事务处理流程。首先通过 DriverManager.getConnection 获取连接，随即调用 setAutoCommit(false)。接着在内部 try 块中执行具体的 SQL 更新。如果 executeUpdate 抛出异常，控制权转移到内层 catch，执行 rollback() 撤销之前的更改。如果正常执行完毕，则调用 commit() 持久化数据。外层还有一个 catch 用于处理连接层面的异常，确保即使在内层未捕获的情况下也能进行回滚保护。
如何处理嵌套或保存点场景
当单个事务中包含多个独立子步骤，且希望仅回滚其中某一部分而不影响整个事务时，可以使用 Savepoint。通过 connection.setSavepoint(name) 设置标记点，后续若需撤销特定操作，可调用 connection.rollback(savepoint)。这允许在同一个事务中进行更细粒度的错误恢复，而无需放弃之前已成功执行的操作。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.Savepoint;
import java.sql.SQLException;
public class SavepointDemo {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/test";
String user = "root";
String password = "password";
try (Connection conn = DriverManager.getConnection(url, user, password)) {
conn.setAutoCommit(false);
try {
// 第一步：插入用户信息
String sqlUser = "INSERT INTO users (name) VALUES ('Alice')";
try (PreparedStatement ps = conn.prepareStatement(sqlUser)) {
ps.executeUpdate();
}
// 设置保存点
Savepoint sp1 = conn.setSavepoint("after_user_insert");
// 第二步：插入订单（可能失败）
String sqlOrder = "INSERT INTO orders (user_id, amount) VALUES (LAST_INSERT_ID(), 500)";
try (PreparedStatement ps = conn.prepareStatement(sqlOrder)) {
ps.executeUpdate();
}
// 假设这里模拟一个错误，回滚到保存点
// 在实际应用中，这可能由业务逻辑触发
throw new SQLException("Simulated order error");
} catch (SQLException e) {
try {
// 回滚到保存点，保留用户插入，撤销订单插入
conn.rollback(sp1);
System.out.println("Rolled back to savepoint: after_user_insert");
// 继续其他操作或最终提交
conn.commit();
} catch (SQLException ex) {
conn.rollback();
System.err.println("Full rollback: " + ex.getMessage());
}
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
该示例演示了 Savepoint 的使用。在插入用户成功后，通过 setSavepoint 创建一个名为 after_user_insert 的标记。随后尝试插入订单，如果此时发生异常，程序捕获异常并调用 rollback(sp1)。这将撤销从保存点到当前点之间的所有操作（即订单插入），但用户信息的插入依然有效。最后可以提交剩余的有效变更。这种方式适用于需要部分回滚的复杂业务场景。
事务回滚后数据库状态具体是什么
调用 rollback() 后，数据库会恢复到调用 setAutoCommit(false) 或上一个 commit() 时的状态。所有在该事务期间执行的 INSERT、UPDATE 或 DELETE 操作都会被撤销，相关行数据保持不变。对于自增主键，虽然记录被删除，但自增值通常不会回退，这意味着下次插入会使用新的 ID。此外，事务回滚不会影响其他并发事务看到的数据，因为 JDBC 事务遵循隔离级别约定，在未提交前对其他事务不可见（取决于隔离级别）。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
