JDBC批量插入数据优化,使用addBatch和executeBatch

SQL的批量插入的问题,如果来个for循环,执行上万次,肯定会很慢,那么,如何去优化呢?

解决方案:用 preparedStatement.addBatch()配合preparedStatement.executeBatch()去批量插入; 效率要比一条一条插入快近60倍。

代码:

    //获取要设置的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; 
    }

 

 

发布评论

分享到:

IT虾米网

微信公众号号:IT虾米 (左侧二维码扫一扫)欢迎添加!

Fine报表权限流程分析记录详解
你是第一个吃螃蟹的人
发表评论

◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。