JDBC 中的批量更新是什么?解释一下?

jdbcjava 8programmingobject oriented programming更新于 2025/5/30 19:56:17

将一组 INSERT、UPDATE 或 DELETE 命令(这些命令会生成更新计数值)分组并一次性执行,这种机制称为批量更新。

向批处理中添加语句

Statement、PreparedStatement 和 CallableStatement 对象包含一个(命令)列表,您可以使用 addBatch() 方法向其中添加相关语句(这些语句会返回更新计数值)。

stmt.addBatch(insert1);
stmt.addBatch(insert2);
stmt.addBatch(insert3);

执行批处理

添加所需语句后,您可以使用 Statement 接口的 executeBatch() 方法执行批处理。

stmt.executeBatch();

使用批量更新,我们可以减少通信开销并提高 Java 应用程序的性能。

注意:在向批处理中添加语句之前,您需要使用 con.setAutoCommit(false) 关闭自动提交;执行批处理后,您需要使用 con.commit() 方法保存更改。

示例

假设我们在数据库中创建了一个名为 Sales 的表,其描述如下:

+-------------------+--------------+------+-----+---------+-------+
| Field             | Type         | Null | Key | Default | Extra |
+-------------------+--------------+------+-----+---------+-------+
| Product_Name      | varchar(255) | YES  |     | NULL    |       |
| Name_Of_Customer  | varchar(255) | YES  |     | NULL    |       |
| Month_Of_Dispatch | varchar(255) | YES  |     | NULL    |       |
| Price             | int(11)      | YES  |     | NULL    |       |
| Location          | varchar(255) | YES  |     | NULL    |       |
+-------------------+--------------+------+-----+---------+-------+

此示例尝试使用批量更新将一组语句插入到上述表中。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
public class BatchUpdates {
   public static void main(String args[])throws Exception {
      //获取连接
      String mysqlUrl = "jdbc:mysql://localhost/sampleDB";
      Connection con = DriverManager.getConnection(mysqlUrl, "root", "password");
      System.out.println("连接已建立......");
      //创建 Statement 对象
      Statement stmt = con.createStatement();
      //设置自动提交为 false
      con.setAutoCommit(false);
      //插入记录的语句
      String insert1 = "INSERT INTO Dispatches VALUES ('KeyBoard', 'Amith', 'January', 1000, 'Hyderabad')";
      String insert2 = "INSERT INTO Dispatches VALUES ('Earphones', 'SUMITH', 'March', 500, 'Vishakhapatnam')";
      String insert3 = "INSERT INTO Dispatches VALUES ('Mouse', 'Sudha', 'September', 200, 'Vijayawada')";
      //将语句添加到批处理
      stmt.addBatch(insert1);
      stmt.addBatch(insert2);
      stmt.addBatch(insert3);
      //执行批处理
      stmt.executeBatch();
      //保存更改
      con.commit();
      System.out.println("Records inserted......");
   }
}

输出

连接已建立......
Records inserted......

如果您验证表的内容,您可以在其中找到插入的记录:

+--------------+------------------+-------------------+-------+----------------+
| Product_Name | Name_Of_Customer | Month_Of_Dispatch | Price | Location |
+--------------+------------------+-------------------+-------+----------------+
| KeyBoard     | Amith            | January           | 1000  | Hyderabad |
| Earphones    | SUMITH           | March             | 500   | Vishakhapatnam |
| Mouse        | Sudha            | September         | 200   | Vijayawada |
+--------------+------------------+-------------------+-------+----------------+

相关文章