🧑 博主简介：CSDN博客专家，「公益历代文学网」（PC端可以访问：https://lidaiwenxue.com/#/?__c=1000，移动端可关注公众号 “ 心海云图 ” 微信小程序搜索“历代文学”）总架构师，首席架构师，也是联合创始人！16年工作经验，精通Java编程，高并发设计，分布式系统架构设计，Springboot和微服务，熟悉Linux，ESXI虚拟化以及云原生Docker和K8s，热衷于探索科技的边界，并将理论知识转化为实际应用。保持对新技术的好奇心，乐于分享所学，希望通过我的实践经历和见解，启发他人的创新思维。在这里，我希望能与志同道合的朋友交流探讨，共同进步，一起在技术的世界里不断学习成长。
🤝商务合作：请搜索或扫码关注微信公众号 “ 心海云图 ”

---

JDBC批量执行UPDATE语句原理详解

JDBC 提供了批处理功能，可以一次性向数据库发送多个 SQL 语句（如 INSERT、UPDATE、DELETE），从而减少网络往返次数，显著提升批量操作的性能。下面详细介绍如何使用 JDBC 批量执行 UPDATE 语句。

---

1. 批处理的基本概念

批处理允许你将多个 SQL 语句打包在一起发送给数据库执行。对于 UPDATE 操作，通常会有多条更新语句，或者一条带不同参数的相同 SQL 语句（更适合使用 PreparedStatement）。数据库驱动和数据库服务器会尽可能优化这些语句的执行，例如重用解析计划，从而提升效率。

---

2. 使用 Statement 执行批处理

虽然 Statement 也可以执行批处理，但不推荐用于批量更新，因为：

• 需要手动拼接 SQL，容易出错。
• 无法利用预编译的优势。
• 容易引发 SQL 注入风险。

示例（不推荐）：

Statement stmt = connection.createStatement();
stmt.addBatch("UPDATE user SET name='张三' WHERE id=1");
stmt.addBatch("UPDATE user SET name='李四' WHERE id=2");
stmt.addBatch("UPDATE user SET name='王五' WHERE id=3");
int[] results = stmt.executeBatch();

---

3. 使用 PreparedStatement 执行批处理（推荐）

PreparedStatement 预编译 SQL 模板，只需改变参数即可，效率更高且安全。步骤如下：

3.1 关闭自动提交（可选但推荐）

为了确保一批更新的原子性（要么全部成功，要么全部失败），建议关闭自动提交，手动控制事务。

connection.setAutoCommit(false);

3.2 创建 PreparedStatement

编写带占位符 ? 的 SQL 语句。

String sql = "UPDATE user SET name = ? WHERE id = ?";
PreparedStatement pstmt = connection.prepareStatement(sql);

3.3 循环添加批处理参数

对于每一组参数，设置到 PreparedStatement 中，然后调用 addBatch() 将其添加到批处理队列。

// 假设有一个用户列表待更新
List<User> userList = getUserList();
for (User user : userList) {
    pstmt.setString(1, user.getName());
    pstmt.setInt(2, user.getId());
    pstmt.addBatch();   // 添加到批处理
}

3.4 执行批处理

调用 executeBatch() 一次性发送所有更新到数据库执行。返回一个 int[] 数组，每个元素代表对应 SQL 语句影响的行数（具体含义依赖于数据库驱动，通常 -2 表示成功但未知行数，-3 表示执行失败）。

int[] updateCounts = pstmt.executeBatch();

3.5 提交事务

connection.commit();

3.6 处理异常

如果执行过程中发生 BatchUpdateException，可以捕获并获取已成功执行的语句的计数，然后决定回滚或部分提交。

try {
    int[] results = pstmt.executeBatch();
    connection.commit();
} catch (BatchUpdateException e) {
    // 获取成功执行的计数数组
    int[] successfulCounts = e.getUpdateCounts();
    // 处理异常，一般回滚事务
    connection.rollback();
} finally {
    // 关闭资源
    pstmt.close();
    connection.close();
}

3.7 清空批处理（可选）

如果需要在同一个 PreparedStatement 对象上执行多批操作，可以在每批执行后调用 clearBatch() 清空之前的参数。

pstmt.clearBatch();

---

4. 完整示例代码

下面是一个完整的示例，演示如何使用 JDBC 批量更新用户信息。

import java.sql.*;

public class JdbcBatchUpdateExample {

    public static void batchUpdateUsers(List<User> users) {
        String url = "jdbc:mysql://localhost:3306/testdb";
        String username = "root";
        String password = "password";

        String sql = "UPDATE user SET name = ? WHERE id = ?";

        try (Connection conn = DriverManager.getConnection(url, username, password);
             PreparedStatement pstmt = conn.prepareStatement(sql)) {

            // 关闭自动提交，开启事务
            conn.setAutoCommit(false);

            // 添加批处理参数
            for (User user : users) {
                pstmt.setString(1, user.getName());
                pstmt.setInt(2, user.getId());
                pstmt.addBatch();
            }

            // 执行批处理
            int[] results = pstmt.executeBatch();

            // 提交事务
            conn.commit();

            System.out.println("批量更新完成，影响行数：" + results.length);

        } catch (BatchUpdateException e) {
            // 处理部分成功的情况，根据需求回滚或记录
            e.printStackTrace();
            try (Connection conn = DriverManager.getConnection(url, username, password)) {
                conn.rollback();  // 需要获取连接后回滚，注意这里只是示例，实际应在原连接中处理
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        List<User> users = Arrays.asList(
            new User(1, "张三三"),
            new User(2, "李四四"),
            new User(3, "王五五")
        );
        batchUpdateUsers(users);
    }

    static class User {
        int id;
        String name;
        // 构造方法、getter/setter 省略
    }
}

---

5. 注意事项

5.1 批处理大小控制

一次添加过多语句可能导致内存溢出或数据库负载过高。建议分批次提交，例如每 500 条或 1000 条执行一次 executeBatch()，然后 commit()，再继续下一批。

5.2 数据库驱动支持

绝大多数主流数据库（MySQL、Oracle、PostgreSQL、SQL Server 等）的 JDBC 驱动都支持批处理，但具体行为可能略有差异（例如 executeBatch() 返回值的含义）。

5.3 事务管理

如果不关闭自动提交，每条语句执行后会自动提交，无法保证原子性。通常建议在批量更新时关闭自动提交，并在执行完毕后手动提交或回滚。

5.4 重用 PreparedStatement

如果在一个连接中执行多个不同的批量更新，可以重用同一个 PreparedStatement 对象，只需调用 clearBatch() 清空之前的参数，然后重新添加新参数并执行。

5.5 返回值解读

executeBatch() 返回的 int[] 数组：

• 如果值大于等于 0，表示该语句影响的行数（取决于数据库）。
• 如果值为 Statement.SUCCESS_NO_INFO（-2），表示执行成功但未知影响行数。
• 如果值为 Statement.EXECUTE_FAILED（-3），表示执行失败（通常只在 BatchUpdateException 中出现的部分成功情况）。

5.6 使用 try-with-resources 自动关闭资源

确保 PreparedStatement 和 Connection 在使用后正确关闭，避免资源泄漏。

---

6. 性能提升原理

批处理之所以高效，是因为它将多次网络请求合并为一次，减少了通信开销。同时，数据库可以优化执行计划，例如对于同一条 SQL 的多次执行，只需解析一次。在大量数据更新的场景下，性能提升非常明显。

---

7. 总结

使用 JDBC 批量执行 UPDATE 语句的核心是：

• 使用 PreparedStatement 并调用 addBatch() 添加参数。
• 调用 executeBatch() 发送批处理。
• 结合事务控制保证数据一致性。
• 合理分批次执行，避免内存溢出。

掌握这些技巧，可以让你在 Java 应用中高效地进行批量数据更新操作。