如何使用NestJS与Mongoose实现跨数据库Lookup查询？

完全可以实现，NestJS基于Express，底层依赖Mongoose，而MongoDB 3.2+本身支持跨数据库的$lookup聚合操作，直接通过Mongoose的聚合API就能实现需求。以下是具体实现步骤：

1. 确保多数据库连接配置正确 #

确认已按照NestJS的Mongoose模块规范配置多个数据库连接，每个连接指定唯一的connectionName：

// app.module.ts
import { Module } from '@nestjs/common';
import { MongooseModule } from '@nestjs/mongoose';

@Module({
  imports: [
    MongooseModule.forRoot('mongodb://localhost/db1', { connectionName: 'db1' }),
    MongooseModule.forRoot('mongodb://localhost/db2', { connectionName: 'db2' }),
  ],
})
export class AppModule {}

2. 定义对应数据库的Schema和Model #

为每个数据库的集合创建Schema，并在导入时指定对应的connectionName：

数据库db1的User Schema #

// user.schema.ts
import { Prop, Schema, SchemaFactory } from '@nestjs/mongoose';
import { Document } from 'mongoose';

export type UserDocument = User & Document;

@Schema({ collection: 'users' }) // 明确集合名，避免自动复数化问题
export class User {
  @Prop()
  name: string;
  @Prop()
  orderId: string; // 关联db2中orders集合的_id
}

export const UserSchema = SchemaFactory.createForClass(User);

在模块中导入（指定connectionName为db1）：

// user.module.ts
import { Module } from '@nestjs/common';
import { MongooseModule } from '@nestjs/mongoose';
import { User, UserSchema } from './user.schema';

@Module({
  imports: [
    MongooseModule.forFeature([{ name: User.name, schema: UserSchema }], 'db1'),
  ],
  providers: [UserService],
  exports: [UserService],
})
export class UserModule {}

数据库db2的Order Schema #

// order.schema.ts
import { Prop, Schema, SchemaFactory } from '@nestjs/mongoose';
import { Document } from 'mongoose';

export type OrderDocument = Order & Document;

@Schema({ collection: 'orders' })
export class Order {
  @Prop()
  _id: string;
  @Prop()
  amount: number;
}

export const OrderSchema = SchemaFactory.createForClass(Order);

在模块中导入（指定connectionName为db2）：

// order.module.ts
import { Module } from '@nestjs/common';
import { MongooseModule } from '@nestjs/mongoose';
import { Order, OrderSchema } from './order.schema';

@Module({
  imports: [
    MongooseModule.forFeature([{ name: Order.name, schema: OrderSchema }], 'db2'),
  ],
})
export class OrderModule {}

3. 实现跨数据库Lookup查询 #

在Service中注入对应数据库的Model，通过aggregate()方法构建包含跨库$lookup的聚合管道：

// user.service.ts
import { Injectable } from '@nestjs/common';
import { InjectModel } from '@nestjs/mongoose';
import { Model } from 'mongoose';
import { User, UserDocument } from './user.schema';

@Injectable()
export class UserService {
  constructor(
    @InjectModel(User.name, 'db1') private userModel: Model<UserDocument>,
  ) {}

  async getUsersWithCrossDbOrders() {
    return this.userModel.aggregate([
      {
        $lookup: {
          from: 'orders', // 目标数据库的集合名
          localField: 'orderId', // 当前集合的关联字段
          foreignField: '_id', // 目标集合的关联字段
          as: 'orderDetails', // 查询结果的别名
          db: 'db2', // 目标数据库名称
        },
      },
    ]).exec();
  }
}

注意事项 #

• 确保MongoDB版本≥3.2，该版本开始支持跨数据库$lookup
• 操作数据库的账号需要具备两个目标数据库的读写权限
• 如果集合名称和Mongoose自动生成的不一致（比如自动复数化），务必在Schema中通过collection属性指定实际集合名

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