From 3f340a3f7e4dae574c9f548be4319f33626c3235 Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Wed, 25 Apr 2018 11:38:05 +0800
Subject: [PATCH]

---
 src/org/redkale/source/PoolJdbcSource.java | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/src/org/redkale/source/PoolJdbcSource.java b/src/org/redkale/source/PoolJdbcSource.java
index a664b657e..b90d17a30 100644
--- a/src/org/redkale/source/PoolJdbcSource.java
+++ b/src/org/redkale/source/PoolJdbcSource.java
@@ -46,7 +46,15 @@ public class PoolJdbcSource extends PoolSource<Connection> {
             @Override
             public void connectionClosed(ConnectionEvent event) {
                 PooledConnection pc = (PooledConnection) event.getSource();
-                if (queue.offer(pc)) saveCounter.incrementAndGet();
+                if (queue.offer(pc)) {
+                    saveCounter.incrementAndGet();
+                } else {
+                    try {
+                        pc.close();
+                    } catch (Exception e) {
+                        dataSource.logger.log(Level.INFO, DataSource.class.getSimpleName() + " " + pc + " close error", e);
+                    }
+                }
             }
 
             @Override