Oracle批量提交

195次阅读

共计 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(“ 开始调用存过 ”);