java preparedstatement 执行批量混合操作的核心方法是调用 addbatch() 将多条 sql 语句加入缓存，随后使用 executebatch() 一次性提交。具体做法是创建连接后关闭自动提交（setautocommit(false)），循环调用 addbatch() 设置参数，最后调用 executebatch() 并手动提交事务（commit()）。若中途发生异常，需回滚事务（rollback()）以保证数据一致性。
如何配置 PreparedStatement 以支持批量处理
要启用批量处理，必须显式关闭 JDBC 连接的自动提交模式，否则每条语句都会立即执行，无法形成批量效果。开发者需要获取 Connection 对象，调用 setAutoCommit(false)，然后准备带有占位符的 PreparedStatement。在循环中，通过 setXxx() 方法为占位符赋值，并调用 addBatch() 将该次操作加入队列。这种配置方式允许数据库驱动在内部优化 SQL 的执行计划，减少网络往返次数。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
public class BatchExample {
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)) {
// 2. 添加批量数据
for (int i = 0; i < 100; i++) {
pstmt.setString(1, "User" + i);
pstmt.setString(2, "user" + i + "@example.com");
pstmt.addBatch();
}
// 3. 执行批量
int[] results = pstmt.executeBatch();
// 4. 提交事务
conn.commit();
System.out.println("Batch executed successfully. Results: " + java.util.Arrays.toString(results));
} catch (Exception e) {
// 5. 异常回滚
conn.rollback();
e.printStackTrace();
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
上述代码展示了标准的批量插入流程。预期结果是控制台打印出包含 100 个整数的数组，每个整数通常表示该条语句影响的行数（对于 INSERT 通常是 1）。如果某条语句失败，executeBatch() 会抛出 BatchUpdateException，此时事务处于未提交状态，必须调用 rollback() 撤销所有已执行的批量操作。
立即学习“Java免费学习笔记（深入）”；
掌握 ES6+ 特性，包括 async/await、解构、扩展运算符、箭头函数、Promise、模块、迭代器、生成器以及函数式编程模式，编写简洁高效的 Java
如何处理批量操作中的部分失败与结果验证
当批量操作中某一条语句出错时，executeBatch() 的行为取决于数据库驱动和配置。默认情况下，大多数驱动会在遇到错误时停止后续执行并抛出异常。为了验证哪些语句成功、哪些失败，开发者应捕获 BatchUpdateException，并通过其 getUpdateCounts() 方法获取返回的整数数组。该数组的长度可能小于实际添加的批次数量，缺失的部分即为未执行或失败的条目。此外，可以通过检查返回值中的 Statement.SUCCESS_NO_INFO 或 Statement.EXECUTE_FAILED 常量来进一步判断具体状态。
import java.sql.BatchUpdateException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.Statement;
public class PartialFailureExample {
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, "User1"); pstmt.setString(2, "u1@test.com"); pstmt.addBatch();
pstmt.setString(1, "User2"); pstmt.setString(2, "u2@test.com"); pstmt.addBatch();
pstmt.setString(1, "User1"); pstmt.setString(2, "u3@test.com"); pstmt.addBatch(); // Duplicate key
try {
int[] counts = pstmt.executeBatch();
conn.commit();
System.out.println("All succeeded: " + java.util.Arrays.toString(counts));
} catch (BatchUpdateException e) {
conn.rollback();
int[] counts = e.getUpdateCounts();
System.out.println("Partial failure. Counts: " + java.util.Arrays.toString(counts));
// 分析 counts 数组：[1, 1, -3] 表示前两条成功，第三条失败
for (int i = 0; i < counts.length; i++) {
if (counts[i] == Statement.EXECUTE_FAILED) {
System.out.println("Failed at index: " + i);
}
}
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
运行上述代码，预期输出为 Partial failure. Counts: [1, 1, -3]。其中 1 表示成功插入一行，-3 是 Statement.EXECUTE_FAILED 的值，表示该条语句执行失败。开发者可以根据这个数组定位到具体的失败索引，从而进行日志记录或重试逻辑。注意，一旦抛出 BatchUpdateException，事务尚未提交，必须显式调用 rollback() 才能恢复数据库状态。
基于 executeBatch() 返回数组的具体问题分析
当 executeBatch() 返回一个整数数组时，每个元素对应一次 addBatch() 调用的影响行数。如果返回数组长度小于调用 addBatch() 的次数，说明后续操作未执行。若某个元素值为 Statement.SUCCESS_NO_INFO（值通常为 -2），表示语句执行成功但无法确定影响行数，常见于某些数据库的 UPDATE 操作。若值为 Statement.EXECUTE_FAILED（值通常为 -3），则表示该特定语句失败。开发者应遍历此数组，结合索引判断哪些批次已成功写入数据库，哪些需要重新处理或记录错误。
