java中执行批量操作的核心在于利用 preparedstatement 的 addbatch() 方法积累sql语句，并通过 executebatch() 一次性提交给数据库。具体做法是开启事务自动提交关闭状态，循环调用 addbatch() 添加参数化查询，最后调用 executebatch() 并处理返回的更新计数数组。若需管理连接，通常配合 connection 对象手动控制事务边界，确保数据一致性。
如何配置 PreparedStatement 以支持批量插入
要配置支持批量操作的 PreparedStatement，必须在创建语句时指定 Statement.RETURN_GENERATED_KEYS 或相关标志，并在 Connection 上禁用自动提交。关键步骤包括设置 JDBC URL 的 rewriteBatchedStatements=true 参数（针对 MySQL）以优化性能，以及使用 clearBatch() 防止内存溢出。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class BatchInsertExample {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/testdb?rewriteBatchedStatements=true";
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 (?, ?)";
// 2. 预编译语句
try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
for (int i = 0; i < 1000; i++) {
pstmt.setString(1, "User" + i);
pstmt.setString(2, "user" + i + "@example.com");
// 3. 添加到批处理
pstmt.addBatch();
}
// 4. 执行批处理
int[] results = pstmt.executeBatch();
// 5. 提交事务
conn.commit();
System.out.println("Batch executed successfully. Results: " + java.util.Arrays.toString(results));
} catch (SQLException e) {
conn.rollback();
throw e;
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
上述代码展示了完整的批量插入流程。预期结果是控制台打印出包含1000个1的整数数组，表示每行都成功插入了一条记录。如果发生异常，事务将回滚，数据库状态保持不变。
立即学习“Java免费学习笔记（深入）”；
如何处理批量操作中的异常与回滚
在批量操作中，默认行为是遇到错误时抛出 BatchUpdateException 并停止后续执行。为了更精细地控制，可以捕获该异常并检查 getUpdateCounts() 数组，区分已成功和失败的批次。最佳实践是在 try-catch 块中包裹 executeBatch()，并在 catch 中执行 rollback()。
import java.sql.BatchUpdateException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class BatchWithRollbackExample {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/testdb?rewriteBatchedStatements=true";
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)) {
for (int i = 0; i < 10; i++) {
pstmt.setString(1, "User" + i);
pstmt.setString(2, "user" + i + "@example.com");
pstmt.addBatch();
}
// 模拟在第5条插入一个重复主键错误（假设name是唯一索引）
// 实际测试中，需要确保数据库约束能触发此异常
int[] results = pstmt.executeBatch();
conn.commit();
} catch (BatchUpdateException e) {
System.err.println("Batch update failed at index: " + e.getErrorCode());
int[] counts = e.getUpdateCounts();
for (int i = 0; i < counts.length; i++) {
if (counts[i] == Statement.SUCCESS_NO_INFO || counts[i] == Statement.EXECUTE_FAILED) {
System.err.println("Failed at item: " + i);
}
}
conn.rollback();
System.out.println("Transaction rolled back due to error.");
} catch (SQLException e) {
conn.rollback();
e.printStackTrace();
}
} catch (SQLException e) {
e.printStackTrace();n }
}
}
此代码演示了异常处理机制。当 executeBatch() 抛出 BatchUpdateException 时，程序会捕获它，分析哪些条目失败，然后回滚整个事务。预期输出是错误信息和“Transaction rolled back due to error.”，数据库中没有新增任何数据。
基于 executeBatch() 返回值的具体问题分析
executeBatch() 返回一个 int[] 数组，每个元素对应一次批量操作的更新行数。成功执行的语句返回正数（通常是1），未执行或失败的语句返回 Statement.SUCCESS_NO_INFO (-2) 或 Statement.EXECUTE_FAILED (-3)。通过分析这个数组，可以精确知道哪些操作成功了，哪些失败了，从而实现部分提交或重试逻辑。
