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);
            }
        }
  • 相关阅读:
    HTML5 完美解决javascript中iphone手机和android手机复制文本到剪切板问题
    去除移动端alert/confirm的网址(url)
    项目通过tomcat部署到服务器,请求数据中文乱码问题
    JEECG中表单提交的中断
    mysql数据库1129错误
    java中比较两个double类型值的大小
    spring配置上传文件大小
    GET方式,获取服务器文件
    java中多个数字运算后值不对(失真)处理方法
    V-rep学习笔记:关节力矩控制
  • 原文地址:https://www.cnblogs.com/androidsuperman/p/6987005.html
Copyright © 2011-2022 走看看