JDBC 批处理（Batch）

墨蓝 2024-03-17 23:35 34阅读 0赞

### 批处理 ###

批处理允许您将相关的SQL语句分组到一个批中，并通过对数据库的一次调用提交它们。

当您一次将多个SQL语句发送到数据库时，可以减少通信开销，从而提高性能。

>  *  Statement、 PreparedStatement 和 CallableStatement 的 addBatch ()方法用于向批处理添加单个语句。executeBatch ()用于开始执行组合在一起的所有语句。
>  *  executeBatch()返回一个整数数组，数组中的每个元素表示相应update语句的更新计数。
>  *  正如您可以将语句添加到批处理中进行处理一样，您也可以使用 clearBatch ()方法删除它们。此方法删除所有添加了 addBatch ()方法的语句。但是，不能选择要删除的语句。
>  *  您应该使用DatabaseMetaData.supportsBatchUpdates ()方法来确定目标数据库是否支持批量更新处理。如果 JDBC 驱动程序支持此特性，则该方法返回 true。

### 使用语句对象进行批处理 ###

这是将批处理与Statement对象一起使用的典型步骤序列

>  *  使用这两种*createStatement()*方法创建 Statement 对象。
>  *  使用 setAutoCommit ()将 auto-commit 设置为 false。
>  *  在创建的语句对象上使用addBatch()方法向批处理中添加任意数量的SQL语句。
>  *  对所创建的语句对象使用 executeBatch ()方法执行所有 SQL 语句。
>  *  最后，使用*commit()*方法提交所有更改。

### 实例 ###

以下代码段提供了使用Statement对象进行批量更新的示例

// 创建语句对象
    Statement stmt = conn.createStatement();
    
    // 将自动提交设置为false
    conn.setAutoCommit(false);
    
    // 创建SQL语句
    String SQL = "INSERT INTO Employees (id, first, last, age) " +
                 "VALUES(200,'Zia', 'Ali', 30)";
    // 在批处理中添加上面的SQL语句。
    stmt.addBatch(SQL);
    
    // 再创建一条SQL语句
    String SQL = "INSERT INTO Employees (id, first, last, age) " +
                 "VALUES(201,'Raj', 'Kumar', 35)";
    // 在批处理中添加上面的SQL语句。
    stmt.addBatch(SQL);
    
    // 再创建一条SQL语句
    String SQL = "UPDATE Employees SET age = 35 " +
                 "WHERE id = 100";
    // 在批处理中添加上面的SQL语句。
    stmt.addBatch(SQL);
    
    // 创建一个int []来保存返回的值
    int[] count = stmt.executeBatch();
    
    //明确提交语句以应用更改
    conn.commit();

### 使用PrepareStatement对象进行批处理 ###

这是将批处理与PrepareStatement对象一起使用的典型步骤序列

> 1.  使用占位符创建SQL语句。
> 2.  使用任一 PrepareStatement()方法创建PrepareStatement对象。
> 3.  使用 setAutoCommit ()将 auto-commit 设置为 false。
> 4.  在创建的语句对象上使用 addBatch ()方法添加尽可能多的 SQL 语句到批处理中。
> 5.  对所创建的语句对象使用 executeBatch ()方法执行所有 SQL 语句。
> 6.  最后，使用*commit()*方法提交所有更改。

以下代码段提供了使用PrepareStatement对象进行批量更新的示例

// 创建SQL语句
    String SQL = "INSERT INTO Employees (id, first, last, age) " +
                 "VALUES(?, ?, ?, ?)";
    // 创建PrepareStatement对象
    PreparedStatemen pstmt = conn.prepareStatement(SQL);
    //将自动提交设置为false
    conn.setAutoCommit(false);
    // 设置变量
    pstmt.setInt( 1, 400 );
    pstmt.setString( 2, "Pappu" );
    pstmt.setString( 3, "Singh" );
    pstmt.setInt( 4, 33 );
    // 将其添加到批
    pstmt.addBatch();
    // 设置变量
    pstmt.setInt( 1, 401 );
    pstmt.setString( 2, "Pawan" );
    pstmt.setString( 3, "Singh" );
    pstmt.setInt( 4, 31 );
    // 将其添加到批
    pstmt.addBatch();
    //添加更多批
    //创建一个int []来保存返回的值
    int[] count = stmt.executeBatch();
    //明确提交语句以应用更改
    conn.commit();