Torch everything

query-function.js

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) {
        // Torch the connection
        connection.destroy();
        return reject(err);
      }
      resolve(resp);
    });
  });
}