NodeJS/Express/Mongodb报错：Cannot read property 'collection' of undefined

看起来你这个可复用连接模块的思路没问题，但实际使用中大概率碰到了连接未就绪就调用getDb或者MongoDB驱动版本不兼容的问题，我帮你一步步排查和修正：

一、最常见的坑：异步调用顺序错误 #

你的connectToServer是异步方法，如果在它的回调执行完成前就调用getDb，拿到的_db会是undefined，后续操作自然会报错。

正确的使用姿势 #

必须确保connectToServer执行完成后，再进行数据库操作：

// 比如在你的入口文件（app.js）里
const dbConnection = require('./server/config/db-connection');

dbConnection.connectToServer((err) => {
  if (err) {
    console.error('MongoDB连接失败:', err);
    process.exit(1);
  }
  // 连接成功后再启动服务或者执行数据库操作
  app.listen(3000, () => {
    console.log('服务启动，MongoDB已连接');
  });
});

// 之后在其他模块里调用getDb
const db = dbConnection.getDb();
// 比如查询操作
db.collection('articles').find({}).toArray((err, docs) => {
  // 处理结果
});

二、MongoDB驱动版本兼容问题（v4+版本） #

现在大部分项目用的是MongoDB驱动v4及以上版本，这个版本的MongoClient.connect返回的是**client对象**，而不是直接的db实例，你的代码是旧版本（v3及以下）的写法，这会导致_db其实是client，后续调用db.collection()会报错。

修正后的连接模块代码 #

更新server/config/db-connection.js适配新版本驱动：

const { MongoClient } = require('mongodb');
let _db;

module.exports = {
  connectToServer: async function(callback) {
    try {
      // 连接数据库，注意新版驱动的写法
      const client = await MongoClient.connect("mongodb://localhost:27017");
      // 指定要使用的数据库
      _db = client.db('articles');
      console.log('MongoDB连接成功');
      return callback(null);
    } catch (err) {
      console.error('MongoDB连接失败:', err);
      return callback(err);
    }
  },
  getDb: function() {
    if (!_db) {
      throw new Error('请先调用connectToServer建立数据库连接');
    }
    return _db;
  }
};

这里做了几个优化：

• 改用async/await让异步代码更易读
• 增加了getDb时的判断，如果未连接直接抛出明确错误，方便排查
• 适配新版驱动的client.db()获取数据库实例

三、额外的健壮性优化 #

• 可以把数据库连接字符串放到环境变量里，不要硬编码，比如用process.env.MONGODB_URI
• 增加重连机制，如果连接断开可以自动重试
• 可以添加连接状态的检查方法

带重连机制的进阶版本（可选） #

const { MongoClient } = require('mongodb');
let _db;
let _client;
const uri = process.env.MONGODB_URI || "mongodb://localhost:27017";
const dbName = 'articles';

async function connect() {
  try {
    _client = await MongoClient.connect(uri, {
      retryWrites: true,
      w: 'majority',
      // 自动重连配置
      autoReconnect: true,
      reconnectTries: Number.MAX_VALUE,
      reconnectInterval: 1000
    });
    _db = _client.db(dbName);
    console.log('MongoDB连接成功');
    // 监听连接断开事件
    _client.on('close', () => {
      console.warn('MongoDB连接断开，正在尝试重连...');
      connect();
    });
  } catch (err) {
    console.error('MongoDB连接失败，5秒后重试:', err);
    setTimeout(connect, 5000);
  }
}

module.exports = {
  init: function(callback) {
    connect().then(() => callback(null)).catch(err => callback(err));
  },
  getDb: function() {
    if (!_db) {
      throw new Error('请先调用init方法初始化数据库连接');
    }
    return _db;
  },
  close: function() {
    if (_client) {
      _client.close();
    }
  }
};

最后再检查几个点 #

• 确保MongoDB服务已经在本地localhost:27017启动
• 确认articles数据库已经存在（如果不存在，MongoDB会在第一次写入时自动创建，但读取前最好先创建）
• 检查驱动版本，执行npm list mongodb看版本，如果是v4+就用上面的新版代码，v3及以下可以用你原来的代码但要注意异步顺序

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