Java 和 MySQL - 批处理

批处理允许您将相关 SQL 语句分组为一个批处理，并通过一次调用提交给数据库。

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

• JDBC 驱动程序不需要支持此功能。您应该使用 DatabaseMetaData.supportsBatchUpdates() 方法来确定目标数据库是否支持批量更新处理。如果您的 JDBC 驱动程序支持此功能，则该方法返回 true。

• Statement、PreparedStatement 和 CallableStatement 的 addBatch() 方法用于将各个语句添加到批处理中。 executeBatch() 用于启动所有组合在一起的语句的执行。

• executeBatch() 返回一个整数数组，数组中的每个元素代表相应更新语句的更新计数。

• 就像您可以将语句添加到批处理中进行处理一样，您可以使用 clearBatch() 方法将其删除。此方法将删除您使用 addBatch() 方法添加的所有语句。但是，您无法有选择地选择要删除的语句。

使用语句对象进行批处理

以下是使用语句对象进行批处理的典型步骤序列 −

• 使用 createStatement() 方法创建语句对象。

• 使用 setAutoCommit() 将自动提交设置为 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 对象进行批处理的典型步骤序列 −

• 使用占位符创建 SQL 语句。

• 使用 prepareStatement() 方法创建 PrepareStatement 对象。

• 使用 setAutoCommit() 将自动提交设置为 false。

• 使用 addBatch() 方法在创建的语句对象上将任意数量的 SQL 语句添加到批处理中。

• 使用 executeBatch() 方法在创建的语句对象上执行所有 SQL 语句。

• 最后，使用 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();