批量添加数据简介

在JDBC中通过PreparedStatement的对象的addBatch()和executeBatch()方法进行数据的批量插入。

  • addBatch()把若干SQL语句装载到一起，然后一次性传送到数据库执行，即是批量处理sql数据的。
  • executeBatch()会将装载到一起的SQL语句执行。

注意：
MySql默认情况下是不开启批处理的。
数据库驱动从5.1.13开始添加了一个对rewriteBatchStatement的参数的处理，该参数能够让MySql开启批处理。在url中添加该参数：rewriteBatchedStatements=true

mysql的url参数

useUnicode [true | false] 是否使用编码集,需配合 characterEncoding 参数使用。
characterEncoding [utf-8 | gbk | …] 编码类型。
useSSL [true | false] 是否使用SSL协议。
rewriteBatchedStatements [true | false] 可以重写向数据库提交的SQL语句。

若有多个参数可&连接
如：?useSSL=false&charecterEncoding=true

  1. import java.sql.Connection;
  2. import java.sql.PreparedStatement;
  4. /**
  5.  * 向mysql数据库批量添加数据
  6.  */
  7. public class AddBatchTest {
  8.     /**
  9.      * 批量添加数据方式一(数据量小)
  10.      */
  11.     public void addBatch_1(){
  12.         Connection connection = null;
  13.         PreparedStatement preparedStatement = null;
  14.         try {
  15.             connection = JDBCUtils.getConnection();
  16.             preparedStatement = connection.prepareStatement("insert into users values (default ,?,?)");
  18.             //参数绑定
  19.             for(int i=0;i<1000;i++){
  20.                 preparedStatement.setString(1,"laogeng"+i);
  21.                 preparedStatement.setInt(2,20);
  22.                 //缓存sql
  23.                 preparedStatement.addBatch();
  24.             }
  25.             preparedStatement.executeBatch();
  27.         }catch (Exception e){
  28.             e.printStackTrace();
  29.         }finally {
  30.             JDBCUtils.clossResource(preparedStatement,connection);
  31.         }
  32.     }
  34.     /**
  35.      * 批量添加数据方式二（数据量大）
  36.      */
  37.     public void addBatch_2(){
  38.         Connection connection = null;
  39.         PreparedStatement preparedStatement = null;
  40.         try {
  41.             connection = JDBCUtils.getConnection();
  42.             preparedStatement = connection.prepareStatement("insert into users values (default ,?,?)");
  44.             //参数绑定
  45.             for(int i=0;i<1000;i++){
  46.                 preparedStatement.setString(1,"laogeng"+i);
  47.                 preparedStatement.setInt(2,20);
  48.                 //缓存sql
  49.                 preparedStatement.addBatch();
  51.                 if(i%500==0){
  52.                     preparedStatement.executeBatch();
  53.                     //清缓存
  54.                     preparedStatement.clearBatch();
  55.                 }
  56.             }
  58.         }catch (Exception e){
  59.             e.printStackTrace();
  60.         }finally {
  61.             JDBCUtils.clossResource(preparedStatement,connection);
  62.         }
  63.     }
  65.     public static void main(String[] args) {
  66.         AddBatchTest addBatchTest = new AddBatchTest();
  67.         addBatchTest.addBatch_2();
  68.     }
  69. }