如何先执行SQL查询再运行后续代码？解决循环提前执行问题

这个问题我太熟了——本质是踩了Node.js异步回调的坑！你写的mysqlModule.queryDB是异步执行的，它不会等着数据库返回结果再继续跑代码，而是直接往下走，所以你的listFunc函数会在查询还没完成的时候就结束了。不过其实你写的for循环是在回调函数里的，理论上它会在查询完成后才执行，但问题在于你试图从回调里return funclist，这根本没法把结果返回给调用listFunc的地方，而且可能你误以为循环提前跑了，实际是函数提前返回了空值。

要解决这个问题，我们可以用Promise + async/await来把异步代码“变同步”，确保循环（或者更简洁的数组映射）只在查询完成后执行：

步骤1：把数据库查询封装成Promise #

先把回调式的查询改成Promise风格，这样就能用await来等待结果：

function queryDBPromise(database, query) {
  return new Promise((resolve, reject) => {
    mysqlModule.queryDB(database, query, (err, result) => {
      if (err) reject(err);
      else resolve(result);
    });
  });
}

步骤2：改造listFunc为async函数 #

用async/await来等待查询完成，之后再处理结果：

static async listFunc() {
  try {
    const queryList = "SELECT * FROM func";
    // 这里会等待数据库查询完成才继续执行
    const result = await queryDBPromise(database, queryList);
    
    // 用map代替for循环，更简洁高效
    const funclist = result.map(item => ({
      id: item.id,
      psw: item.senha,
      nome: item.nome,
      DoB: item.dataNascimento,
      sexo: item.genero,
      morada: item.morada,
      permissoes: item.permissoes
    }));
    
    return funclist;
  } catch (err) {
    // 不要在static函数里直接操作res，把错误抛出去让调用者处理
    throw new Error("Internal server error");
  }
}

调用方式 #

在你的路由处理函数里这样调用：

// 假设这是Express的路由
app.get('/func', async (req, res) => {
  try {
    const funcList = await YourClass.listFunc();
    res.status(200).json(funcList);
  } catch (err) {
    res.status(500).json({
      "status_code": 500,
      "status_message": err.message
    });
  }
});

如果你不想用async/await #

也可以让listFunc直接返回Promise，用.then()链式调用：

static listFunc() {
  return new Promise((resolve, reject) => {
    const queryList = "SELECT * FROM func";
    mysqlModule.queryDB(database, queryList, (err, result) => {
      if (err) {
        reject(new Error("Internal server error"));
      } else {
        const funclist = result.map(item => ({
          id: item.id,
          psw: item.senha,
          nome: item.nome,
          DoB: item.dataNascimento,
          sexo: item.genero,
          morada: item.morada,
          permissoes: item.permissoes
        }));
        resolve(funclist);
      }
    });
  });
}

// 调用
YourClass.listFunc()
  .then(funcList => res.status(200).json(funcList))
  .catch(err => res.status(500).json({
    "status_code": 500,
    "status_message": err.message
  }));

几个关键注意点：

• 不要在static函数里直接操作res对象，这会让函数耦合性太高，应该把结果或错误返回给调用者处理。
• 用Array.map代替手动for循环，代码更简洁也更易维护。
• 异步操作一定要用Promise或者async/await来控制执行顺序，否则永远会出现“代码跑早了”的问题。

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