fix(pool): destroy pooled errors properly with replication (#11140)

.gitignore

@@ -20,3 +20,4 @@ coverage
 esdoc
 esdoc
 package-lock.json
 package-lock.json
 yarn.lock
 yarn.lock
+*.code-workspace
\ No newline at end of file

lib/dialects/abstract/connection-manager.js

@@ -159,12 +159,14 @@ class ConnectionManager {
         }
         }
       },
       },
       destroy: mayBeConnection => {
       destroy: mayBeConnection => {
-        if (mayBeConnection instanceof Error) {
-          return Promise.resolve();
+        if (mayBeConnection.queryType === undefined) {
+          return Promise.all([
+            this.pool.read.destroy(mayBeConnection).catch(/Resource not currently part of this pool/, () => {}),
+            this.pool.write.destroy(mayBeConnection).catch(/Resource not currently part of this pool/, () => {})
+          ]);
         }
         }
 
 
-        return this.pool[mayBeConnection.queryType].destroy(mayBeConnection)
-          .tap(() => { debug('connection destroy'); });
+        return this.pool[mayBeConnection.queryType].destroy(mayBeConnection);
       },
       },
       clear: () => {
       clear: () => {
         return Promise.join(
         return Promise.join(
@@ -188,7 +190,14 @@ class ConnectionManager {
             })
             })
             .catch(err => err);
             .catch(err => err);
         },
         },
-        destroy: connection => this._disconnect(connection),
+        destroy: mayBeConnection => {
+          if (mayBeConnection instanceof Error) {
+            return Promise.resolve();
+          }
+
+          return this._disconnect(mayBeConnection)
+            .tap(() => { debug('connection destroy'); });
+        },
         validate: config.pool.validate
         validate: config.pool.validate
       }, {
       }, {
         Promise: config.pool.Promise,
         Promise: config.pool.Promise,
@@ -210,7 +219,14 @@ class ConnectionManager {
             })
             })
             .catch(err => err);
             .catch(err => err);
         },
         },
-        destroy: connection => this._disconnect(connection),
+        destroy: mayBeConnection => {
+          if (mayBeConnection instanceof Error) {
+            return Promise.resolve();
+          }
+
+          return this._disconnect(mayBeConnection)
+            .tap(() => { debug('connection destroy'); });
+        },
         validate: config.pool.validate
         validate: config.pool.validate
       }, {
       }, {
         Promise: config.pool.Promise,
         Promise: config.pool.Promise,