阿里云-云小站(无限量代金券发放中)
【腾讯云】云服务器、云数据库、COS、CDN、短信等热卖云产品特惠抢购

Oracle批量提交

200次阅读
没有评论

共计 2172 个字符,预计需要花费 6 分钟才能阅读完成。

今天在项目中碰到一个问题,就是 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(“ 开始调用存过 ”);

更多 Oracle 相关信息见 Oracle 专题页面 http://www.linuxidc.com/topicnews.aspx?tid=12

本文永久更新链接地址 :http://www.linuxidc.com/Linux/2016-09/135219.htm

正文完
星哥玩云-微信公众号
post-qrcode
 0
星锅
版权声明:本站原创文章,由 星锅 于2022-01-22发表,共计2172字。
转载说明:除特殊说明外本站文章皆由CC-4.0协议发布,转载请注明出处。
【腾讯云】推广者专属福利,新客户无门槛领取总价值高达2860元代金券,每种代金券限量500张,先到先得。
阿里云-最新活动爆款每日限量供应
评论(没有评论)
验证码
【腾讯云】云服务器、云数据库、COS、CDN、短信等云产品特惠热卖中