diff --git a/lib/mysql.js b/lib/mysql.js index 91b7437..87831b1 100644 --- a/lib/mysql.js +++ b/lib/mysql.js @@ -32,6 +32,12 @@ exports.initialize = function initializeSchema(schema, callback) { charset: s.collation.toUpperCase(), // Correct by docs despite seeming odd. supportBigNumbers: s.supportBigNumbers }); + + if (s.keepAlive) { + setInterval(function() { + schema.client.query('select 1'); + }, s.keepAlive); + } schema.client.on('error', function (err) { schema.emit('error', err);