java实现sql语句批处理

Posted 2020-09-06

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.     }  
31. }