需求

  1. 一次性插入很多条记录，一条一条插入太慢，开启批处理操作，一次性插入

代码演示

  1. Java代码如下 ```java package com.wisdom.java02;

import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.Statement;

import org.junit.Test;

public class BatchTest {

  1. /*
  2.  * 未使用批量插入数据耗时36814
  3.  * */
  4. @Test
  5. public void batchTest01() throws Exception{
  6.     long start = System.currentTimeMillis();
  7.     // 注册驱动
  8.     Class.forName("com.mysql.jdbc.Driver");
  10.     // 连接数据库
  11.     String url = "jdbc:mysql://192.168.160.131:3306/subquery";
  12.     Connection conn = DriverManager.getConnection(url,"root","2wsx#EDC");
  14.     // 操作数据库
  15.     String sql = "insert into dept values(?,?,?)";
  16.     PreparedStatement pre = conn.prepareStatement(sql);
  17.     for(int i = 0; i < 1000; i++){
  18.         pre.setObject(1, null);
  19.         pre.setObject(2, "dname"+i);
  20.         pre.setObject(3, "loc"+i);
  21.         pre.executeUpdate();
  22.     }
  24.     // 关闭资源
  25.     pre.close();
  26.     conn.close();
  28.     long end = System.currentTimeMillis();
  29.     System.out.println("耗时 : " + (end-start));
  31. }
  33. /*
  34.  * 使用批量插入数据耗时1959
  35.  * */
  36. @Test
  37. public void batchTest02() throws Exception{
  38.     long start = System.currentTimeMillis();
  39.     // 注册驱动
  40.     Class.forName("com.mysql.jdbc.Driver");
  42.     // 连接数据库,rewriteBatchedStatements=true，代表开启批量操作
  43.     String url = "jdbc:mysql://192.168.160.131:3306/subquery?rewriteBatchedStatements=true";
  44.     Connection conn = DriverManager.getConnection(url,"root","2wsx#EDC");
  46.     // 操作数据库
  47.     String sql = "insert into dept values(?,?,?)";
  48.     PreparedStatement pre = conn.prepareStatement(sql);
  49.     for(int i = 0; i < 1000; i++){
  50.         pre.setObject(1, null);
  51.         pre.setObject(2, "dname"+i);
  52.         pre.setObject(3, "loc"+i);
  53.         // //添加到批处理组中，先攒着
  54.         pre.addBatch();
  55.     }
  56.     // 执行批处理操作
  57.     pre.executeBatch();    
  59.     // 关闭资源
  60.     pre.close();
  61.     conn.close();
  63.     long end = System.currentTimeMillis();
  64.     System.out.println("耗时 : " + (end-start));
  66. }

}

```