博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
JDBC批量插入优化addbatch
阅读量:5301 次
发布时间:2019-06-14

本文共 1728 字,大约阅读时间需要 5 分钟。

原文 http://www.cnblogs.com/kxdblog/p/4056010.html

//  获取要设置的Arp基准的List后,插入Arp基准表中    
    
public
boolean insertArpStandardList(List<ArpTable> list) {
        
Connection
conn =
null
;
        
PreparedStatement ps =
null
;
        
ResultSet rs =
null
;
        
//MySql的JDBC连接的url中要加rewriteBatchedStatements参数,并保证5.1.13以上版本的驱动,才能实现高性能的批量插入。
        
//优化插入性能,用JDBC的addBatch方法,但是注意在连接字符串加上面写的参数。
        
//例如: String connectionUrl=
"jdbc:mysql://192.168.1.100:3306/test?rewriteBatchedStatements=true"
;
         
        
String sql =
"insert into arp_standard(guid, devicebrand, devicename, deviceip, ipaddress, "
+
                     
"macaddress, createtime) values(?,?,?,?,?,?,?)"
;
         
        
try{
            
conn = DBConnection.getConnection();
            
ps = conn.prepareStatement(sql);
             
            
//优化插入第一步       设置手动提交  
            
conn.setAutoCommit(
false
); 
             
            
int
len = list.
size
();
            
for
(
int
i=0; i<len; i++) {
                
ps.setString(1, list.get(i).getGuid());
                
ps.setString(2, list.get(i).getDeviceBrand());
                
ps.setString(3, list.get(i).getDeviceName());
                
ps.setString(4, list.get(i).getDeviceIp());
                
ps.setString(5, list.get(i).getIpAddress());
                
ps.setString(6, list.get(i).getMacAddress());
                
ps.setString(7, list.get(i).getCreateTime());
                 
                
//if(ps.executeUpdate() != 1) r =
false
;    优化后,不用传统的插入方法了。
                 
                
//优化插入第二步       插入代码打包,等一定量后再一起插入。
                
ps.addBatch(); 
                
//if(ps.executeUpdate() != 1)result =
false
;
                
//每200次提交一次 
                
if((i!=0 && i%200==0) || i==len-1){//可以设置不同的大小;如50,100,200,500,1000等等  
                    
ps.executeBatch();  
                    
//优化插入第三步       提交,批量插入数据库中。
                    
conn.
commit
();  
                    
ps.clearBatch();        //提交后,Batch清空。
                
}
            
}
 
        
} catch (Exception e) {
            
System.
out
.println(
"MibTaskPack->getArpInfoList() error:"
+ e.getMessage());
            
return
false
;   //出错才报
false
        
} finally {
            
DBConnection.closeConection(conn, ps, rs);
        
}
        
return
true
;
    
}

  效率要比一条一条插入快近60倍。比如for循环或者insert into table test select * from....

坚持不懈

转载于:https://www.cnblogs.com/Simeonwu/p/7568601.html

你可能感兴趣的文章
selenium+java iframe定位
查看>>
P2P综述
查看>>
第五章 如何使用Burp Target
查看>>
Sprint阶段测试评分总结
查看>>
sqlite3经常使用命令&amp;语法
查看>>
linux下编译openjdk8
查看>>
【python】--迭代器生成器装饰器
查看>>
Pow(x, n)
查看>>
安卓当中的线程和每秒刷一次
查看>>
每日一库:Modernizr.js,es5-shim.js,es5-safe.js
查看>>
ajax连接服务器框架
查看>>
wpf样式绑定 行为绑定 事件关联 路由事件实例
查看>>
利用maven管理项目之POM文件配置
查看>>
TCL:表格(xls)中写入数据
查看>>
Oracle事务
查看>>
String类中的equals方法总结(转载)
查看>>
属性动画
查看>>
标识符
查看>>
给大家分享一张CSS选择器优选级图谱 !
查看>>
Win7中不能调试windows service
查看>>