如何将MySQL查询回调的返回值传递至外层用户存在判断函数？

你遇到的核心问题是MySQL查询是异步操作，回调函数里的return只能作用于回调本身，外层的checkClient函数会在查询完成前就执行完毕，所以根本没法直接把回调的返回值传递出去，必须调整实现方式，以下是两种常用的可行方案：

方案一：使用回调函数作为参数传入 #

把结果处理逻辑通过回调函数的方式传入checkClient，查询完成后调用回调返回结果：

function checkClient(token, callback) {
  const connection = mysql.createConnection(db_config);
  connection.connect();
  
  // 必须用参数化查询避免SQL注入！不要直接拼接token
  connection.query('SELECT * FROM users WHERE usid = ?', [token], (err, result) => {
    connection.end(); // 查询完成后关闭连接
    if (err) {
      return callback(err, null); // 把错误传递给回调
    }
    // 判断用户是否存在
    const userExists = Object.keys(result).length !== 0;
    callback(null, userExists);
  });
}

// 调用示例
checkClient(userid, (err, exists) => {
  if (err) {
    console.error('查询用户失败:', err);
    return;
  }
  const usercheck = exists; // 这里拿到结果
  // 执行后续业务逻辑
});

方案二：用Promise封装，支持async/await #

如果习惯用同步风格的代码，可以用Promise封装异步查询，配合async/await使用：

function checkClient(token) {
  return new Promise((resolve, reject) => {
    const connection = mysql.createConnection(db_config);
    connection.connect();
    
    connection.query('SELECT * FROM users WHERE usid = ?', [token], (err, result) => {
      connection.end();
      if (err) {
        return reject(err); // 抛出错误
      }
      const userExists = Object.keys(result).length !== 0;
      resolve(userExists); // 返回结果
    });
  });
}

// 调用示例（必须在async函数内使用await）
async function handleUserCheck() {
  try {
    const usercheck = await checkClient(userid);
    // 拿到结果后执行后续逻辑
  } catch (err) {
    console.error('查询用户失败:', err);
  }
}

// 调用这个async函数
handleUserCheck();

重要提醒 #

1. 永远不要直接拼接SQL语句：原代码里直接把token拼进SQL，存在严重的SQL注入风险，必须用参数化查询（?占位符 + 参数数组）。
2. 建议使用连接池：每次创建新连接效率很低，实际项目中推荐用mysql.createPool()来管理连接，避免频繁创建销毁连接的开销。

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