From 21c326939bce09f5d0ec73f45563e85807bf986a Mon Sep 17 00:00:00 2001
From: YunaiV <zhijiantianya@gmail.com>
Date: Sat, 12 Aug 2017 16:20:27 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=20AbstractConnectionAdapter?=
 =?UTF-8?q?=20=E7=9A=84=20#commit()=EF=BC=8C=E8=A7=A3=E5=86=B3=20=E6=9F=90?=
 =?UTF-8?q?=E4=B8=AA=20connection=20commit=20=E5=BC=82=E5=B8=B8=E6=97=B6?=
 =?UTF-8?q?=EF=BC=8C=E5=90=8E=E9=9D=A2=E7=9A=84=20connection=20=E4=B8=8D?=
 =?UTF-8?q?=E6=89=A7=E8=A1=8C=20commit?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../sharding/jdbc/adapter/AbstractConnectionAdapter.java  | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/jdbc/adapter/AbstractConnectionAdapter.java b/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/jdbc/adapter/AbstractConnectionAdapter.java
index e21c6fd1c3..fc26e00557 100644
--- a/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/jdbc/adapter/AbstractConnectionAdapter.java
+++ b/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/jdbc/adapter/AbstractConnectionAdapter.java
@@ -63,9 +63,15 @@ public abstract class AbstractConnectionAdapter extends AbstractUnsupportedOpera
     
     @Override
     public final void commit() throws SQLException {
+        Collection<SQLException> exceptions = new LinkedList<>();
         for (Connection each : getConnections()) {
-            each.commit();
+            try {
+                each.commit();
+            } catch (final SQLException ex) {
+                exceptions.add(ex);
+            }
         }
+        throwSQLExceptionIfNecessary(exceptions);
     }
     
     @Override
-- 
GitLab