如何等待MySQL异步查询及操作完成后再执行后续逻辑？

嘿，这个问题我太懂了——回调金字塔（也就是大家常说的“回调地狱”）不仅难维护，重复代码更是让人头疼！异步MySQL查询的核心痛点就是要让后续逻辑等待异步操作完成再执行，而解决这个问题的最优方案就是用Promise封装异步操作 + async/await语法，让代码看起来像同步逻辑一样清晰。

先假设你现在可能有这样的“无法正常运行”的示例代码（典型的回调嵌套问题）：

// 用传统回调式的MySQL库
const mysql = require('mysql');
const connection = mysql.createConnection({ /* 数据库配置 */ });

function processUserData() {
  // 第一个查询：获取用户信息
  connection.query('SELECT * FROM users WHERE id = ?', [1], (err, userResults) => {
    if (err) throw err;
    const user = userResults[0];

    // 第二个查询：依赖用户ID获取订单
    connection.query('SELECT * FROM orders WHERE user_id = ?', [user.id], (err, orderResults) => {
      if (err) throw err;
      console.log('用户订单:', orderResults);

      // 再往下嵌套更多操作，代码就成金字塔了...
    });
  });
}

processUserData();
// 这里的代码会直接执行，完全不等上面的查询完成
console.log('这行代码会先打印出来！');

下面我就把这段代码改成能正常等待异步操作完成的版本，同时彻底解决回调嵌套问题：

第一步：改用支持Promise的MySQL客户端 #

首先换掉传统的回调式MySQL库，用mysql2/promise（mysql2的Promise版本），它会把所有数据库查询都包装成Promise，完美适配async/await。

第二步：用async/await让异步逻辑“线性化” #

把所有需要按顺序执行的逻辑放在async函数里，用await关键字等待每个异步查询完成，再执行后续代码：

const mysql = require('mysql2/promise');

// 主逻辑函数，用async标记
async function processUserData() {
  // 1. 创建数据库连接（生产环境更推荐用连接池，后面会说）
  const connection = await mysql.createConnection({
    host: 'localhost',
    user: '你的用户名',
    password: '你的密码',
    database: '你的数据库名'
  });

  try {
    // 2. 等待第一个查询完成，再拿到结果
    const [userResults] = await connection.query('SELECT * FROM users WHERE id = ?', [1]);
    const user = userResults[0];
    console.log('获取到用户:', user);

    // 3. 依赖第一个查询的结果，等待第二个查询完成
    const [orderResults] = await connection.query('SELECT * FROM orders WHERE user_id = ?', [user.id]);
    console.log('用户的订单:', orderResults);

    // 4. 这里写所有后续逻辑，都会严格等待前面的异步操作完成
    console.log('所有数据库操作都搞定了，现在放心执行后续逻辑！');

  } catch (err) {
    // 统一捕获所有异步操作的错误，不用每个查询单独写错误处理
    console.error('数据库操作出错:', err);
  } finally {
    // 不管成功失败，最后都关闭连接
    await connection.end();
  }
}

// 执行主函数
processUserData();

// 这里的代码还是会先执行，但主函数内部的逻辑是按顺序等待的
console.log('主函数已启动，内部会按异步顺序逐步执行');

进阶优化：代码复用与连接池 #

如果有重复的数据库操作，还可以把它们封装成单独的async函数，避免代码重复：

// 封装复用的查询函数
async function getUserById(connection, userId) {
  const [results] = await connection.query('SELECT * FROM users WHERE id = ?', [userId]);
  return results[0];
}

async function getOrdersByUserId(connection, userId) {
  const [results] = await connection.query('SELECT * FROM orders WHERE user_id = ?', [userId]);
  return results;
}

// 主函数里直接调用复用函数
async function processUserData() {
  const connection = await mysql.createConnection({ /* 配置 */ });
  try {
    const user = await getUserById(connection, 1);
    const orders = await getOrdersByUserId(connection, user.id);
    // 后续逻辑...
  } catch (err) { /* 错误处理 */ }
}

另外，生产环境强烈推荐用连接池代替单个连接，更高效稳定：

// 创建连接池
const pool = mysql.createPool({
  host: 'localhost',
  user: '你的用户名',
  password: '你的密码',
  database: '你的数据库名',
  connectionLimit: 10, // 最大连接数
  queueLimit: 0
});

// 使用连接池执行查询
async function processUserData() {
  const [userResults] = await pool.query('SELECT * FROM users WHERE id = ?', [1]);
  // ...后续操作
}

内容的提问来源于stack exchange，提问作者TheE