Using promise-funnel with a database

WithDatabase.js

import mysql from 'mysql'
import createFunnel from 'promise-funnel'
 
const funnel = createFunnel()
funnel.cork()
 
const connection = mysql.createConnection({
    /* options here */
})
 
connection.connect(function () {
    /**
     * At this point query will begin to be invoked immediately
     * And any queries that were queued up while waiting will be
     * invoked.
     */
    funnel.uncork()
})
 
/**
 * Immediately export and allow use of 
 * A "query" function without having to 
 * worry about it being invoked before the connection
 */
export default funnel.wrap(function query (queryString) {
  return new Promise((resolve, reject) => {
    connection.query(queryString, function (error, results) {
      if (error) return reject(error)
      return resolve(results)
    })
  })
})