如何在MongoDB与Node.js中实现跨数据库表间引用？

下面是几种在Node.js环境中实现company.companies表对Root.user表跨库引用的实用方案：

1. 手动关联查询（最灵活易控） #

在companies文档中存储user的_id，查询时先获取companies数据，再通过_id去Root库的user表中查询关联数据，这种方式无需依赖特殊语法，完全由代码控制关联逻辑。

示例代码（使用Mongoose） #

先分别连接两个数据库并定义模型：

const mongoose = require('mongoose');

// 连接Root数据库
const rootConn = mongoose.createConnection('mongodb://localhost:27017/Root');
// 连接company数据库
const companyConn = mongoose.createConnection('mongodb://localhost:27017/company');

// Root库的User模型
const User = rootConn.model('User', new mongoose.Schema({
  name: String,
  email: String
}));

// company库的Company模型
const Company = companyConn.model('Company', new mongoose.Schema({
  name: String,
  ownerId: mongoose.Types.ObjectId // 存储关联的User的_id
}));

查询时手动关联数据：

async function getCompanyWithOwner(companyId) {
  const company = await Company.findById(companyId);
  if (!company) return null;
  // 通过存储的ownerId去Root库查询对应用户
  const owner = await User.findById(company.ownerId);
  return {
    ...company.toObject(),
    owner
  };
}

// 调用示例
getCompanyWithOwner('目标公司ID').then(result => console.log(result));

2. 使用MongoDB原生DBRef #

MongoDB官方提供了DBRef类型用于跨数据库/集合的引用，Node.js中可通过原生驱动直接使用。

示例代码（使用MongoDB原生驱动） #

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

async function main() {
  const client = await MongoClient.connect('mongodb://localhost:27017');
  
  const rootDb = client.db('Root');
  const companyDb = client.db('company');

  // 插入带有DBRef的company文档
  await companyDb.collection('companies').insertOne({
    name: 'Tech Corp',
    owner: new DBRef('user', '目标用户ID', 'Root') // 格式：(关联集合名, 文档ID, 数据库名)
  });

  // 查询并解析DBRef获取关联用户
  const company = await companyDb.collection('companies').findOne({ name: 'Tech Corp' });
  const owner = await rootDb.dereference(company.owner);
  console.log('关联结果:', { ...company, owner });

  await client.close();
}

main();

3. Mongoose跨库模型引用 #

如果使用Mongoose，可以通过指定模型的连接实例，实现跨库的populate关联查询。

示例代码 #

const mongoose = require('mongoose');

const rootConn = mongoose.createConnection('mongodb://localhost:27017/Root');
const companyConn = mongoose.createConnection('mongodb://localhost:27017/company');

const User = rootConn.model('User', new mongoose.Schema({
  name: String,
  email: String
}));

// 在Company Schema中指定关联的User模型及对应连接
const CompanySchema = new mongoose.Schema({
  name: String,
  ownerId: {
    type: mongoose.Types.ObjectId,
    ref: 'User', // 关联User模型
    connection: rootConn // 明确指定User模型所在的数据库连接
  }
});

const Company = companyConn.model('Company', CompanySchema);

// 使用populate直接拉取关联数据
async function getCompanyWithOwner(companyId) {
  const company = await Company.findById(companyId).populate('ownerId');
  return company;
}

getCompanyWithOwner('目标公司ID').then(result => console.log(result));

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