java 中执行批量插入的标准做法是调用 preparedstatement 的 addbatch() 方法积累 sql，随后使用 executebatch() 一次性提交。通过设置 setautocommit(false) 关闭自动提交并配合事务管理，可以显著提升大批量数据写入的性能。
如何配置 PreparedStatement 以支持批量操作
要实现批量插入，核心在于利用 addBatch() 将多条参数化语句暂存于客户端缓冲区，而非立即发送给数据库。在创建连接后，必须显式调用 connection.setAutoCommit(false) 以确保所有批次作为一个原子单元执行。若未关闭自动提交，每次 addBatch() 后的实际执行行为可能因驱动实现而异，导致性能下降或数据不一致。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
public class BatchInsertExample {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/testdb";
String user = "root";
String password = "password";
// 定义批量插入的SQL模板
String sql = "INSERT INTO users (name, email) VALUES (?, ?)";
try (Connection conn = DriverManager.getConnection(url, user, password);
PreparedStatement pstmt = conn.prepareStatement(sql)) {
// 1. 关闭自动提交，开启事务
conn.setAutoCommit(false);
// 2. 准备数据并添加到批次
for (int i = 0; i <p>上述代码展示了完整的流程：首先获取连接并禁用自动提交，接着循环设置参数并调用 <code>addBatch()</code>，最后通过 <code>executeBatch()</code> 发送所有累积的语句。执行完毕后需调用 <code>commit()</code> 确认更改。若过程中发生异常，应调用 <code>rollback()</code> 回滚事务以保证数据完整性。</p><h2>批量插入时如何处理大数量数据的内存与性能</h2><p>当插入数据量极大时，将所有记录一次性加入批次可能导致内存溢出（OutOfMemoryError）。最佳实践是将大数据集分割为多个小批次，例如每 1000 条执行一次 <code>executeBatch()</code> 和 <code>commit()</code>。这种分片策略既能保持批量操作的高吞吐优势，又能控制单次事务的资源消耗。</p><div class="aritcle_card flexRow artxards">
<div class="artcardd flexRow">
<a class="aritcle_card_img" rel="nofollow" href="/xiazai/skill12496" title="Java 开发专家"><img
src="https://img.php.cn/upload/skill/001/246/273/6adaf20d79f23518.jpg" alt="Java 开发专家" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
<div class="aritcle_card_info flexColumn">
<a rel="nofollow" href="/xiazai/skill12496" title="Java 开发专家" class="overflowclass">Java 开发专家</a>
<p class="overflowclass">精通 Java 21+，掌握虚拟线程、模式匹配和 Spring Boot 3.x 等现代特性。是 Java 生态系统（包括 GraalVM、Project Lo</p>
</div>
<a rel="nofollow" href="/xiazai/skill12496" title="Java 开发专家" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span>
</a>
</div>
</div><p><img src="https://img.php.cn/upload/article/001/242/473/179438333159383.png?x-oss-process=image/resize,p_40" alt="Java PreparedStatement 怎么执行批量插入"></p><pre class="brush:php;toolbar:false;">import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
public class ChunkedBatchInsert {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/testdb";
String user = "root";
String password = "password";
String sql = "INSERT INTO logs (message, timestamp) VALUES (?, ?)";
try (Connection conn = DriverManager.getConnection(url, user, password);
PreparedStatement pstmt = conn.prepareStatement(sql)) {
conn.setAutoCommit(false);
int batchSize = 1000;
int count = 0;
// 模拟大量数据源
for (int i = 0; i <p>该示例引入了分块逻辑：设定 <code>batchSize</code> 为 1000，每当累计条目数达到此值时，便触发 <code>executeBatch()</code> 和 <code>commit()</code>，并调用 <code>clearBatch()</code> 释放内存。对于总数不能被批次大小整除的情况，循环结束后需再次执行剩余部分。这种方式确保了在处理数万甚至百万级数据时，应用服务器不会因内存压力而崩溃，同时维持了较高的数据库写入效率。</p><h2>executeBatch() 返回的 int[] 数组代表什么含义</h2><p><code>executeBatch()</code> 方法返回一个 <code>int[]</code> 数组，其中每个元素对应前一次 <code>addBatch()</code> 所添加语句的执行结果。如果某条语句成功执行且影响行数已知，数组中对应位置为该整数；如果受影响的行数不确定（例如某些数据库驱动对 DDL 或非标准操作的反馈），则返回 <code>Statement.SUCCESS_NO_INFO</code>（值为 -2）；如果执行失败，则抛出 <code>BatchUpdateException</code>，此时数组可能不完整或包含部分成功状态。</p><p>在实际开发中，建议检查返回值数组的长度是否与添加的批次数量一致，并遍历数组验证每个状态码。若发现非正数结果，应根据业务需求决定是继续执行后续批次还是中断整个事务。此外，不同 JDBC 驱动对 <code>executeBatch()</code> 的行为可能存在细微差异，例如 MySQL Connector/J 默认会将多条 INSERT 合并为一条多值语句以提升性能，这会影响返回数组的具体数值表现，但整体语义保持一致。</p>
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
