From 007f635081f4b4492b6124c17397e37f8712fd4d Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Fri, 4 May 2018 20:30:54 +0800
Subject: [PATCH]

---
 src/org/redkale/source/DataSqlJdbcSource.java | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/src/org/redkale/source/DataSqlJdbcSource.java b/src/org/redkale/source/DataSqlJdbcSource.java
index a353a42ba..f2051140e 100644
--- a/src/org/redkale/source/DataSqlJdbcSource.java
+++ b/src/org/redkale/source/DataSqlJdbcSource.java
@@ -321,7 +321,7 @@ public class DataSqlJdbcSource extends DataSqlSource<Connection> {
             future.completeExceptionally(e);
             return future;
         } finally {
-            if (conn != null) writePool.closeConnection(conn);
+            if (conn != null) readPool.closeConnection(conn);
         }
     }
 
@@ -346,7 +346,7 @@ public class DataSqlJdbcSource extends DataSqlSource<Connection> {
             future.completeExceptionally(e);
             return future;
         } finally {
-            if (conn != null) writePool.closeConnection(conn);
+            if (conn != null) readPool.closeConnection(conn);
         }
     }
 
@@ -372,7 +372,7 @@ public class DataSqlJdbcSource extends DataSqlSource<Connection> {
             future.completeExceptionally(e);
             return future;
         } finally {
-            if (conn != null) writePool.closeConnection(conn);
+            if (conn != null) readPool.closeConnection(conn);
         }
     }
 
@@ -395,7 +395,7 @@ public class DataSqlJdbcSource extends DataSqlSource<Connection> {
             future.completeExceptionally(e);
             return future;
         } finally {
-            if (conn != null) writePool.closeConnection(conn);
+            if (conn != null) readPool.closeConnection(conn);
         }
     }
 
@@ -427,7 +427,7 @@ public class DataSqlJdbcSource extends DataSqlSource<Connection> {
             future.completeExceptionally(e);
             return future;
         } finally {
-            if (conn != null) writePool.closeConnection(conn);
+            if (conn != null) readPool.closeConnection(conn);
         }
     }
 
@@ -450,7 +450,7 @@ public class DataSqlJdbcSource extends DataSqlSource<Connection> {
             future.completeExceptionally(e);
             return future;
         } finally {
-            if (conn != null) writePool.closeConnection(conn);
+            if (conn != null) readPool.closeConnection(conn);
         }
     }
 
@@ -496,7 +496,7 @@ public class DataSqlJdbcSource extends DataSqlSource<Connection> {
             future.completeExceptionally(e);
             return future;
         } finally {
-            if (conn != null) writePool.closeConnection(conn);
+            if (conn != null) readPool.closeConnection(conn);
         }
     }
 }