节点JS等待一系列mysql查询

const mysql = require('mysql');

// 创建数据库连接池
const pool = mysql.createPool({
  host: 'localhost',
  user: 'username',
  password: 'password',
  database: 'database_name'
});

// 定义待查询的SQL语句数组
const queries = [
  'SELECT * FROM table1',
  'SELECT * FROM table2',
  'SELECT * FROM table3'
];

// 定义一个Promise函数，用于执行单个查询
function executeQuery(query) {
  return new Promise((resolve, reject) => {
    pool.query(query, (error, results) => {
      if (error) {
        reject(error);
      } else {
        resolve(results);
      }
    });
  });
}

// 定义一个异步函数，用于顺序执行一系列查询
async function executeQueries(queries) {
  const results = [];
  
  for (const query of queries) {
    const result = await executeQuery(query);
    results.push(result);
  }
  
  return results;
}

// 调用异步函数执行查询
executeQueries(queries)
  .then(results => {
    console.log(results);
  })
  .catch(error => {
    console.error(error);
  });