Node.JS MySql在循环中等待预期结果

const mysql = require('mysql');

// 创建数据库连接
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'mydatabase'
});

// 连接数据库
connection.connect();

// 定义一个函数，用于执行数据库查询操作并返回Promise对象
function queryDatabase(sql) {
  return new Promise((resolve, reject) => {
    connection.query(sql, (error, results) => {
      if (error) {
        reject(error);
      } else {
        resolve(results);
      }
    });
  });
}

// 在循环中等待预期结果的示例函数
async function waitForExpectedResult() {
  try {
    // 执行数据库查询操作
    const results = await queryDatabase('SELECT * FROM mytable');

    // 处理查询结果
    for (const row of results) {
      // 在这里进行预期结果的处理
      console.log(row);
    }

    // 继续执行下一步操作
    console.log('预期结果处理完成，继续执行其他操作');
  } catch (error) {
    console.error('发生错误：', error);
  } finally {
    // 关闭数据库连接
    connection.end();
  }
}

// 调用等待预期结果的函数
waitForExpectedResult();