Java使用JDBC向MySQL数据库批次插入10W条数据(测试效率)

import java.io.BufferedReader;import java.io.IOException;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.SQLException;import java.util.Date;import com.mysql.jdbc.Connection;public class MysqlBatchUtil { private String sql="INSERT INTO db_test (param1,param2,param3,param4,param5) VALUES (?,?,?,?,?)";  private String charset="utf-8";  private String connectStr="jdbc:mysql://localhost:3306/test"; private String username="root";  private String password="123456";  private void doStore() throws ClassNotFoundException, SQLException, IOException {   Class.forName("com.mysql.jdbc.Driver");   connectStr += "?useServerPrepStmts=false&rewriteBatchedStatements=true";//此处是测试高效批次插入，去掉之后执行时普通批次插入  Connection conn = (Connection) DriverManager.getConnection(connectStr, username,password);   conn.setAutoCommit(false); // 设置手动提交   int count = 0;   PreparedStatement psts = conn.prepareStatement(sql);   String line = null;   Date begin=new Date();  for(int i=0;i<=100000;i++){   psts.setString(1, i+"param1");    psts.setString(2, i+"param2");    psts.setString(3, i+"param3");    psts.setString(4, i+"param4");    psts.setString(5, i+"param5");    psts.addBatch();   // 加入批量处理    count++;    }   psts.executeBatch(); // 执行批量处理   conn.commit(); // 提交   Date end=new Date();  System.out.println("数量="+count);   System.out.println("运行时间="+(end.getTime()-begin.getTime()));  conn.close();  }  public static void main(String[] args) {  try {   new MysqlBatchUtil().doStore();  } catch (ClassNotFoundException e) {   e.printStackTrace();  } catch (SQLException e) {   e.printStackTrace();  } catch (IOException e) {   e.printStackTrace();  } }}

rewriteBatchedStatements=true

useServerPrepStmts=false

connectStr += "?useServerPrepStmts=false&rewriteBatchedStatements=true";