Node.js异步调用MySQL数据库：async函数返回undefined的原因排查

你的问题出在两个核心点上——混用了回调函数和async/await，以及回调内的return无法传递到外层异步函数，导致userHandler没有返回预期的值。

问题原因拆解 #

1. await没有真正等待查询完成
   你使用的mysql库中，当给connection.query传入回调函数时，它不会返回Promise，而是直接执行并通过回调返回结果。这意味着你写的await connection.query(...)根本不会等待查询结束，userHandler会直接执行到函数末尾，没有任何返回值，所以调用时得到undefined。

2. 回调内的return无法传递到外层
   就算await生效了，回调函数里的return result[0].user_id也只是从回调函数本身返回，不会让外层的userHandler返回这个值——这两个函数的作用域是完全独立的。

另外还有个小问题：你用result != 0判断用户是否存在是错误的，因为query返回的结果是数组，空数组和0比较时[] != 0会返回true，这会导致逻辑判断失效，应该用result.length > 0来检查是否有查询结果。

修复方案：改用Promise风格的查询 #

要解决这个问题，我们需要把connection.query转换成支持Promise的形式，这样才能和async/await配合使用。有两种常见方式：

方式1：用util.promisify包装查询方法

Node.js内置的util模块可以把回调风格的函数转换成Promise风格：

const util = require('util');

async function userHandler(username, displayName, profilePicture, email) {
  const connection = await connectDB();
  // 将query方法promisify，让它返回Promise
  connection.query = util.promisify(connection.query);

  // 切换数据库（也可以在connectDB时指定database参数）
  await connection.query('USE spyncdb;');
  
  // 用await直接获取查询结果
  const userResult = await connection.query('SELECT * FROM users WHERE username = ?', [username]);

  if (userResult.length > 0) {
    console.log('User already in database');
    return userResult[0].user_id;
  } else {
    // 插入用户，同样用await获取结果
    const insertResult = await connection.query(
      'INSERT INTO users (username, displayname, profilePicture, email) VALUES (?, ?, ?, ?)', 
      [username, displayName, profilePicture, email]
    );
    console.log('user inserted into db');
    // 返回插入后的用户ID（mysql库中insertResult.insertId就是自增ID）
    return insertResult.insertId;
  }
}

方式2：改用mysql2/promise库

mysql2是mysql库的升级版，原生支持Promise，使用起来更方便：
首先安装依赖：

npm install mysql2

然后修改代码：

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

// 假设connectDB改成返回Promise风格的连接
async function connectDB() {
  return mysql.createConnection({
    host: 'your-host',
    user: 'your-user',
    password: 'your-password',
    database: 'spyncdb' // 这里直接指定数据库，就不用再执行USE语句了
  });
}

async function userHandler(username, displayName, profilePicture, email) {
  const connection = await connectDB();
  
  const [userResult] = await connection.query('SELECT * FROM users WHERE username = ?', [username]);

  if (userResult.length > 0) {
    console.log('User already in database');
    return userResult[0].user_id;
  } else {
    const [insertResult] = await connection.query(
      'INSERT INTO users (username, displayname, profilePicture, email) VALUES (?, ?, ?, ?)', 
      [username, displayName, profilePicture, email]
    );
    console.log('user inserted into db');
    return insertResult.insertId;
  }
}

调用部分的注意事项 #

你的自执行异步函数写法是对的，但要确保它被实际执行（比如不要只定义不调用）：

(async () => {
  // 假设aUser是已定义的用户对象
  let user_id = await userHandler(aUser.username, aUser.displayName, aUser.profilePicture, aUser.email);
  console.log(user_id); // 现在会正确输出用户ID
})();

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