Spring Mongo跨不同数据库实现Lookup聚合查询方案咨询

算力阿峰

2026-7-5

跨数据库Lookup聚合实现（Spring Data MongoDB）

MongoDB原生支持跨数据库的$lookup关联查询，只需将关联目标指定为"数据库名.集合名"格式，结合Spring Data MongoDB可以按以下两种方式实现：

1. 修改LookupOperation实现跨库关联

直接调整LookupOperation的from参数为目标数据库名.集合名，同时使用对应源集合（User）所在数据库的MongoTemplate执行聚合：

// Race集合位于db1数据库，from参数指定为"db1.race"
LookupOperation lookupOperation = LookupOperation.newLookup()
        .from("db1.race")
        .localField("carId")
        .foreignField("carId")
        .as("result");

// 使用连接User所在数据库（db2）的MongoTemplate实例
Aggregation aggregation = Aggregation.newAggregation(lookupOperation);
List<AggResult> outputs = userMongoTemplate.aggregate(aggregation, "user", AggResult.class).getMappedResults();

注意：项目中需要配置两个独立的MongoTemplate实例，分别对应db1和db2，聚合操作必须从源集合（User）所在的db2发起。

2. 原生聚合管道写法

如果需要更灵活的控制，可直接通过原生AggregationOperation构建跨库$lookup阶段：

AggregationOperation crossDbLookup = context -> new Document("$lookup",
        new Document("from", "db1.race")
                .append("localField", "carId")
                .append("foreignField", "carId")
                .append("as", "result")
);

Aggregation aggregation = Aggregation.newAggregation(crossDbLookup);
List<AggResult> outputs = userMongoTemplate.aggregate(aggregation, "user", AggResult.class).getMappedResults();