java jdbc 执行批量插入操作的核心做法是调用 connection 对象的 addbatch() 方法将多条 sql 语句暂存，随后通过 executebatch() 一次性提交给数据库。具体实现时，通常先关闭自动提交模式（setautocommit(false)），然后循环构建参数并添加至批次，最后执行并提交事务。若遇到主键冲突或数据量极大导致内存溢出，需结合 clearbatch() 分批处理或使用 preparedstatement 预编译优化。
如何配置 Connection 以支持批量处理
要启用批量处理，必须显式关闭 Connection 的自动提交功能，否则每条语句都会立即生效，无法形成真正的“批”。同时，建议设置 Statement 的最大行数限制，防止单次批次过大引发 OutOfMemoryError。在代码层面，这涉及获取连接后调用 setAutoCommit(false)，并在所有操作完成后调用 commit()。如果中途发生异常，应调用 rollback() 保证数据一致性。
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";
String user = "root";
String password = "password";
// 模拟插入1000条数据
int batchSize = 1000;
int totalRecords = 5000;
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)) {
for (int i = 0; i < totalRecords; i++) {
pstmt.setString(1, "User_" + i);
pstmt.setString(2, "user_" + i + "@example.com");
// 2. 添加到批次
pstmt.addBatch();
// 3. 每1000条执行一次，防止内存溢出
if ((i + 1) % batchSize == 0) {
pstmt.executeBatch();
pstmt.clearBatch();
}
}
// 4. 执行剩余部分
pstmt.executeBatch();
// 5. 提交事务
conn.commit();
System.out.println("Batch insert completed successfully.");
} catch (SQLException e) {
conn.rollback();
throw e;
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}上述代码展示了标准的批量插入流程：首先建立连接并禁用自动提交，接着使用 PreparedStatement 预编译 SQL 语句以提高效率。在循环中，每次调用 addBatch() 将参数加入队列，当累计达到 batchSize 阈值时，调用 executeBatch() 发送数据并清空缓冲区。最后处理剩余数据并提交事务。这种分块策略能有效平衡内存占用与网络传输开销。
立即学习“Java免费学习笔记（深入）”；
如何处理批量插入中的异常与回滚
在执行 executeBatch() 时，如果某条记录失败（如违反唯一约束），默认行为取决于驱动程序的 continueBatchOnError 属性。大多数现代 JDBC 驱动（如 MySQL Connector/J）默认会抛出 BatchUpdateException 并中断后续执行。此时，程序需要捕获该异常，检查返回的更新计数数组，确定哪些行成功、哪些失败，并根据业务需求决定是跳过错误行继续处理，还是整体回滚。此外，若未捕获异常且事务处于开启状态，必须确保在 finally 块或 try-with-resources 中正确回滚，避免脏数据残留。
import java.sql.BatchUpdateException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class BatchWithErrorHandling {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/testdb?allowMultiQueries=true";
String user = "root";
String password = "password";
try (Connection conn = DriverManager.getConnection(url, user, password)) {
conn.setAutoCommit(false);
String sql = "INSERT INTO users (id, name) VALUES (?, ?)";
try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
// 假设第3条数据ID重复，会导致异常
int[] ids = {1, 2, 3, 4, 5};
String[] names = {"A", "B", "C", "D", "E"};
for (int i = 0; i < ids.length; i++) {
pstmt.setInt(1, ids[i]);
pstmt.setString(2, names[i]);
pstmt.addBatch();
}
try {
int[] results = pstmt.executeBatch();
System.out.println("Success count: " + results.length);
conn.commit();
} catch (BatchUpdateException e) {
// 获取已成功的更新计数
int[] counts = e.getUpdateCounts();
System.out.println("Failed at index: " + e.getIndex());
System.out.println("Successful updates before failure: " + counts.length);
conn.rollback();
}
}
} catch (SQLException e) {
e.printStackTrace();n }
}
}此示例演示了异常处理机制。当 executeBatch() 抛出 BatchUpdateException 时，通过 e.getIndex() 可以定位到出错的具体位置，而 e.getUpdateCounts() 则返回已成功执行的行数数组。开发者可根据这些信息进行日志记录或重试逻辑。关键在于，一旦捕获异常，必须调用 conn.rollback() 撤销当前事务中的所有更改，确保数据库状态的一致性。对于大规模数据导入，建议结合 LOAD DATA INFILE 等数据库原生命令以获得更高性能，但 JDBC 批量方式更适用于通用业务场景。
基于 PreparedStatement 缓存对批量插入性能的影响
在使用 PreparedStatement 进行批量插入时，驱动程序通常会缓存 SQL 语句的执行计划，从而避免每次执行都重新解析 SQL。然而，如果 SQL 语句中包含大量动态拼接的参数，或者不同批次间 SQL 结构差异较大，可能导致缓存失效或内存泄漏。此外，某些数据库驱动（如旧版 MySQL Connector）在默认配置下可能不会真正利用服务器端预处理，而是退化为普通 Statement 行为。因此，验证性能提升的关键在于检查驱动是否实际发送了二进制参数包，而非仅依赖代码层面的 addBatch 调用。
