bug fixed for FilterChainImpl

2023-03-04 19:17:16 +00:00 · 2012-06-29 14:48:38 +08:00
parent 2913f21822
commit bd3f2ebb92
1 changed files with 10 additions and 0 deletions
@@ -4394,11 +4394,21 @@ public class FilterChainImpl implements FilterChain {

    @Override
    public void dataSource_recycle(DruidPooledConnection connection) throws SQLException {
+        if (this.pos < filterSize) {
+            nextFilter().dataSource_recycle(this, connection);
+            return;
+        }
+        
        connection.recycle();
    }

    @Override
    public DruidPooledConnection dataSource_connect(DruidDataSource dataSource, long maxWaitMillis) throws SQLException {
+        if (this.pos < filterSize) {
+            DruidPooledConnection conn = nextFilter().dataSource_connect(this, dataSource, maxWaitMillis);
+            return conn;
+        }
+        
        return dataSource.getConnectionDirect(maxWaitMillis);
    }