循环内的Node Express js查询

const express = require('express');
const app = express();
const mysql = require('mysql');

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

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

// 定义路由
app.get('/query', async (req, res) => {
  try {
    const data = ['value1', 'value2', 'value3']; // 待查询的数据集合

    for (const value of data) {
      // 执行查询操作
      const queryResult = await queryData(value);
      console.log(queryResult);
    }

    res.send('查询完成');
  } catch (error) {
    console.error(error);
    res.status(500).send('查询失败');
  }
});

// 执行查询操作
function queryData(value) {
  return new Promise((resolve, reject) => {
    const query = `SELECT * FROM mytable WHERE column = '${value}'`;

    connection.query(query, (error, results) => {
      if (error) {
        reject(error);
      } else {
        resolve(results);
      }
    });
  });
}

// 启动服务器
app.listen(3000, () => {
  console.log('服务器已启动');
});