JDBC p4 批处理

批处理

• 基本介绍：
  
  
  
  • 当需要成批插入或者更新记录时。可以采用Java的批量更新机制，这一机制允许多条语句一次性提交给数据库批量处理。通常情况下比单独提交处理更有效率。
    
  • JDBC的批量处理语句包括下面方法：
    
    
    
    • addBatch()：添加需要批量处理的SQL语句或参数；
      
    • executeBatch()：执行批量处理语句；
      
    • clearBatch()：清空批处理包的语句；
      
    
    
  • JDBC连接MySQL时，如果要使用批处理功能，请在url中加入参数：rewriteBatchedStatements=true。
    
  • 批处理往往和PreparedStatement一起搭配使用，可以即减少编译次数，又减少运行次数，效率大大提高。
    
  • 批处理是将我们的SQL语句先存放在ArrayList中，当添加到指定的值后就executeBatch，批量处理。批处理会减少我们发送sql语句的网络开销，而且减少编译次数，因此效率提高。
    
  案例：
  1. package com.hspedu.jdbc.batch_;
  3. import com.hspedu.jdbc.utils.JDBCUtils;
  4. import org.junit.jupiter.api.Test;
  6. import java.sql.Connection;
  7. import java.sql.PreparedStatement;
  8. import java.sql.SQLException;
  9. import java.sql.Statement;
  11. /**
  12. * @author: 86199
  13. * @date: 2023/7/20 15:34
  14. * Description: 演示Java 的 批处理
  15. */
  16. public class Batch_ {
  17.     //传统方法添加数据到admin2表
  18.     @Test
  19.     public void noBatch(){
  20.         //得到连接
  21.         Connection connection;
  22.         PreparedStatement preparedStatement;
  24.         try {
  25.             connection = JDBCUtils.getConnection();
  27.             String sql = "insert into admin2 values (NULL, ?, ?)";
  28.             preparedStatement = connection.prepareStatement(sql);
  31.             System.out.println("开始执行");
  32.             long start = System.currentTimeMillis();
  33.             for (int i = 0; i < 5000; i++) {
  34.                 preparedStatement.setString(1, "jack" + i);
  35.                 preparedStatement.setString(2, "666");
  36.                 //执行
  37.                 preparedStatement.executeUpdate();
  38.             }
  39.             long end = System.currentTimeMillis();
  40.             System.out.println("传统方式 耗时 = " + (end - start));//传统方式 耗时 = 4825
  41.         } catch (SQLException e) {
  42.             throw new RuntimeException(e);
  43.         }
  45.         //关闭资源
  46.         JDBCUtils.close(null, preparedStatement, connection);
  47.     }
  50.     //使用批量方式添加数据
  51.     @Test
  52.     public void batch(){
  53.         //得到连接
  54.         Connection connection;
  55.         PreparedStatement preparedStatement;
  57.         try {
  58.             connection = JDBCUtils.getConnection();
  60.             String sql = "insert into admin2 values (NULL, ?, ?)";
  61.             preparedStatement = connection.prepareStatement(sql);
  64.             System.out.println("开始执行");
  65.             long start = System.currentTimeMillis();
  66.             for (int i = 0; i < 5000; i++) {
  67.                 preparedStatement.setString(1, "jack" + i);
  68.                 preparedStatement.setString(2, "666");
  69.                 //将 sql语句加入批处理包
  70.                 //执行
  71.                 preparedStatement.addBatch();
  72.                 //当有5000条时，再批量执行
  73.                 if((i + 1) % 1000 == 0){
  74.                     preparedStatement.executeBatch();
  75.                     //清空
  76.                     preparedStatement.clearBatch();
  77.                 }
  78.             }
  79.             long end = System.currentTimeMillis();
  80.             System.out.println("批量包方式 耗时 = " + (end - start));//批处理方式 耗时 = 87
  81.         } catch (SQLException e) {
  82.             throw new RuntimeException(e);
  83.         }
  85.         //关闭资源
  86.         JDBCUtils.close(null, preparedStatement, connection);
  87.     }
  88. }

  复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！