回调函数内部赋值后外部无法获取该值，MongoDB查询代码问题求助

• 异步执行顺序错误：MongoClient.connect 以及后续的数据库查询都是异步回调执行逻辑，函数会优先执行末尾的 return WelcomedCount 语句，此时回调内的赋值操作还未触发，因此返回值永远是初始值0。
• 遍历逻辑不符合需求：当前使用 forEach 遍历所有匹配的文档，每次遍历都会覆盖 WelcomedCount 的值，最终只能拿到最后一个匹配文档的 UsersWelcomed 字段值，和函数名指向的计数需求不符。
• 错误处理不完善：数据库连接异常、查询异常仅做了简单打印甚至无处理，出现问题时无法快速定位，也不会中断异常流程。

推荐使用async/await语法改写异步逻辑，避免回调嵌套导致的执行顺序问题，以下是示例实现：

场景1：统计包含UsersWelcomed字段的文档总数 #

module.exports.ReqForWelcomedCount = async function ReqForWelcomedCount() {
  let client = null;
  try {
    // 等待数据库连接完成
    client = await MongoClient.connect(uri);
    const collection = client.db("agiobot").collection("data");
    // 直接调用计数方法统计符合条件的文档数量
    return await collection.countDocuments({
      UsersWelcomed: { $exists: true }
    });
  } catch (err) {
    console.error("数据库操作错误：", err);
    return 0;
  } finally {
    // 无论是否出现异常，都关闭数据库连接
    if (client) await client.close();
  }
}

场景2：累加所有文档的UsersWelcomed字段值 #

如果需要统计所有UsersWelcomed的数值总和，将查询部分替换为聚合逻辑即可：

const aggregateRes = await collection.aggregate([
  { $match: { UsersWelcomed: { $exists: true } } },
  { $group: { _id: null, total: { $sum: "$UsersWelcomed" } } }
]).toArray();
return aggregateRes[0]?.total || 0;

调用说明 #

因为函数已经改写为异步函数，调用时需要使用await或者then方法获取返回值：

// 调用示例
const count = await ReqForWelcomedCount();
// 或者
ReqForWelcomedCount().then(count => console.log(count));

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