java jdbc 实现批量操作数据目录的核心做法是关闭自动提交并配合 addbatch 与 executebatch。通过设置 connection 的 autocommit 为 false，将多条 sql 语句加入批次后一次性执行，最后调用 commit 提交事务。若执行过程中发生异常，则调用 rollback 回滚所有操作，确保数据一致性。

JDBC 事务中如何配置批量处理参数

在建立数据库连接后，必须显式关闭自动提交模式，否则每条语句都会立即生效，无法形成事务边界。接着需要设置批处理的大小限制，防止内存溢出。使用 setAutoCommit(false) 开启事务管理，并通过 addBatch() 累积 SQL 命令。当累积数量达到阈值或循环结束时，调用 executeBatch() 发送指令给数据库驱动。如果数据库支持，还可以设置 rewriteBatchedStatements 等驱动级参数以优化性能。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class BatchTransactionExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/mydb";
        String user = "root";
        String password = "password";

        try (Connection conn = DriverManager.getConnection(url, user, password)) {
            // 1. 关闭自动提交
            conn.setAutoCommit(false);

            String sql = "INSERT INTO directory_entries (name, path) VALUES (?, ?)";
            try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
                // 2. 添加批量数据
                for (int i = 0; i <p>上述代码展示了完整的流程：获取连接、关闭自动提交、准备语句、循环添加批次、执行批次、提交事务以及异常回滚。预期结果是控制台打印出“Batch executed successfully. Rows affected: 1000”，且数据库中新增 1000 条记录。如果中途出错，数据库状态保持不变。</p><h2>如何处理批量操作中的部分失败情况</h2><p>当批量操作中某一条语句失败时，默认行为取决于数据库驱动和配置。大多数情况下，<code>executeBatch()</code> 会抛出 <code>BatchUpdateException</code>。此时需要检查异常对象中的更新计数数组，确定哪些语句成功执行，哪些失败。对于 MySQL 驱动，如果设置了 <code>continueBatchOnError</code>，即使某条失败也会继续执行后续语句；否则会在第一条失败处停止。开发者应根据业务需求选择是否捕获异常并手动处理剩余批次，或者依赖驱动的默认行为进行整体回滚。</p><div class="aritcle_card flexRow artxards">
											<div class="artcardd flexRow">
												<a class="aritcle_card_img" rel="nofollow" href="/xiazai/skill12540" title="javascript-typescript-typescript-scaffold"><img
														src="https://img.php.cn/upload/skill/001/246/273/6adaf20e352aa140.jpg" alt="javascript-typescript-typescript-scaffold" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
												<div class="aritcle_card_info flexColumn">
													<a rel="nofollow" href="/xiazai/skill12540" title="javascript-typescript-typescript-scaffold" class="overflowclass">javascript-typescript-typescript-scaffold</a>
													<p class="overflowclass">你是 TypeScript 项目架构专家，专注于脚手架搭建生产就绪的 Node.js 和前端应用。生成包含现代工具链（pnpm、Vite、Next.js）、类型</p>
												</div>
												<a rel="nofollow" href="/xiazai/skill12540" title="javascript-typescript-typescript-scaffold" 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/179445284295499.png?x-oss-process=image/resize,p_40" alt="Java JDBC 事务管理怎么实现批量操作数据目录"></p><pre class="brush:php;toolbar:false;">import java.sql.BatchUpdateException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class PartialFailureHandling {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/mydb?continueBatchOnError=true";
        String user = "root";
        String password = "password";

        try (Connection conn = DriverManager.getConnection(url, user, password)) {
            conn.setAutoCommit(false);
            String sql = "INSERT INTO directory_entries (id, name) VALUES (?, ?)";
            try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
                // 模拟插入：前两条正常，第三条主键冲突，第四条正常
                pstmt.setInt(1, 1); pstmt.setString(2, "A"); pstmt.addBatch();
                pstmt.setInt(1, 2); pstmt.setString(2, "B"); pstmt.addBatch();
                pstmt.setInt(1, 1); pstmt.setString(2, "C"); pstmt.addBatch(); // Duplicate key
                pstmt.setInt(1, 3); pstmt.setString(2, "D"); pstmt.addBatch();

                try {
                    int[] results = pstmt.executeBatch();
                    conn.commit();
                    // 分析结果数组
                    for (int i = 0; i <p>该示例演示了如何处理部分失败。URL 中添加了 <code>continueBatchOnError=true</code> 参数，使得即使遇到主键冲突，驱动也会尝试执行后续语句。执行后，<code>executeBatch()</code> 返回一个整数数组，其中包含每条语句的执行结果。成功的语句返回影响行数，失败的语句可能返回 <code>SUCCESS_NO_INFO</code> 或 <code>EXECUTE_FAILED</code>。开发者可以遍历该数组，识别哪些条目成功，哪些失败，从而决定是否需要重试或记录日志。预期输出会显示第 0、1、3 条语句成功，第 2 条语句失败。如果未设置 <code>continueBatchOnError</code>，则可能在第 2 条语句处直接抛出异常，导致第 3 条语句未被执行。</p><h2>基于程序中某个输入、条件或结果的具体问题</h2><p>在上述代码中，当 <code>executeBatch()</code> 返回的结果数组中包含 <code>Statement.EXECUTE_FAILED</code> 时，意味着对应的 SQL 语句执行失败。这通常是由于违反约束（如主键重复）、数据类型不匹配或语法错误引起的。在这种情况下，虽然事务尚未提交，但数据库内部可能已经锁定了相关资源。因此，必须在捕获异常后立即调用 <code>rollback()</code>，以释放锁并恢复数据库状态。此外，如果业务逻辑允许部分成功，可以在 <code>catch</code> 块中解析 <code>BatchUpdateException</code> 的 <code>getUpdateCounts()</code> 方法，获取已成功执行的语句索引，然后针对失败的语句进行单独处理或重试。</p>

Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南