runSql.js

const runSql = (connection, sqlText) => new Promise((resolve, reject) => {
  connection.execute({
    sqlText,
    complete: (err, stmt, rows) => {
      if (err) {
        reject(err);
        return;
      }
      resolve(rows);
    }
  });
};