zoukankan      html  css  js  c++  java
  • Java -- JDBC 学习--批量处理

    批量处理JDBC语句提高处理速度

    当需要成批插入或者更新记录时。可以采用Java的批量更新机制,这一机制允许多条语句一次性提交给数据库批量处理。通常情况下比单独提交处理更有效率
    JDBC的批量处理语句包括下面两个方法:

    1. addBatch(String):添加需要批量处理的SQL语句或是参数;
    2. executeBatch();执行批量处理语句;

    通常我们会遇到两种批量执行SQL语句的情况:
    多条SQL语句的批量处理;
    一个SQL语句的批量传参;

    多条SQL语句的批量处理

    一个SQL语句的批量传参

    例子:

    1,事务

    2,PreparedStatement 

    3,addBatch(String)+executeBatch()

    来插入巨量数据

    @Test
        public void testBatch(){
            Connection connection = null;
            PreparedStatement preparedStatement = null;
            String sql = null;
            
            try {
                connection = JDBCTools.getConnection();
                JDBCTools.beginTx(connection);
                sql = "INSERT INTO customers VALUES(?,?,?)";
                preparedStatement = connection.prepareStatement(sql);
                Date date = new Date(new java.util.Date().getTime());
                
                long begin = System.currentTimeMillis();
                for(int i = 0; i < 100000; i++){
                    preparedStatement.setInt(1, i + 1);
                    preparedStatement.setString(2, "name_" + i);
                    preparedStatement.setDate(3, date);
                    
                    //"积攒" SQL 
                    preparedStatement.addBatch();
                    
                    //当 "积攒" 到一定程度, 就统一的执行一次. 并且清空先前 "积攒" 的 SQL
                    if((i + 1) % 300 == 0){
                        preparedStatement.executeBatch();
                        preparedStatement.clearBatch();
                    }
                }
                
                //若总条数不是批量数值的整数倍, 则还需要再额外的执行一次. 
                if(100000 % 300 != 0){
                    preparedStatement.executeBatch();
                    preparedStatement.clearBatch();
                }
                
                long end = System.currentTimeMillis();
                
                System.out.println("Time: " + (end - begin)); //569
                
                JDBCTools.commit(connection);
            } catch (Exception e) {
                e.printStackTrace();
                JDBCTools.rollback(connection);
            } finally{
                JDBCTools.releaseDB(null, preparedStatement, connection);
            }
        }
  • 相关阅读:
    开发中的一些总结。。。
    Directory Listing Denied错误
    webservice的一些使用心得。。
    vs2005 sp1 补丁后,不能初始化
    谈C/C++指针精髓
    CString 的函数
    javaScript 中 call 函数的用法说明 & 继承
    条款12: 尽量使用初始化而不要在构造函数里赋值(effectiveC++)
    js日期时间函数(经典+完善+实用)
    学习之路一 记录学习中的手记
  • 原文地址:https://www.cnblogs.com/androidsuperman/p/6987005.html
Copyright © 2011-2022 走看看