批处理 - JDBC 驱动程序 V2.4.3 | OceanBase 文档中心

批处理

更新时间：2026-04-09 15:20:59

通过将多个 UPDATE 或 INSERT 语句分组为一个批处理，将整个批处理发送到数据库并一起处理，可以减少数据库的往返处理次数，从而提高应用程序性能。

OceanBase Connector/J 使用服务器 PrepareStatement 和 Statements 作为与数据库进行批处理通信的标准，并通过 allowMultiQueries 和 rewriteBatchedStatements 两个参数进行管理。如果将 allowMultiQueries 或 rewriteBatchedStatements 选项设置为 true，则 OceanBase Connector/J 将仅使用文本协议。PrepareStatement（参数替换）在客户端由驱动程序处理。

对于插入查询，rewriteBatchedStatements 用于重写 batchedStatement 以在单个 executeQuery 中执行。当它处于活跃状态时，useServerPrepStmts 选项被设置为 false。allowMultiQueries 为 true 时允许多值查询。

在 Oracle 和 MySQL 两种模式下，OceanBase Connector/J 对于批处理的设置会有不同。

Oracle 模式下的批处理

PrepareStatement 处理方式

useServerPrepStmts	rewriteBatchedStatements	allowMultiQueries	INSERT 操作	UPDATE 操作
true	true	true	重新进行Prepare，一共 addBatch 多少次，sqlString 就添加多少个`values()` 后的括号部分。	`UPDATE` SQL 语句通过分号";"拼接在一起。
true	true	false	重新进行Prepare，一共 addBatch 多少次，sqlString 就添加多少个`values()` 后的括号部分。	`UPDATE` SQL 语句通过分号";"拼接在一起。
true	false	true	Prepare 的 sqlString 是正常格式，之后通过多次 `EXECUTE` 来设置参数。	Prepare 的 sqlString 是正常格式，之后通过多次 `EXECUTE` 设置参数。
true	false	false	Prepare 的 sqlString 是正常格式，之后通过多次 `EXECUTE` 来设置参数。	Prepare 的 sqlString 是正常格式，之后通过多次 `EXECUTE` 设置参数。
false	true	true	`INSERT` SQL 语句通过括号"()"拼接在一起，为文本格式。	`UPDATE` SQL 语句通过分号";"拼接在一起。
false	true	false	`INSERT` SQL 语句通过括号"()"拼接在一起，为文本格式。	`UPDATE` SQL 语句通过分号";"拼接在一起。
false	false	true	执行多次 `INSERT` 语句。	执行多次 `UPDATE` 语句。
false	false	false	执行多次 `INSERT` 语句。	执行多次 `UPDATE` 语句。

Statement 处理方式

useServerPrepStmts	rewriteBatchedStatements	allowMultiQueries	INSERT 操作	UPDATE 操作
true	true	true	`INSERT` SQL 语句通过括号"()"拼接在一起，为文本格式。	`UPDATE` SQL 语句通过分号";"拼接在一起（都是文本格式）。
true	true	false	`INSERT` SQL 语句通过括号"()"拼接在一起，为文本格式。	`UPDATE` SQL 语句通过分号";"拼接在一起（都是文本格式）。
true	false	true	逐个执行 `INSERT` 语句。	逐个执行 `UPDATE` 语句。
true	false	false	逐个执行 `INSERT` 语句。	逐个执行 `UPDATE` 语句。
false	true	true	`INSERT` SQL 语句通过括号"()"拼接在一起，为文本格式。	`UPDATE` SQL 语句通过分号";"拼接在一起（都是文本格式）。
false	true	false	`INSERT` SQL 语句通过括号"()"拼接在一起，为文本格式。	`UPDATE` SQL 语句通过分号";"拼接在一起（都是文本格式）。
false	false	true	逐个执行 `INSERT` 语句。	逐个执行 `UPDATE` 语句。
false	false	false	逐个执行 `INSERT` 语句。	逐个执行 `UPDATE` 语句。

MySQL 模式下的批处理

PrepareStatement 处理方式

useServerPrepStmts	rewriteBatchedStatements	allowMultiQueries	INSERT 操作	UPDATE 操作
true	true	true	重新进行Prepare，一共 addBatch 多少次，sqlString 就添加多少个`values()` 后的括号部分。	`UPDATE` SQL 语句通过分号";"拼接在一起。
true	true	false	重新进行Prepare，一共 addBatch 多少次，sqlString 就添加多少个`values()` 后的括号部分。	`UPDATE` SQL 语句通过分号";"拼接在一起。
true	false	true	Prepare 的 sqlString 是正常格式，之后通过多次 `EXECUTE` 来设置参数。	Prepare 的 sqlString 是正常格式，之后通过多次 `EXECUTE` 设置参数。
true	false	false	Prepare 的 sqlString 是正常格式，之后通过多次 `EXECUTE` 来设置参数。	Prepare 的 sqlString 是正常格式，之后通过多次 `EXECUTE` 设置参数。
false	true	true	`INSERT` SQL 语句通过括号"()"拼接在一起，为文本格式。	`UPDATE` SQL 语句通过分号";"拼接在一起。
false	true	false	`INSERT` SQL 语句通过括号"()"拼接在一起，为文本格式。	`UPDATE` SQL 语句通过分号";"拼接在一起。
false	false	true	执行多次 `INSERT` 语句。	执行多次 `UPDATE` 语句。
false	false	false	执行多次 `INSERT` 语句。	执行多次 `UPDATE` 语句。

Statement 处理方式

useServerPrepStmts	rewriteBatchedStatements	allowMultiQueries	INSERT 操作	UPDATE 操作
true	true	true	`INSERT` SQL 语句通过括号"()"拼接在一起，为文本格式。	`UPDATE` SQL 语句通过分号";"拼接在一起（都是文本格式）。
true	true	false	`INSERT` SQL 语句通过括号"()"拼接在一起，为文本格式。	`UPDATE` SQL 语句通过分号";"拼接在一起（都是文本格式）。
true	false	true	逐个执行 `INSERT` 语句。	逐个执行 `UPDATE` 语句。
true	false	false	逐个执行 `INSERT` 语句。	逐个执行 `UPDATE` 语句。
false	true	true	`INSERT` SQL 语句通过括号"()"拼接在一起，为文本格式。	`UPDATE` SQL 语句通过分号";"拼接在一起（都是文本格式）。
false	true	false	`INSERT` SQL 语句通过括号"()"拼接在一起，为文本格式。	`UPDATE` SQL 语句通过分号";"拼接在一起（都是文本格式）。
false	false	true	逐个执行 `INSERT` 语句。	逐个执行 `UPDATE` 语句。
false	false	false	逐个执行 `INSERT` 语句。	逐个执行 `UPDATE` 语句。

示例

public void test_execute_batch() {
    Connection conn = null;
    try {
        for (int q = 0; q < 2; q++) {
            for (int w = 0; w < 2; w++) {
                for (int e = 0; e < 2; e++) {

                    /**
                     *  useServerPrepStmts = true / false
                     *  rewriteBatchedStatements = true / false
                     *  allowMultiQueries = true / false
                     */
                    boolean uSPS = q == 0 ? false : true;
                    String rBS = w == 0 ? "false" : "true";
                    String aMQ = e == 0 ? "false" : "true";

                    String other_condition = "&rewriteBatchedStatements=" + rBS
                            + "&allowMultiQueries=" + aMQ;
                    conn = ConnectionUtils.getDefObOracleConnection(uSPS, true, other_condition);
                    Statement statement = conn.createStatement();

                    try {
                        statement.execute("DROP TABLE test_batch_t");
                    } catch (SQLException exp) {
                        //e.printStackTrace();
                    }

                    String sql = "create table test_batch_t(id int primary key, c1 varchar2(10))";
                    statement.execute(sql);

                    PreparedStatement ps = conn
                            .prepareStatement("insert into test_batch_t(id, c1) values (?, ?)");

                    for (int j = 0; j < 10; j++) {
                        ps.setInt(1, j);
                        ps.setString(2, j + "_test");
                        ps.addBatch();
                    }
                    ps.executeBatch();

                    ps = conn.prepareStatement("update test_batch_t set id = ? where c1 = ?");

                    for (int j = 0; j < 10; j++) {
                        ps.setInt(1, j);
                        ps.setString(2, j + "_test");
                        ps.addBatch();
                    }
                    ps.executeBatch();
                }
            }
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
}