java preparedstatement 执行批量数据容灾的核心做法是结合事务管理与异常回滚机制，确保在批量插入或更新过程中，一旦某条数据出错，整个批次要么全部成功，要么全部撤销，从而避免产生脏数据。具体实现时，需关闭自动提交（auto-commit），通过 addbatch() 收集 sql 参数，并在 executebatch() 捕获异常后调用 rollback() 恢复数据库状态。
如何配置连接以支持事务控制
要实现容灾，第一步是获取 JDBC 连接并禁用自动提交模式。默认情况下，JDBC 连接处于自动提交状态，每条语句执行后立即持久化，这会导致部分成功、部分失败的数据残留。通过调用 connection.setAutoCommit(false)，可以将多条操作纳入同一个事务中，直到显式调用 commit() 才生效。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
public class BatchTransactionDemo {
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);
String sql = "INSERT INTO users (name, email) VALUES (?, ?)";
try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
// 模拟批量数据
String[][] data = {{"Alice", "alice@example.com"}, {"Bob", "bob@example.com"}};
for (String[] row : data) {
pstmt.setString(1, row[0]);
pstmt.setString(2, row[1]);
pstmt.addBatch();
}
// 2. 执行批量
int[] results = pstmt.executeBatch();
// 3. 提交事务
conn.commit();
System.out.println("Batch executed successfully. Results: " + java.util.Arrays.toString(results));
} catch (Exception e) {
// 4. 发生异常时回滚
conn.rollback();
System.err.println("Error occurred, transaction rolled back.");
e.printStackTrace();
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
上述代码展示了完整的流程：先设置 setAutoCommit(false)，然后循环调用 addBatch() 添加参数，最后调用 executeBatch()。如果中间任何一步抛出异常，程序进入 catch 块并执行 conn.rollback()，保证数据库状态不变。预期输出为控制台打印成功信息，若数据中存在非法值导致 SQL 错误，则打印错误信息且数据库中无新增记录。
立即学习“Java免费学习笔记（深入）”；
如何处理大批量数据的内存溢出与分批提交
当批量数据量极大时，一次性将所有数据加入 PreparedStatement 的批处理队列可能导致内存溢出（OOM）。此时需要采用分批提交策略，即每处理一定数量的数据就执行一次 executeBatch() 和 commit()，然后清空批次。这样既能保持事务的一致性（每个小批次独立事务），又能控制内存占用。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
public class BatchChunkDemo {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/test";
String user = "root";
String password = "password";
int batchSize = 1000; // 每批处理1000条
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)) {
// 模拟大量数据
for (int i = 0; i < 5000; i++) {
pstmt.setString(1, "User" + i);
pstmt.setString(2, "user" + i + "@example.com");
pstmt.addBatch();
// 每达到batchSize条，执行并提交
if ((i + 1) % batchSize == 0) {
pstmt.executeBatch();
conn.commit();
pstmt.clearBatch(); // 清空批次，释放内存
System.out.println("Committed batch up to index " + i);
}
}
// 处理剩余不足一批的数据
int[] remainingResults = pstmt.executeBatch();
conn.commit();
System.out.println("Final batch committed. Results: " + java.util.Arrays.toString(remainingResults));
} catch (Exception e) {
conn.rollback();
System.err.println("Error in chunk processing, rolled back.");
e.printStackTrace();
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
该方案将 5000 条数据分为 5 个批次，每 1000 条提交一次。关键点是调用 pstmt.clearBatch() 来清除已执行的批次内容，防止内存累积。如果在某个批次中发生异常，仅该批次及之前的数据可能已提交（取决于是否在每个批次后 commit），但通常建议在每个小批次内也做异常捕获，以实现更细粒度的容灾。预期输出为每处理完 1000 条打印一次提交日志，最后处理剩余 500 条。
当PreparedStatement中某条SQL语法错误时，executeBatch会怎样处理后续数据
在使用 executeBatch() 执行批量操作时，如果其中某条 SQL 存在语法错误或约束冲突，默认行为取决于 JDBC 驱动和数据库类型。对于 MySQL Connector/J，默认情况下，如果一条语句失败，executeBatch() 会抛出 BatchUpdateException，并且该异常对象中包含一个 updateCounts 数组，指示哪些索引已成功执行，哪些失败。然而，并非所有驱动都保证原子性，有些驱动可能在遇到错误后停止处理后续语句，而有些可能继续尝试。因此，必须检查返回的 updateCounts 数组来确定实际成功的条目数，并结合事务回滚机制来确保数据一致性。
