Remove item from the active queue on connection error

Author: chornyi

lib/dialects/mysql/connector-manager.js

@@ -374,7 +374,7 @@ module.exports = (function() {
 
   var dequeue = function(queueItem) {
     //return the item's connection to the pool
-    if (this.pool) {
+	if (this.pool && queueItem.client) {
       this.pool.release(queueItem.client)
     }
     this.activeQueue = without(this.activeQueue, queueItem)
@@ -404,6 +404,7 @@ module.exports = (function() {
       type: queueItem.query.options.type
     }, function (err, connection) {
       if (err) {
+	    afterQuery.call(self, queueItem)
         queueItem.query.emit('error', err)
         return
       }