Skip to content

Commit

Permalink
configurable sql connection pool
Browse files Browse the repository at this point in the history
  • Loading branch information
oded leiba committed May 18, 2016
1 parent 514b82f commit 2a607fe
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 1 deletion.
2 changes: 2 additions & 0 deletions lib/properties.js
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,8 @@ module.exports = function (settingsDir) {
properties_default.db.dialect = process.env.DBDIALECT || properties_default.db.dialect
properties_default.db.dir = process.env.DBDIR || properties_default.db.dir
properties_default.db.debug = (process.env.DBDEBUG === 'true') || (properties_default.db.debug === 'true')
properties_default.db.minConnections = process.env.DBMINCONNECTIONS || properties_default.db.minConnections
properties_default.db.maxConnections = process.env.DBMAXCONNECTIONS || properties_default.db.maxConnections
}
if (properties_default.redis) {
properties_default.redis.host = process.env.REDISHOST || properties_default.redis.host
Expand Down
8 changes: 7 additions & 1 deletion lib/sqldb.js
Original file line number Diff line number Diff line change
Expand Up @@ -13,9 +13,15 @@ module.exports = function (settings) {
host: settings.host,
port: settings.port,
logging: settings.debug && console.log,
pool: {minConnections: 10, maxConnections: 15}
}

var minConnections = parseInt(settings.minConnections || settings.maxConnections || '0', 10)
var maxConnections = parseInt(settings.maxConnections || settings.minConnections || '0', 10)
var pool = (minConnections || maxConnections) && {minConnections: minConnections, maxConnections: maxConnections}
if (pool) options.pool = pool

console.log('options.pool =', options.pool)

var sequelize = new Sequelize(settings.name, settings.user, settings.pass, options)
var db = {}
db.sequelize = sequelize
Expand Down

0 comments on commit 2a607fe

Please sign in to comment.