java jdbc 处理批量操作事务补偿的核心做法是开启手动提交模式，在 try 块中执行批量 sql，并在 catch 块中捕获异常后调用 rollback() 回滚事务。如果业务要求部分成功（即失败时跳过错误行继续执行），则需要在循环中逐条执行并配合 addbatch() 与 executebatch() 的混合使用，或者在捕获特定异常后记录日志并继续下一轮循环，同时保持事务处于活动状态直到所有批次完成。
JDBC 默认自动提交下的批量回滚机制是怎样的
JDBC 驱动默认开启自动提交，此时每条 SQL 都会立即生效，无法通过 rollback() 进行整体补偿。要支持批量事务补偿，必须显式调用 connection.setAutoCommit(false) 关闭自动提交，将所有批量操作包裹在事务中，一旦某一步骤抛出 SQLException，即可通过 connection.rollback() 撤销该批次内所有已执行的变更。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class BatchRollbackExample {
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);
String sql = "INSERT INTO users (name, email) VALUES (?, ?)";
try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
// 添加多个参数到批处理
pstmt.setString(1, "Alice");
pstmt.setString(2, "alice@example.com");
pstmt.addBatch();
pstmt.setString(1, "Bob");
pstmt.setString(2, "bob@example.com");
pstmt.addBatch();
// 执行批量操作
int[] results = pstmt.executeBatch();
// 如果没有异常，提交事务
conn.commit();
System.out.println("Batch executed successfully. Results: " + java.util.Arrays.toString(results));
} catch (SQLException e) {
// 发生异常时回滚事务
conn.rollback();
System.err.println("Transaction rolled back due to error: " + e.getMessage());
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
如何实现部分成功的批量操作补偿策略
当需要实现“部分成功”即忽略单行错误继续执行后续批次时，不能直接使用 executeBatch() 的整体事务，而应在循环中逐条调用 executeUpdate() 或分小块执行 executeBatch()，并在每次执行后检查返回值或捕获异常。若某一行失败，记录日志但不中断事务，继续处理下一行，最后统一提交。这种方式牺牲了原子性，但提高了容错率。
立即学习“Java免费学习笔记（深入）”；
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
public class PartialSuccessBatch {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/test";
String user = "root";
String password = "password";
List<String[]> records = new ArrayList<>();
records.add(new String[]{"Charlie", "charlie@example.com"});
records.add(new String[]{"Invalid", null}); // 可能引发约束冲突
records.add(new String[]{"David", "david@example.com"});
try (Connection conn = DriverManager.getConnection(url, user, password)) {
conn.setAutoCommit(false);
String sql = "INSERT INTO users (name, email) VALUES (?, ?)";
int successCount = 0;
int failCount = 0;
try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
for (String[] record : records) {
try {
pstmt.setString(1, record[0]);
pstmt.setString(2, record[1]);
pstmt.executeUpdate();
successCount++;
} catch (SQLException e) {
failCount++;
System.err.println("Failed to insert record: " + record[0] + ", Error: " + e.getMessage());
// 不抛出异常，继续下一条
}
}
// 即使有失败，也提交已成功的事务部分
conn.commit();
System.out.println("Success: " + successCount + ", Failed: " + failCount);
} catch (SQLException e) {
conn.rollback();
System.err.println("Transaction failed completely: " + e.getMessage());
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
批量操作中如何确保数据库连接在异常后仍可恢复
在批量操作过程中，如果发生网络中断或数据库重启，Connection 对象可能进入不可用状态。此时直接调用 rollback() 会抛出新的 SQLException。正确的做法是在 catch 块中先尝试 rollback()，若失败则关闭连接并重新获取新连接，同时记录当前进度以便后续重试。此外，应使用 try-with-resources 确保连接和语句对象正确释放，避免资源泄漏。
