From c176891fedf151f6055a7e1e32c929c70bf1a43f Mon Sep 17 00:00:00 2001 From: terrymanu Date: Mon, 21 Aug 2017 11:47:41 +0800 Subject: [PATCH] refactor BatchPreparedStatementExecutor --- .../executor/type/batch/BatchPreparedStatementExecutor.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/executor/type/batch/BatchPreparedStatementExecutor.java b/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/executor/type/batch/BatchPreparedStatementExecutor.java index 66cc25c057..950d6f4b0a 100644 --- a/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/executor/type/batch/BatchPreparedStatementExecutor.java +++ b/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/executor/type/batch/BatchPreparedStatementExecutor.java @@ -73,10 +73,11 @@ public final class BatchPreparedStatementExecutor { int count = 0; for (BatchPreparedStatementUnit each : batchPreparedStatementUnits) { for (Map.Entry entry : each.getJdbcAndActualAddBatchCallTimesMap().entrySet()) { + int value = null == results.get(count) ? 0 : results.get(count)[entry.getValue()]; if (DatabaseType.Oracle == dbType) { - result[entry.getKey()] = results.get(count)[entry.getValue()]; + result[entry.getKey()] = value; } else { - result[entry.getKey()] += null == results.get(count) ? 0 : results.get(count)[entry.getValue()]; + result[entry.getKey()] += value; } } count++; -- GitLab