Handle reconnects for MySQL read replicas with pooling

Author: chornyi

lib/dialects/mysql/connector-manager.js

@@ -351,10 +351,10 @@ module.exports = (function() {
       if (typeof(pool.destroy) == 'function') {
   	    pool.destroy(client)
       } else {
-  	    if (pool.read && typeof(pool.read.destroy) == 'function') {
+	    if (client.queryType == 'read' && pool.read && typeof(pool.read.destroy) == 'function') {
   		  pool.read.destroy(client)
   	    }
-  	    if (pool.write && typeof(pool.write.destroy) == 'function') {
+	    if (client.queryType == 'write' && pool.write && typeof(pool.write.destroy) == 'function') {
   		  pool.write.destroy(client)
   	    }
       }