MongoDB插入数据无报错却失败，附代码寻求排查解决方法

核心问题分析 #

初始代码的问题

• 变量作用域错误：MongoClient.connect回调里的let db是局部变量，createbus函数里的db未定义，调用db.collection会报错但没被捕获。
• 异步操作未等待：insertOne是异步方法，直接调用后立刻执行client.close()，插入操作还没完成连接就被关闭。
• 重复创建连接：既实例化了const client = new MongoClient(...)，又调用MongoClient.connect，造成不必要的连接重复。

更新后代码的问题

• finally块过早关闭连接：client.connect是异步回调，外层finally会在回调执行前就触发client.close()，导致连接刚发起就被关闭，永远进不了checkpoint2。
• 回调错误无法被捕获：connect和insertOne的回调里的错误，外层try/catch无法捕获，因为回调是异步执行的。
• 异步操作未正确处理：即使走到insertOne，也没有等待异步完成就可能被后续操作打断。

修复后的代码（使用async/await，更易维护） #

const { MongoClient, ServerApiVersion } = require('mongodb');
const uri = "mongodb+srv://<user>:<password>@Bussar.v5r4pfd.mongodb.net/bussdb?retryWrites=true&w=majority";

// 全局复用客户端实例，不要每次调用函数都新建
const client = new MongoClient(uri, { 
  useNewUrlParser: true, 
  useUnifiedTopology: true, 
  serverApi: ServerApiVersion.v1 
});

async function createbus(data) {
  console.log("checkpoint 1");
  let db;
  try {
    // 等待连接建立完成
    await client.connect();
    console.log("checkpoint 2");
    
    db = client.db("bussdb");
    console.log("checkpoint 3");
    
    const bussar = db.collection("busscoll");
    console.log("checkpoint 4");
    
    // 等待插入操作完成，确保数据写入
    const result = await bussar.insertOne(data);
    console.log("插入成功：", result);
    console.log("checkpoint 5");
  } catch (e) {
    console.error("操作出错：", e);
  } finally {
    // 仅当连接已建立时才关闭，避免无效操作
    if (client.isConnected()) {
      await client.close();
    }
  }
}

关键修复说明 #

• 用async/await替代回调，确保异步操作按顺序执行，避免过早关闭连接。
• 复用同一个client实例，减少不必要的连接开销。
• 统一在外层try/catch捕获所有错误，方便排查问题。
• 在finally块中检查连接状态后再关闭，避免重复关闭或关闭未建立的连接。
• 等待insertOne执行完成再继续，保证数据真正写入数据库。

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