使用 addbatch() 和 executebatch() 是优化 java preparedstatement 批量数据性能的核心手段。通过预先设置 sql 语句并分批添加参数，最后一次性提交执行，可以显著减少网络往返次数（rtt）并降低数据库解析开销。建议在循环中每积累一定数量的数据后调用 executebatch() 以控制内存占用，并在操作完成后调用 clearbatch() 重置状态。
如何配置 JDBC URL 以启用批量处理
在连接字符串中添加 rewriteBatchedStatements=true 参数可以让 MySQL 驱动将多条 INSERT 语句合并为一条执行，从而大幅提升吞吐量。这一配置仅对支持重写协议的数据库有效，开启后驱动会自动拦截批量插入请求并转换为多值插入语法。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
public class BatchInsertExample {
public static void main(String[] args) throws Exception {
String url = "jdbc:mysql://localhost:3306/testdb?rewriteBatchedStatements=true";
Connection conn = DriverManager.getConnection(url, "user", "pass");
String sql = "INSERT INTO users (name, age) VALUES (?, ?)";
try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
for (int i = 0; i < 1000; i++) {
pstmt.setString(1, "User_" + i);
pstmt.setInt(2, 20 + i % 50);
pstmt.addBatch();
if (i % 100 == 0) {
pstmt.executeBatch();
pstmt.clearBatch();
}
}
pstmt.executeBatch();
}
}
}
上述代码展示了标准的批量插入流程。首先建立带有优化参数的连接，接着在循环中不断调用 addBatch() 累积数据。当计数器达到 100 的倍数时，触发 executeBatch() 并提交当前批次，随后立即 clearBatch() 释放内存。这种分块策略避免了单次事务过大导致的内存溢出或锁竞争问题。
立即学习“Java免费学习笔记（深入）”；
如何处理批量更新中的异常与回滚
在执行批量更新时，默认行为可能因数据库而异，通常建议显式关闭自动提交并使用 Statement.RETURN_GENERATED_KEYS 获取结果。若某条记录失败，可根据业务需求选择中断整个批次或继续执行剩余部分，这取决于 executeBatch() 返回数组中的状态码。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.Statement;
public class BatchUpdateWithRollback {
public static void main(String[] args) throws Exception {
String url = "jdbc:mysql://localhost:3306/testdb?rewriteBatchedStatements=true";
Connection conn = DriverManager.getConnection(url, "user", "pass");
conn.setAutoCommit(false);
String sql = "UPDATE users SET age = ? WHERE id = ?";
try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
for (int i = 0; i < 100; i++) {
pstmt.setInt(1, 30);
pstmt.setInt(2, i + 1);
pstmt.addBatch();
}
int[] results = pstmt.executeBatch();
for (int result : results) {
if (result == Statement.SUCCESS_NO_INFO || result == Statement.EXECUTE_FAILED) {
System.out.println("Batch item failed or no info");
}
}
conn.commit();
} catch (Exception e) {
conn.rollback();
throw e;
}
}
}
该示例演示了带事务控制的批量更新。通过 setAutoCommit(false) 确保所有操作要么全部成功，要么全部回滚。执行后检查返回的 int[] 数组，识别出 EXECUTE_FAILED 状态以便进行日志记录或后续处理。如果发生整体异常，则进入 catch 块执行 rollback() 保证数据一致性。
基于 executeBatch() 返回值的具体问题分析
executeBatch() 返回的整数数组中，每个元素代表对应 SQL 语句的执行结果。正值表示受影响的行数，-2 表示 SUCCESS_NO_INFO，-3 表示 EXECUTE_FAILED。在 MySQL 配合 rewriteBatchedStatements=true 使用时，由于语句被合并，返回值往往统一为 SUCCESS_NO_INFO，此时无法直接得知每条语句的具体影响行数，需依赖业务逻辑校验。
