Express连接MongoDB：回调外无法获取查询结果求助

这是Node.js异步编程的典型问题——你遇到的undefined是因为异步回调函数的执行时机晚于外部同步代码。

具体来说：

• MongoClient.connect()和collection.find().toArray()都是异步操作，它们的回调函数会等到数据库操作完成后才执行。
• 当你执行到console.log(myIncomingData)时，回调里的myIncomingData = result还根本没跑过，所以这个变量还是初始的undefined。
• 另外你的代码还有个隐藏问题：db.close()放在了toArray()的回调外面，这会导致数据库连接在查询结果返回前就被关闭，可能直接导致查询失败。

方案1：调整回调嵌套顺序（传统方式） #

把db.close()和响应客户端的逻辑都放到toArray()的回调内部，确保在查询完成后再执行这些操作：

const MongoClient = require('mongodb').MongoClient; 
const express = require('express'); 
const assert = require('assert'); 
const app = express(); 
const PORT = process.env.PORT||13000; 

app.get('/',(req,res) => { 
  const url = 'mongodb://localhost:27017/'; 
  MongoClient.connect(url,{useNewUrlParser:true},(err,db)=>{ 
    assert.equal(err,null); 
    db.db('my_posts').collection('posts').find().toArray((err,result) =>{ 
      assert.equal(err,null); 
      console.log(result); // 这里正常打印结果
      // 在这里处理结果，比如返回给客户端
      res.send(result);
      // 查询完成后再关闭连接
      db.close(); 
    }); 
  }); 
}) 

app.listen(PORT,()=>console.log('server is running ...'))

方案2：使用Async/Await（更简洁的现代方式） #

Express路由支持异步函数，我们可以把异步操作转换成Promise风格，用await等待结果，代码可读性会高很多：

const MongoClient = require('mongodb').MongoClient; 
const express = require('express'); 
const assert = require('assert'); 
const app = express(); 
const PORT = process.env.PORT||13000; 

// 把路由处理函数改成async函数
app.get('/', async (req,res) => { 
  const url = 'mongodb://localhost:27017/'; 
  try {
    // 等待连接成功
    const client = await MongoClient.connect(url,{useNewUrlParser:true});
    const db = client.db('my_posts');
    // 等待查询结果
    const result = await db.collection('posts').find().toArray();
    console.log(result);
    res.send(result);
    // 关闭连接
    client.close();
  } catch(err) {
    // 捕获错误
    assert.equal(err,null);
    res.status(500).send('数据库查询失败');
  }
}) 

app.listen(PORT,()=>console.log('server is running ...'))

• Node.js中I/O操作（比如数据库请求、文件读写）都是异步的，不会阻塞主线程，所以回调函数会在操作完成后才执行。
• 如果你想在异步操作完成后使用结果，必须把逻辑写在回调内部，或者用Promise+async/await的方式同步化异步代码。

内容的提问来源于stack exchange，提问作者zero.one