Oracle批量提交

今天在項目中碰到一個問題,就是需要批量提交10000條語句,

剛開始使用的是statement.addBatch(),結果提交的時候發現需要26秒;

檢查半天,發現批量提交的時候也要關掉自動提交(重要),不然極其影響性能。

改了一下程序,最終代碼如下,執行時間為1秒鍾:

// 獲取一個連接
            Connection conn = null;
            PreparedStatement pstm = null;
            try {
                conn = DBConnectionManager.getInstance().getConnection(
                        ConfigDef.DS_UPDATE_KEY);
                 conn.setAutoCommit(false);   
//                statement = conn.createStatement();
                Map<String, String> resultMap = collectResult.get(0);
                //獲取第一個
                StringBuilder keyParams = new StringBuilder();
                StringBuilder valueParams = new StringBuilder();
                for (Map.Entry<String, String> entry : resultMap.entrySet()) {
                    keyParams.append(", ").append(entry.getKey());
                    valueParams.append(", ? ");
                }
                String sqlTemplate = MessageFormat.format(SqlConstant.INSERT_SQL_TEMPLATE, new Object[]{"TB_BMP_SXAUDIT_DATA_TEMP",keyParams,valueParams});
                logger.info("sqlTemplate:"+ sqlTemplate);
                pstm = conn.prepareStatement(sqlTemplate);   

                int len = collectResult.size();
                String uid =  auditObject.getAuditObjectId()+"_"+ taskSeq;
                for (int i = 0; i < len; i++) {
                    
                    // 對於每一個結果,都要生成往臨時表插入一條SQL語句
                    resultMap = collectResult.get(i);
                    //第一個參數是UID
                    pstm.setString(1, uid);
                    // 第2個參數是TASK_ID
                    pstm.setInt(2, taskInfo.getPlanId());
                    // 第3個參數是BATCH_NO
                    Date batchNO = new Date(format.parse(receiveTask.getTaskStartTime()).getTime());
                    System.out.println(batchNO);
                    pstm.setDate(3, batchNO);
                    //第4個參數是CollectID
                    pstm.setLong(4,Long.valueOf(auditObject.getAuditObjectId()));
                    // 第5個參數是TARGET_DB
                    pstm.setString(5, auditObject.getTargetDb());
                    // 第8個參數是AUDIT_TIMES
                    pstm.setInt(6,1);
                    int idx = 7;
                    for (Map.Entry<String, String> entry : resultMap.entrySet()) {
                        pstm.setString(idx++, entry.getValue());
                    }
                    pstm.addBatch();
                }
                logger.info("開始執行批量提交");
                pstm.executeBatch();
                conn.commit();
                //等待任務執行成功,調用稽核存過
                logger.info("開始調用存過");