Node.js数据库连接函数未返回预期对象，CRUD函数调用报错

你遇到的这个问题核心在于异步代码的执行顺序，咱们一步步拆解原因和修复方案：

为什么getDbConnection()返回undefined？ #

MongoClient.connect()是异步函数——它不会立刻返回数据库连接，而是要等网络请求完成后，通过回调函数返回结果。但你写的getDbConnection()里，return db是写在connect的回调内部的，这个返回值根本不会被getDbConnection()本身返回。

当你执行var dbo = getDbConnection()时，getDbConnection()会先触发MongoClient.connect()，然后立刻结束函数执行（因为函数顶层没有return语句），所以默认返回undefined——这就是CreatePost()里的dbo是undefined、调用dbo.db()报错的原因。

修复方案：用async/await处理异步逻辑 #

现在Node.js里处理异步代码最清晰的方式是async/await，咱们重构你的代码：

1. 重构数据库连接函数 #

改成返回Promise的async函数，确保能等待连接建立完成：

async function getDbConnection() {
  try {
    // await会等待connect的异步操作完成，拿到db对象
    const db = await MongoClient.connect(url);
    return db;
  } catch (err) {
    console.error('数据库连接失败:', err);
    throw err; // 抛出错误让调用者处理
  }
}

2. 重构插入函数，避免异步混乱 #

原来的循环里直接调用insertOne会导致异步操作无序执行，而且每次插入就关闭连接的做法也不对——第一个插入完成就关连接，后面的插入会直接失败。我们把所有插入操作的Promise收集起来，等待全部完成后再关闭连接：

async function CreatePost(dbo) {
  console.log(typeof dbo);
  const mydbo = dbo.db("fb");
  const insertTasks = [];

  for(let i=0;i<25;i++) {
    // 用let声明postData，避免全局变量污染
    const postData = { 
      pstID: ""+i, 
      pstTitle: "Highway 37",
      pstTime: "100",
      pstdBy: "100",
      pstCntnt: "100"
    };
    // 把每个insertOne的Promise加入数组
    insertTasks.push(mydbo.collection("mypost").insertOne(postData));
  }

  // 等待所有插入操作完成
  await Promise.all(insertTasks);
  console.log("25 documents inserted successfully");
  // 所有操作完成后再关闭连接
  dbo.close();
}

3. 正确调用异步函数 #

因为getDbConnection和CreatePost都是异步函数，需要用async函数包裹调用逻辑：

async function runApp() {
  try {
    // 等待数据库连接建立完成
    const dbo = await getDbConnection();
    // 等待插入操作完成
    await CreatePost(dbo);
  } catch (err) {
    console.error('操作出错:', err);
  }
}

// 启动程序
runApp();

额外注意点 #

• 原来的代码里postData没有用let/var/const声明，会变成全局变量，在循环里容易出问题，一定要加上声明。
• 不要在单个插入的回调里关闭连接，必须等所有数据库操作完成后再关闭，否则会导致后续操作失败。

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