Merge pull request #1298 from janmeier/badPooling

Fix for connection errors when using replication

lib/dialects/mariadb/connector-manager.js

@@ -90,7 +90,10 @@ module.exports = (function() {
             var config = self.config.replication.read[reads++]
             var config = self.config.replication.read[reads++]
 
 
             connect.call(self, function (err, connection) {
             connect.call(self, function (err, connection) {
-              connection.queryType = 'read'
+              if (connection) {
+                connection.queryType = 'read'
+              }
+
               done(null, connection)
               done(null, connection)
             }, config)
             }, config)
           },
           },
@@ -106,7 +109,10 @@ module.exports = (function() {
           name: 'sequelize-write',
           name: 'sequelize-write',
           create: function (done) {
           create: function (done) {
             connect.call(self, function (err, connection) {
             connect.call(self, function (err, connection) {
-              connection.queryType = 'write'
+              if (connection) {
+                connection.queryType = 'write'
+              }
+              
               done(null, connection)
               done(null, connection)
             }, self.config.replication.write)
             }, self.config.replication.write)
           },
           },

lib/dialects/mysql/connector-manager.js

@@ -88,8 +88,11 @@ module.exports = (function() {
             var config = self.config.replication.read[reads++];
             var config = self.config.replication.read[reads++];
 
 
             connect.call(self, function (err, connection) {
             connect.call(self, function (err, connection) {
-              connection.queryType = 'read'
-              done(null, connection)
+              if (connection) {
+                connection.queryType = 'read'
+              }
+
+              done(err, connection)
             }, config);
             }, config);
           },
           },
           destroy: function(client) {
           destroy: function(client) {
@@ -104,8 +107,11 @@ module.exports = (function() {
           name: 'sequelize-write',
           name: 'sequelize-write',
           create: function (done) {
           create: function (done) {
             connect.call(self, function (err, connection) {
             connect.call(self, function (err, connection) {
-              connection.queryType = 'write'
-              done(null, connection)
+              if (connection) {
+                connection.queryType = 'read'
+              }
+
+              done(err, connection)
             }, self.config.replication.write);
             }, self.config.replication.write);
           },
           },
           destroy: function(client) {
           destroy: function(client) {
@@ -296,7 +302,6 @@ module.exports = (function() {
     }
     }
 
 
     var connection = mysql.createConnection(connectionConfig);
     var connection = mysql.createConnection(connectionConfig);
-
     connection.connect(function(err) {
     connection.connect(function(err) {
       if (err) {
       if (err) {
         switch(err.code) {
         switch(err.code) {

test/sequelize.test.js

@@ -64,6 +64,22 @@ describe(Support.getTestDialectTeaser("Sequelize"), function () {
               done()
               done()
             })
             })
         })
         })
+
+        it('triggers the error event when using replication', function (done) {
+          new Sequelize('sequelize', null, null, {
+            replication: {
+              read: {
+                host: 'localhost',
+                username: 'omg',
+                password: 'lol'
+              }
+            }
+          }).authenticate()
+            .complete(function(err, result) {
+              expect(err).to.not.be.null
+              done()
+            })
+        })
       })
       })
     })
     })
   }
   }