diff --git a/lib/connectionHandler.js b/lib/connectionHandler.js index 8ae4a45..f421848 100644 --- a/lib/connectionHandler.js +++ b/lib/connectionHandler.js @@ -30,7 +30,9 @@ const connectionHandler = async (connection) => { if ((typeof connection === 'object') && (!(connection instanceof Connection) && !(connection instanceof Pool))) { debug('creating connection from object:', connection); - if (connection.isPool) { + if (connection.config) { + connection = mysql.createConnection(connection.config); + } else if (connection.isPool) { connection = mysql.createPool(connection); } else { connection = mysql.createConnection(connection);