使用MongoClient替代Mongoose，无法解决作用域问题以导出回调函数

我完全懂你的困扰——不想为了 schema 验证额外引入 Mongoose 增加项目复杂度，但用原生 MongoClient 时，总被mongo.connect()的回调作用域绑住，没法把请求处理函数（比如你的newReading和myDashboard）正常导出，直接把exports放回调里还会报错。其实核心问题是MongoDB连接是异步操作，你需要先确保数据库连接完成，再让外部函数能访问到数据库实例。

下面给你两种简洁的解决方案，都能让你摆脱作用域限制：

方案一：用单例Promise封装数据库连接 #

这种方法会先预建立数据库连接，并且只连接一次（单例模式），之后所有请求处理函数都可以通过异步方式获取已连接的数据库实例。

第一步：创建单独的数据库连接文件（比如db.js） #

const { MongoClient } = require('mongodb');
const MONGODB_URI = 'mongodb://localhost:27017/your-db-name'; // 替换成你的连接串
let dbInstance;

// 封装连接逻辑为异步函数
async function getDB() {
  // 如果已经有连接实例，直接返回，避免重复连接
  if (dbInstance) {
    return dbInstance;
  }
  try {
    const client = await MongoClient.connect(MONGODB_URI);
    dbInstance = client.db(); // 这里可以指定数据库名，或者从连接串里取
    console.log('✅ MongoDB连接成功');
    return dbInstance;
  } catch (err) {
    console.error('❌ MongoDB连接失败:', err);
    throw err; // 抛出错误，让调用方处理
  }
}

module.exports = getDB;

第二步：在请求处理模块中使用 #

现在你可以把newReading和myDashboard完全移出连接作用域，正常导出：

const getDB = require('./db');

// 处理POST请求的newReading函数
exports.newReading = async (req, res) => {
  try {
    const db = await getDB(); // 异步获取数据库实例
    await db.collection('readings').insertOne(req.body);
    res.status(201).send({ message: '读数已成功添加' });
  } catch (err) {
    res.status(500).send({ error: err.message });
  }
};

// 处理GET请求的myDashboard函数
exports.myDashboard = async (req, res) => {
  try {
    const db = await getDB();
    const readings = await db.collection('readings').find({}).toArray();
    res.status(200).send(readings);
  } catch (err) {
    res.status(500).send({ error: err.message });
  }
};

方案二：提前初始化连接，启动服务器前确保连接完成 #

如果你的项目是Express这类Web框架，还可以在启动服务器前先完成数据库连接，之后把db实例挂载到全局或者Express的app对象上：

const express = require('express');
const { MongoClient } = require('mongodb');
const app = express();
const PORT = 3000;
const MONGODB_URI = 'mongodb://localhost:27017/your-db-name';

// 启动服务器前先连接数据库
async function startServer() {
  try {
    const client = await MongoClient.connect(MONGODB_URI);
    const db = client.db();
    // 把db实例挂载到app上，后续路由里可以直接通过req.app.get('db')获取
    app.set('db', db);
    
    app.use(express.json());
    // 导入路由（路由里可以直接使用app上的db实例）
    app.use('/api', require('./routes'));
    
    app.listen(PORT, () => {
      console.log(`服务器运行在http://localhost:${PORT}`);
    });
  } catch (err) {
    console.error('启动失败:', err);
    process.exit(1);
  }
}

startServer();

然后在路由文件routes.js里：

const router = require('express').Router();

router.post('/readings', async (req, res) => {
  const db = req.app.get('db');
  await db.collection('readings').insertOne(req.body);
  res.status(201).send({ message: '添加成功' });
});

router.get('/dashboard', async (req, res) => {
  const db = req.app.get('db');
  const data = await db.collection('readings').find({}).toArray();
  res.status(200).send(data);
});

module.exports = router;

为什么之前直接把exports放connect回调里会报错？ #

因为MongoClient.connect()是异步的，当Node.js加载你的模块时，exports的函数可能还没被赋值（此时回调还没执行），外部调用这些函数时会得到undefined，自然会报错。而上面的两种方案都确保了在函数执行时，数据库实例已经准备好，从根源上解决了作用域和异步的问题。

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