diff --git a/lib/mysql.js b/lib/mysql.js index 86e13eb..d61f8ce 100644 --- a/lib/mysql.js +++ b/lib/mysql.js @@ -37,11 +37,12 @@ exports.initialize = function initializeDataSource(dataSource, callback) { user: s.username || s.user, password: s.password, timezone: s.timezone, - // database: s.database, + // database: s.database, // Don't configure the DB here so that the pool can be used for multiple DBs debug: s.debug, socketPath: s.socketPath, charset: s.collation.toUpperCase(), // Correct by docs despite seeming odd. - supportBigNumbers: s.supportBigNumbers + supportBigNumbers: s.supportBigNumbers, + connectionLimit: s.connectionLimit || 10 }); dataSource.client.on('error', function (err) { @@ -55,50 +56,15 @@ exports.initialize = function initializeDataSource(dataSource, callback) { dataSource.connector = new MySQL(dataSource.client, s); dataSource.connector.dataSource = dataSource; - callback && callback(); - - /* - dataSource.client.getConnection(function (err, connection) { - if (err) { - callback && callback(err); - return; - } - connection.query('USE `' + s.database + '`', function (err) { - if (err) { - if (err.message.match(/(^|: )unknown database/i)) { - var dbName = s.database; - var charset = s.charset; - var collation = s.collation; - var q = 'CREATE DATABASE ' + dbName + ' CHARACTER SET ' + charset + ' COLLATE ' + collation; - connection.query(q, function (error) { - if (!error) { - connection.query('USE ' + s.database, function (err, result) { - connection.release(); - callback && callback(err, result); - }); - } else { - connection.release(); - callback && callback(err); - } - }); - } else { - connection.release(); - callback && callback(err); - } - } else { - connection.release(); - callback && callback(); - } - }); - }); - */ - // MySQL specific column types juggler.ModelBuilder.registerType(function Point() { }); dataSource.EnumFactory = EnumFactory; // factory for Enums. Note that currently Enums can not be registered. + process.nextTick(function() { + callback && callback(); + }); }; exports.MySQL = MySQL;