fix #452

apache · Nov 20, 2017 · 3c27db2 · 3c27db2
1 parent bce237f
commit 3c27db2
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/RELEASE-NOTES.md b/RELEASE-NOTES.md
@@ -3,6 +3,7 @@
 ### 缺陷修正
 
 1. [ISSUE #436](https://github.com/shardingjdbc/sharding-jdbc/issues/436) 读写分离多从库配置RoundRobin算法并使用MyBatis时，只能路由到同一从库
+1. [ISSUE #452](https://github.com/shardingjdbc/sharding-jdbc/issues/452) DDL语句分片至多个表会造成连接泄漏的问题
 
 ## 2.0.0.M2
 

diff --git a/...jdbc-core/src/main/java/io/shardingjdbc/core/jdbc/core/connection/ShardingConnection.java b/...jdbc-core/src/main/java/io/shardingjdbc/core/jdbc/core/connection/ShardingConnection.java
@@ -72,10 +72,9 @@ public Collection<Connection> getAllConnections(final String dataSourceName) thr
             dataSources = new HashMap<>(1, 1);
             dataSources.put(dataSourceName, dataSource);
         }
-
         Collection<Connection> result = new LinkedList<>();
         for (Entry<String, DataSource> entry : dataSources.entrySet()) {
-            Connection connection = entry.getValue().getConnection();
+            Connection connection = getCachedConnections().containsKey(entry.getKey()) ? getCachedConnections().get(entry.getKey()) : entry.getValue().getConnection();
             replayMethodsInvocation(connection);
             getCachedConnections().put(entry.getKey(), connection);
             result.add(connection);