function doQuery(query) { return pool.getConnectionAsync().then(function(connection) { return connection.queryAsync(query) .finally(function(){ connection.release(); }); }); } //don't have to worry about closing connection doQuery("SELECT * FROM table").spread(function(rows, fields){ });