jdbc 批量处理

批量处理允许将相关的sql语句分组到批处理中，并通过对数据库的一次调用来提交它们，一次执行完成与数据库之间的交互。

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

1. jdbc 批量处理方法

• 使用 databasemetadata.supportsbatchupdates() 方法来确定目标数据库是否支持批量更新处理。如果 jdbc 驱动程序支持此功能，该方法将返回 true。
• statement， preparedstatement 和 callablestatement 的 addbatch() 方法用于将单个语句添加到批处理。 executebatch()用于执行组成批量的所有语句。
• executebatch() 返回一个整数数组，数组的每个元素表示相应更新语句的更新计数。
• 就像将批处理语句添加到处理中一样，可以使用 clearbatch() 方法删除它们。此方法将删除所有使用 addbatch() 方法添加的语句。但是，无法指定选择某个要删除的语句。

2. 使用 statement 批处理步骤

以下是使用 statement对象的批处理的典型步骤序列 -

• 使用 createstatement() 方法创建 statement 对象。
• 使用 setautocommit() 将自动提交设置为 false。
• 使用 addbatch() 方法在创建的 statement 对象上添加 sql 语句到批处理中。
• 在创建的 statement 对象上使用 executebatch() 方法执行所有sql语句。
• 最后，使用 commit()方法提交所有更改。

3. 使用 statement 批处理范例

以下代码片段提供了使用 statement对象的批量更新示例：

// create statement object
statement stmt = conn.createstatement();

// set auto-commit to false
conn.setautocommit(false);

// create sql statement
string sql = "insert into employees (id, first, last, age) " +
             "values(200,'ruby', 'yang', 30)";
// add above sql statement in the batch.
stmt.addbatch(sql);

// create one more sql statement
string sql = "insert into employees (id, first, last, age) " +
             "values(201,'java', 'lee', 35)";
// add above sql statement in the batch.
stmt.addbatch(sql);

// create one more sql statement
string sql = "update employees set age = 35 " +
             "where id = 100";
// add above sql statement in the batch.
stmt.addbatch(sql);

// create an int[] to hold returned values
int[] count = stmt.executebatch();

//explicitly commit statements to apply changes
conn.commit();

4. 使用 preparestatement 批处理步骤

以下是使用 preparestatement对象进行批处理的典型步骤顺序：

• 使用占位符创建sql语句。
• 使用 preparestatement()方法创建 preparestatement对象。
• 使用 setautocommit()将自动提交设置为 false。
• 使用 addbatch()方法在创建的 statement对象上添加sql语句到批处理中。
• 在创建的 statement对象上使用 executebatch()方法执行所有sql语句。
• 最后，使用 commit()方法提交所有更改。

5. 使用 preparedstatement 批处理范例

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

// create sql statement
string sql = "insert into employees (id, first, last, age) " +
             "values(?, ?, ?, ?)";

// create preparestatement object
preparedstatemen pstmt = conn.preparestatement(sql);

//set auto-commit to false
conn.setautocommit(false);

// set the variables
pstmt.setint( 1, 400 );
pstmt.setstring( 2, "jdbc" );
pstmt.setstring( 3, "li" );
pstmt.setint( 4, 33 );
// add it to the batch
pstmt.addbatch();

// set the variables
pstmt.setint( 1, 401 );
pstmt.setstring( 2, "csharp" );
pstmt.setstring( 3, "liang" );
pstmt.setint( 4, 31 );
// add it to the batch
pstmt.addbatch();

//add more batches
.
.
.
.
//create an int[] to hold returned values
int[] count = stmt.executebatch();

//explicitly commit statements to apply changes
conn.commit();