用mysql实现多个循环的Node.js查询

在Node.js中使用MySQL实现多个循环查询，通常涉及到异步操作和数据库连接管理。以下是一个基本的示例，展示了如何使用mysql模块来实现这一点。

基础概念

异步编程：Node.js采用异步非阻塞I/O模型，适合处理高并发的网络请求。
回调函数：用于处理异步操作完成后的逻辑。
Promise：一种更现代的处理异步操作的方式，可以避免回调地狱。
async/await：基于Promise的语法糖，使异步代码看起来更像同步代码。

类型与应用场景

串行查询：一个查询完成后才开始下一个查询。
并行查询：多个查询同时发起，不等待前一个查询完成。

应用场景包括但不限于：

数据库初始化填充。
批量数据处理。
复杂的业务逻辑处理。

示例代码

以下是一个使用async/await实现串行查询的示例：

const mysql = require('mysql');

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

connection.connect();

// 定义一个异步函数来执行多个查询
async function runQueries() {
  try {
    // 第一个查询
    const [results1] = await new Promise((resolve, reject) => {
      connection.query('SELECT * FROM table1', (error, results) => {
        if (error) reject(error);
        else resolve(results);
      });
    });

    console.log('Results from table1:', results1);

    // 第二个查询
    const [results2] = await new Promise((resolve, reject) => {
      connection.query('SELECT * FROM table2 WHERE id IN (?)', [results1.map(row => row.id)], (error, results) => {
        if (error) reject(error);
        else resolve(results);
      });
    });

    console.log('Results from table2:', results2);

    // 更多查询...

  } catch (error) {
    console.error('Error executing queries:', error);
  } finally {
    // 关闭数据库连接
    connection.end();
  }
}

// 调用函数
runQueries();