Search code examples
node.jsnode-mysql

Node.js - Using await new Promise in mysql pool connection - SyntaxError: Unexpected token new


Node.js - Using await new Promise in mysql pool connection - SyntaxError: Unexpected token new

I'm trying to use a new promise inside a pool connection ... but I'm getting this SyntaxError: Unexpected token new. What am I missing?

Error:

let rowsPromise01 = await new Promise((resolve,reject)=>{
                              ^^^
SyntaxError: Unexpected token new

js:

const pool = require('./config/dbpool');    

pool.getConnection(function(err, connection) {
  if (err) throw err;

   let rowsPromise01 = await new Promise((resolve,reject)=>{
    connection.query("SELECT * FROM table01", function(err, rows) {
        //connection.release();
        if (err) {
          console.log(err);
          reject(err);
        } else {
          console.log('Found records: '+rows.length);
          resolve(rows);       
        }
    });
   });

   let rowsPromise02 = await new Promise((resolve,reject)=>{
    connection.query(SELECT * FROM table02,function(err, results) {
      connection.release();
      if (err) {
        console.log(err);
        reject(err);
      } else {
      console.log('Found records: '+result.length);
      resolve(results);
      }
    });

    });

});

The dbpool.js looks like this:

const mysql= require('mysql');

//database connection
var pool = mysql.createPool({
  connectionLimit: 10,
  host     : 'localhost',
  user     : 'root',
  password : 'password',
  database : 'database'
});

module.exports = {
  getConnection (callback) {
    pool.getConnection((err, conn) => {
      if(err) {
        return callback(err);
      }
      callback(err, conn);
    });
  },
  query (query, params=[], cb) {
    this.getConnection((err, conn) => {
        conn.release();
        if(err) return cb(err, null);
        conn.query(query, params, (err, res) => {
            if(err) return cb(err, null);
            return cb(null, res);
        });
    });
  }
}

Solution

  • The error is a bit of a red herring, the issue is really with the await keyword, which is only valid inside functions that are marked with async, which in your case is missing.

    Fix:

    pool.getConnection(async function(err, connection) { .... });
    

    More info here: https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Statements/async_function#Description