Node.js中如何先执行数据库查询再返回函数结果？

你碰到的是Node.js异步编程的典型问题：connection.query是非阻塞异步操作，函数不会等它执行完就继续往下跑，所以return auth执行时，auth还没被赋值，自然返回undefined，等异步查询完成进入回调时，函数早就退出了。

修复方案：用Promise+async/await处理异步逻辑 #

这是目前最易读、最主流的异步处理方式，能让异步代码看起来像同步代码一样顺序执行：

static async checkUser(email, password) {
  console.log("Check user function logged");
  console.log("Email in Par was : " + email);
  const sql = "SELECT password FROM members where email=?";
  console.log(sql);

  try {
    // 将异步查询封装为Promise，等待查询完成
    const result = await new Promise((resolve, reject) => {
      connection.query(sql, [email], (error, queryResult) => {
        if (error) {
          reject(error);
        } else {
          resolve(queryResult);
        }
      });
    });

    // 拿到查询结果后再判断auth值
    let auth = false;
    if (result.length > 0) {
      auth = result[0].password === password;
      if (auth) {
        console.log("password was Correct");
      }
    }
    return auth;
  } catch (error) {
    console.error(error.message);
    throw error; // 也可以根据需求返回false，统一错误处理
  } finally {
    // 确保查询完成后再关闭连接，避免提前断开
    connection.end();
    console.log("function scope left");
  }
}

调用注意事项 #

因为checkUser现在是异步函数，调用时必须用await或者.then()获取返回值：

// 示例调用
async function handleLogin() {
  const isAuthenticated = await YourClass.checkUser("user@example.com", "yourpassword");
  console.log("验证结果：", isAuthenticated);
}
handleLogin();

关键要点 #

1. async/await让异步代码按顺序执行，await会暂停函数，直到Promise完成
2. 把connection.end()放在finally块里，确保无论查询成功/失败，都会正确关闭连接（原代码里提前关闭连接会导致查询报错）
3. 用try/catch捕获异步操作的错误，避免程序崩溃

内容的提问来源于stack exchange，提问作者Syed Zainullah Qazi