Node.js中MySQL查询结果正确但函数无法正常返回问题求助

你遇到的问题本质是Node.js中MySQL驱动的异步非阻塞特性：con.query是异步方法，它会立刻返回，而数据库查询的结果要等IO操作完成后才会通过回调函数返回。外层函数会在con.query调用后直接执行结束，根本等不到回调函数里的结果，所以外层函数无法拿到回调中的返回值。

比如你的checkIfUserExists函数，它没有任何return语句，默认返回undefined，你看到的"始终返回false"其实是undefined在布尔判断中被当成了false。第二个例子里，外层函数同样会在con.query执行前就返回，自然拿不到result[0].UserID。

下面是两种常用的解决方式，推荐优先使用第二种（Promise+async/await），代码更易读、更易维护。

1. 使用回调函数传递结果 #

修改外层函数，让它接受一个回调参数，把查询结果或错误通过回调传递出去：

function checkIfUserExists(username, callback) {
  con.query("SELECT * FROM UserTable WHERE username = ?", username, function (err, result) {
    if (err) return callback(err); // 将错误传递给回调
    // 将查询结果的判断值传递给回调
    callback(null, result.length > 0);
  });
}

// 调用示例
checkIfUserExists("test_user", function(err, isExists) {
  if (err) {
    console.error("查询出错：", err);
    return;
  }
  console.log("用户是否存在：", isExists);
});

获取用户ID的场景同理：

function getUserID(sql, callback) {
  con.query(sql, function (err, result) {
    if (err) return callback(err);
    callback(null, result[0].UserID);
  });
}

// 调用示例
getUserID("SELECT UserID FROM UserTable WHERE username = 'test_user'", function(err, userId) {
  if (err) {
    console.error("查询出错：", err);
    return;
  }
  console.log("用户ID：", userId);
});

2. 使用Promise + async/await（推荐） #

将异步的con.query封装成Promise，再用async/await语法让代码看起来像同步逻辑，这是当前Node.js处理异步的标准方式。

方式一：手动封装Promise #

// 封装query为Promise
function queryPromise(sql, params) {
  return new Promise((resolve, reject) => {
    con.query(sql, params, function(err, result) {
      if (err) reject(err);
      else resolve(result);
    });
  });
}

// 用async/await改写业务函数
async function checkIfUserExists(username) {
  const result = await queryPromise("SELECT * FROM UserTable WHERE username = ?", username);
  return result.length > 0;
}

async function getUserID(sql) {
  const result = await queryPromise(sql);
  return result[0].UserID;
}

// 调用示例（必须在async函数内或用.then处理）
async function main() {
  try {
    const isExists = await checkIfUserExists("test_user");
    console.log("用户是否存在：", isExists);

    const userId = await getUserID("SELECT UserID FROM UserTable WHERE username = 'test_user'");
    console.log("用户ID：", userId);
  } catch (err) {
    console.error("操作出错：", err);
  }
}

main();

方式二：使用mysql2的Promise版本 #

直接使用mysql2/promise库，它原生支持Promise，无需手动封装：

# 先安装mysql2
npm install mysql2

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

// 建立连接（推荐用连接池，避免频繁创建连接）
async function getDBConnection() {
  const connection = await mysql.createConnection({
    host: 'localhost',
    user: '你的数据库用户名',
    password: '你的数据库密码',
    database: '你的数据库名'
  });
  return connection;
}

async function checkIfUserExists(username) {
  const connection = await getDBConnection();
  // execute方法返回[结果集, 字段信息]，解构获取结果集
  const [rows] = await connection.execute("SELECT * FROM UserTable WHERE username = ?", [username]);
  await connection.end();
  return rows.length > 0;
}

async function getUserID(username) {
  const connection = await getDBConnection();
  const [rows] = await connection.execute("SELECT UserID FROM UserTable WHERE username = ?", [username]);
  await connection.end();
  return rows[0].UserID;
}

// 调用示例
async function main() {
  try {
    const isExists = await checkIfUserExists("test_user");
    console.log("用户是否存在：", isExists);

    const userId = await getUserID("test_user");
    console.log("用户ID：", userId);
  } catch (err) {
    console.error("操作出错：", err);
  }
}

main();

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