如何使用mongoose创建支持共享动态数据库连接的模块

问题根因 #

Node.js 遵循 CommonJS 模块规范，module.exports 的赋值是值拷贝行为：你在模块初始化导出对象时，Order/Item等变量还处于undefined状态，导出对象里直接存了这几个变量当时的undefined值。后续你在sendUserId里修改的是模块内部的同名变量，和导出对象里的属性已经没有关联了，所以外部拿到的永远是初始的undefined。

解决方案 #

方案1：导出对象使用getter动态获取（改动最小，兼容原有调用逻辑） #

直接修改导出部分的写法，把US_DB的属性改成访问器，每次外部读取的时候都会拉取当前模块内部的最新变量值，不需要调整其他业务代码的调用方式：

module.exports = {
  UA_DB: {
    User,
  },
  US_DB: {
    // 用getter每次读取都返回当前最新的内部变量
    get Order() { return Order },
    get Item() { return Item },
    get Ingredient() { return Ingredient },
    get Place() { return Place },
  },
  sendUserId,
};

方案2：通过方法获取US模型（更安全，可做初始化校验） #

新增统一的模型获取方法，同时增加初始化校验，避免未登录就调用US模型时出现无意义报错：

// 模块内新增方法
function getUSModel(modelName) {
  if (!US_DB) throw new Error('US数据库未初始化，请先完成登录');
  const models = { Order, Item, Ingredient, Place };
  return models[modelName];
}

// 导出时新增该方法
module.exports = {
  UA_DB: { User },
  getUSModel,
  sendUserId,
};

外部调用时用const Order = getUSModel('Order')即可。

方案3：多用户场景适配 #

你当前的写法仅支持单用户登录，多个用户同时登录时后创建的连接会覆盖之前的连接。如果是多租户服务场景，可以用Map存储不同用户的连接实例，避免覆盖：

// 用Map存储不同用户的US数据库实例
const USDBMap = new Map();

async function sendUserId(newUserId) {
  // 已创建过的连接直接复用，避免重复初始化
  if (USDBMap.has(newUserId)) return USDBMap.get(newUserId);
  // 等待异步连接完成再注册模型
  const US_DB = await mongoose.createConnection(/*... ${newUserId} ...*/ ).asPromise();
  const models = {
    Order: US_DB.model("Order", require("../../data-schemas/order")),
    Item: US_DB.model("Item", require("../../data-schemas/item")),
    Ingredient: US_DB.model("Ingredient", require("../../data-schemas/ingredient")),
    Place: US_DB.model("Place", require("../../data-schemas/place"))
  };
  USDBMap.set(newUserId, models);
  console.log(`opened US database for user ${newUserId}`);
  return models;
}

// 导出根据userId获取对应模型的方法
function getUSModels(userId) {
  if (!USDBMap.has(userId)) throw new Error(`用户${userId}的US数据库未初始化`);
  return USDBMap.get(userId);
}

module.exports = {
  UA_DB: { User },
  sendUserId,
  getUSModels
};

额外注意事项 #

mongoose.createConnection是异步方法，你当前的写法没有等待连接完成就注册模型，可能会出现调用模型时连接还未就绪的异常，建议把sendUserId改为async函数，调用时加await等待连接初始化完成。

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