如何高效实现Node.js多MongoDB连接并兼容原有代码？

1. 更新环境变量配置 #

首先在.env文件中添加新连接的配置，用明确的命名区分不同连接的URI和数据库名：

# 原书籍数据库连接
MONGODB_BOOKS_URI=mongodb://localhost:27017
DB_BOOKS_NAME=books

# 新增店铺数据库连接
MONGODB_STORES_URI=mongodb://localhost:27018
DB_STORES_NAME=stores

2. 重构MongoDB连接管理模块 #

将原单连接逻辑改为多连接管理，通过连接标识区分不同实例，同时保留原db()函数以兼容旧代码：

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

// 存储已建立的客户端连接，key为连接标识（如'books'、'stores'）
const activeConnections = {};

// 预定义各连接的配置映射，从环境变量读取
const connectionConfigs = {
  books: {
    uri: process.env.MONGODB_BOOKS_URI,
    dbName: process.env.DB_BOOKS_NAME
  },
  stores: {
    uri: process.env.MONGODB_STORES_URI,
    dbName: process.env.DB_STORES_NAME
  }
};

/**
 * 获取指定连接的数据库实例
 * @param {string} [key='books'] - 连接标识，默认使用原书籍数据库
 * @returns {Promise<Db>} 数据库实例
 */
const getDb = async (key = 'books') => {
  // 校验连接配置是否存在
  if (!connectionConfigs[key]) {
    throw new Error(`无效的连接标识：${key}，请检查配置`);
  }

  // 连接已存在则直接复用
  if (activeConnections[key]) {
    return activeConnections[key].db(connectionConfigs[key].dbName);
  }

  // 建立新连接并缓存
  const client = await MongoClient.connect(connectionConfigs[key].uri);
  activeConnections[key] = client;

  return client.db(connectionConfigs[key].dbName);
};

// 保留原db函数，完全兼容旧代码调用
const db = async () => getDb('books');

// 可选：添加全局关闭所有连接的方法，用于应用退出时清理资源
const closeAllConnections = async () => {
  await Promise.all(Object.values(activeConnections).map(client => client.close()));
};

module.exports = {
  db,
  getDb,
  closeAllConnections
};

3. 旧代码无需修改 #

原控制器工具函数继续使用db()即可，逻辑完全不变：

async function getBookById(id) {
  const client = await db();
  const book = await client
    .collection('books')
    .findOne(id);
  return book;
}

4. 新增代码使用指定连接 #

店铺相关工具函数通过getDb('stores')获取新连接：

async function getStoreById(id) {
  const client = await getDb('stores');
  const store = await client
    .collection('stores')
    .findOne(id);
  return store;
}

方案优势 #

• 完全兼容旧代码：原db()函数保留，旧业务逻辑无需任何改动。
• 扩展性强：后续新增连接时，只需在.env添加配置、在connectionConfigs中新增映射即可。
• 连接复用：每个连接仅初始化一次，避免重复建立连接消耗资源。
• 逻辑清晰：通过连接标识明确区分不同数据库，避免混淆。

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