Merge branch 'node-mysql-options' of https://github.com/poying/sequelize into po…

…ying-node-mysql-options

lib/dialects/mysql/connector-manager.js

@@ -253,17 +253,25 @@ module.exports = (function() {
   }
   }
 
 
   var connect = function(done, config) {
   var connect = function(done, config) {
-    var emitter = new (require('events').EventEmitter)()
     config = config || this.config
     config = config || this.config
 
 
-    var connection = mysql.createConnection({
+    var emitter = new (require('events').EventEmitter)()
+    var connectionConfig = {
       host: config.host,
       host: config.host,
       port: config.port,
       port: config.port,
       user: config.username,
       user: config.username,
       password: config.password,
       password: config.password,
       database: config.database,
       database: config.database,
       timezone: 'Z'
       timezone: 'Z'
-    })
+    };
+
+    if (config.connectionOptions) {
+      Object.keys(config.connectionOptions).forEach(function (key) {
+        connectionConfig[key] = config.connectionOptions[key];
+      });
+    }
+
+    var connection = mysql.createConnection(connectionConfig);
 
 
     connection.connect(function(err) {
     connection.connect(function(err) {
       if (err) {
       if (err) {

lib/sequelize.js

@@ -103,7 +103,8 @@ module.exports = (function() {
       native  : this.options.native,
       native  : this.options.native,
       replication: this.options.replication,
       replication: this.options.replication,
       dialectModulePath: this.options.dialectModulePath,
       dialectModulePath: this.options.dialectModulePath,
-      maxConcurrentQueries: this.options.maxConcurrentQueries
+      maxConcurrentQueries: this.options.maxConcurrentQueries,
+      connectionOptions: this.options.connectionOptions,
     }
     }
 
 
     try {
     try {

test/configuration.test.js

@@ -101,14 +101,23 @@ describe(Support.getTestDialectTeaser("Configuration"), function() {
     })
     })
 
 
     it('should accept four parameters (database, username, password, options)', function(done) {
     it('should accept four parameters (database, username, password, options)', function(done) {
-      var sequelize = new Sequelize('dbname', 'root', 'pass', { port: 999 })
+      var sequelize = new Sequelize('dbname', 'root', 'pass', {
+        port: 999,
+        connectionOptions: {
+          supportBigNumbers: true,
+          bigNumberStrings: true
+        }
+      })
       var config = sequelize.config
       var config = sequelize.config
 
 
       expect(config.database).to.equal('dbname')
       expect(config.database).to.equal('dbname')
       expect(config.username).to.equal('root')
       expect(config.username).to.equal('root')
       expect(config.password).to.equal('pass')
       expect(config.password).to.equal('pass')
       expect(config.port).to.equal(999)
       expect(config.port).to.equal(999)
+      expect(config.connectionOptions.supportBigNumbers).to.be.true
+      expect(config.connectionOptions.bigNumberStrings).to.be.true
       done()
       done()
     })
     })
   })
   })
+
 })
 })

test/support.js

@@ -35,7 +35,8 @@ var Support = {
       logging: options.logging,
       logging: options.logging,
       dialect: options.dialect,
       dialect: options.dialect,
       port:    options.port || process.env.SEQ_PORT || config[options.dialect].port,
       port:    options.port || process.env.SEQ_PORT || config[options.dialect].port,
-      pool:    options.pool
+      pool:    options.pool,
+      connectionOptions: options.connectionOptions || {}
     }
     }
 
 
     if (!!options.host) {
     if (!!options.host) {