Node.js中MongoDB查询结果赋值变量的异步问题求解

我太懂你踩的这个异步坑了！MongoDB的所有查询操作都是异步执行的，你直接require('./test_mongodb.js')的时候，模块里的查询请求还在和数据库交互呢，根本没返回结果，所以你拿到的DOC要么是初始的undefined，要么是个没完成的Promise，自然打印不出正确内容。

先给你拆解问题根源：你的test_mongodb.js大概率是这种错误写法——直接在模块里跑异步查询，然后导出一个还没被赋值的变量：

// 错误的test_mongodb.js示例
const { MongoClient } = require('mongodb');
let doc;

// 异步查询，此时模块已经开始导出变量了
MongoClient.connect('mongodb://localhost:27017')
  .then(client => client.db('yourDB').collection('yourCollection').findOne({}))
  .then(result => doc = result)
  .catch(err => console.error(err));

module.exports = doc; // 导出时doc还是undefined！

下面给你两种最常用的正确解决方案：

方案1：用回调函数处理异步结果 #

修改test_mongodb.js，导出一个接受回调的函数，让查询完成后再把结果传给主文件：

// test_mongodb.js
const { MongoClient } = require('mongodb');

function getMongoDoc(callback) {
  MongoClient.connect('mongodb://localhost:27017')
    .then(client => {
      const db = client.db('yourDB');
      return db.collection('yourCollection').findOne({});
    })
    .then(result => {
      callback(null, result); // 成功时传递结果
      client.close(); // 记得关闭连接
    })
    .catch(err => callback(err)); // 错误时传递异常
}

module.exports = getMongoDoc;

然后在app.js里调用这个函数，在回调里拿到结果：

// app.js
const getMongoDoc = require('./test_mongodb.js');

getMongoDoc((err, DOC) => {
  if (err) {
    console.error('查询失败:', err);
    return;
  }
  console.log(typeof(DOC)); // 现在能正确打印类型了
  console.log('Works:', JSON.stringify(DOC));
});

方案2：用Promise/Async-Await（更现代推荐） #

现在Node.js更推崇用Promise处理异步，我们可以让test_mongodb.js导出一个Promise，然后在主文件里用await或者.then()获取结果：

// test_mongodb.js
const { MongoClient } = require('mongodb');

async function getMongoDoc() {
  const client = await MongoClient.connect('mongodb://localhost:27017');
  const db = client.db('yourDB');
  const doc = await db.collection('yourCollection').findOne({});
  client.close();
  return doc;
}

module.exports = getMongoDoc;

然后在app.js里用Async-Await（注意要放在async函数里）：

// app.js
const getMongoDoc = require('./test_mongodb.js');

async function main() {
  try {
    const DOC = await getMongoDoc();
    console.log(typeof(DOC));
    console.log('Works:', JSON.stringify(DOC));
  } catch (err) {
    console.error('查询出错:', err);
  }
}

main();

额外小贴士 #

• 不要在模块顶层直接用await（除非你把项目改成ES模块，在package.json里设置"type": "module"），所以一定要把异步逻辑封装成函数。
• 可以考虑复用MongoDB客户端连接，而不是每次查询都重新连接，这样能提升性能——比如在test_mongodb.js里初始化一次连接，后续查询直接复用客户端。

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