A basic wrapper for mysql connection

mysql-wrapper.js

'use strict';

module.exports.query = query;

/* --------------------- */

const mysql = require('mysql');

const connection = mysql.createConnection({
  host     : process.env.HOSTNAME,
  port     : process.env.PORT,
  user     : process.env.USERNAME,
  password : process.env.PASSWORD,
  database : process.env.DB_NAME,
  // I don't recommend having multipleStatements always set to true
  // as it leaves you more vulnerable to sql injections
  // but in order to send transactions as a block in our example
  // we will need it
  multipleStatements: true 
});

connection.connect();


function query(input) {
  const _defaults = {
    params: []
  };
  const {sql, params} = Object.assign(_defaults, input);

  return new Promise((resolve, reject) => {
    connection.query(sql, params, (err, resp) => {
      if (err) {
        return reject(err);
      }
      resolve(resp);
    });
  });
}