首页 > 代码库 > java实现sql语句批处理

java实现sql语句批处理

Statement实现批处理:

优点:能够处理多种不同结构的sql语句

缺点:不能预处理,执行效率较差。对于参数不同的同一条sql语句需要多次调用addBatch()

[java] view plain copy 技术分享技术分享
  1. package com.itheima.batch;  
  2.   
  3. import java.sql.Connection;  
  4. import java.sql.Statement;  
  5.   
  6. import org.junit.Test;  
  7.   
  8. import com.itheima.util.DBUtil;  
  9.   
  10.   
  11. public class StatementBatch {  
  12.   
  13.     /*  mysql数据库: 
  14.         create database batch; 
  15.         use batch; 
  16.         create table mybatch( 
  17.             id int primary key auto_increment, 
  18.             name varchar(50) 
  19.         ); 
  20.         insert into mybatch values (null, ‘1‘); 
  21.         insert into mybatch values (null, ‘2‘); 
  22.         insert into mybatch values (null, ‘3‘); 
  23.         insert into mybatch values (null, ‘4‘); 
  24.      */  
  25.     @Test  
  26.     public void statementBatch() {  
  27.         Connection conn = null;  
  28.         Statement stat = null;  
  29.         try{  
  30.             conn = DBUtil.getConn();  
  31.             stat = conn.createStatement();  
  32.             stat.addBatch("create database batch");  
  33.             stat.addBatch("use batch");  
  34.             stat.addBatch("create table mybatch( id int primary key auto_increment, name varchar(50) )");  
  35.             stat.addBatch("insert into mybatch values (null, ‘1‘)");  
  36.             stat.addBatch("insert into mybatch values (null, ‘2‘)");  
  37.             stat.addBatch("insert into mybatch values (null, ‘3‘)");  
  38.             stat.addBatch("insert into mybatch values (null, ‘4‘)");  
  39.             stat.executeBatch();  
  40.         } catch (Exception e) {  
  41.             e.printStackTrace();  
  42.         } finally {  
  43.             DBUtil.close(conn, stat, null);  
  44.         }  
  45.     }  
  46. }  

PreparedStatement实现批处理:

优点:能够预处理,执行效率高;参数不同的同一条sql语句执行简便

缺点:只能批处理参数不同的同一条sql语句

[java] view plain copy 技术分享技术分享
  1. package com.itheima.batch;  
  2.   
  3. import java.sql.Connection;  
  4. import java.sql.PreparedStatement;  
  5.   
  6. import org.junit.Test;  
  7.   
  8. import com.itheima.util.DBUtil;  
  9.   
  10. public class PrepBatch {  
  11.   
  12.     @Test  
  13.     public void prepBatch() {  
  14.           
  15.         Connection conn = null;  
  16.         PreparedStatement ps = null;  
  17.         try{  
  18.             conn = DBUtil.getConn();  
  19.             ps = conn.prepareStatement("insert into mybatch value(null, ?)");  
  20.             for(int i = 0; i < 1000; i++) {  
  21.                 ps.setString(1, "name" + i);  
  22.                 ps.addBatch();  
  23.             }  
  24.             ps.executeBatch();  
  25.         } catch (Exception e) {  
  26.             e.printStackTrace();  
  27.         } finally {  
  28.             DBUtil.close(conn, ps, null);  
  29.         }  
  30.     }  

java实现sql语句批处理