Java & MySQL - 批处理

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

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

JDBC驱动程序不需要支持此功能。您应该使用DatabaseMetaData.supportsBatchUpdates()方法来确定目标数据库是否支持批更新处理。如果您的JDBC驱动程序支持此功能，则该方法返回true。
Statement、PreparedStatement和CallableStatement的addBatch()方法用于将单个语句添加到批处理中。executeBatch()用于启动对所有分组语句的执行。
executeBatch()返回一个整数数组，数组的每个元素代表相应更新语句的更新计数。
就像您可以将语句添加到批处理以进行处理一样，您也可以使用clearBatch()方法将其删除。此方法删除您使用addBatch()方法添加的所有语句。但是，您不能选择性地选择要删除哪个语句。

使用Statement对象的批处理

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

使用createStatement()方法创建一个Statement对象。
使用setAutoCommit()将自动提交设置为false。
使用在创建的Statement对象上的addBatch()方法将任意数量的SQL语句添加到批处理中。
使用在创建的Statement对象上的executeBatch()方法执行所有SQL语句。
最后，使用commit()方法提交所有更改。

示例

以下代码片段提供了一个使用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,'Zia', 'Ali', 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,'Raj', 'Kumar', 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();

使用PrepareStatement对象的批处理

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

创建带有占位符的SQL语句。
使用prepareStatement()方法创建PrepareStatement对象。
使用setAutoCommit()将自动提交设置为false。
使用在创建的Statement对象上的addBatch()方法将任意数量的SQL语句添加到批处理中。
使用在创建的Statement对象上的executeBatch()方法执行所有SQL语句。
最后，使用commit()方法提交所有更改。

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

// 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, "Pappu" );
pstmt.setString( 3, "Singh" );
pstmt.setInt( 4, 33 );
// Add it to the batch
pstmt.addBatch();

// Set the variables
pstmt.setInt( 1, 401 );
pstmt.setString( 2, "Pawan" );
pstmt.setString( 3, "Singh" );
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();

打印页面