不要怂,就是干,撸起袖子干!

Commit 7ad48925 by Jan Aagaard Meier

Fix for mariadb as well

1 parent 64f3a87a
Showing with 6 additions and 0 deletions
...@@ -90,7 +90,10 @@ module.exports = (function() { ...@@ -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) {
if (connection) {
connection.queryType = 'read' connection.queryType = 'read'
}
done(null, connection) done(null, connection)
}, config) }, config)
}, },
...@@ -106,7 +109,10 @@ module.exports = (function() { ...@@ -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) {
if (connection) {
connection.queryType = 'write' connection.queryType = 'write'
}
done(null, connection) done(null, connection)
}, self.config.replication.write) }, self.config.replication.write)
}, },
......
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!