Spring Data MongoDB聚合查询：原生语句与转换语句查看方案

1. 直接使用完整原生聚合语句 #

不用拆分管道，直接把完整的原生聚合JSON转换成AggregationOperation执行：

实现步骤 #

• 把你的原生聚合管道JSON字符串解析为Document列表
• 将每个Document包装成AggregationOperation（直接返回原生Document即可绕开Spring Data的转换）
• 组装成Aggregation后用MongoTemplate执行

代码示例 #

import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.aggregation.Aggregation;
import org.springframework.data.mongodb.core.aggregation.AggregationOperation;
import org.bson.Document;
import java.util.List;
import java.util.stream.Collectors;

// 你的原生聚合管道JSON（直接复制MongoDB Compass里的语句即可）
String nativePipelineJson = "[{ $match: { status: 'ACTIVE' } }, { $group: { _id: '$category', total: { $sum: '$amount' } } }]";

// 解析为MongoDB原生Document列表
List<Document> nativePipeline = Document.parse("{\"pipeline\": " + nativePipelineJson + "}")
        .getList("pipeline", Document.class);

// 转换为Spring Data的AggregationOperation列表
List<AggregationOperation> operations = nativePipeline.stream()
        .map(doc -> (AggregationOperation) aggregationContext -> doc)
        .collect(Collectors.toList());

// 执行聚合
Aggregation aggregation = Aggregation.newAggregation(operations);
// 替换成你的实体类和集合名
AggregationResults<YourResultEntity> results = mongoTemplate.aggregate(aggregation, "your_collection", YourResultEntity.class);

这个方法完全跳过Spring Data对聚合管道的转换，直接用原生语句执行，适合复杂的聚合场景。

2. 查看完整的转换后聚合语句（无需修改日志配置） #

如果不想改日志的截断设置，可以手动将Aggregation对象转换为MongoDB原生的Document，然后打印完整JSON：

代码示例 #

import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.aggregation.Aggregation;
import org.bson.Document;
import com.mongodb.client.MongoDatabase;

// 假设你已经组装好Aggregation对象
Aggregation yourAggregation = Aggregation.newAggregation(
        Aggregation.match(Criteria.where("status").is("ACTIVE")),
        Aggregation.group("category").count().as("count")
);

// 获取MongoDB连接实例
MongoDatabase db = mongoTemplate.getMongoDbFactory().getDb();

// 将Spring Data的Aggregation转换为原生Document
Document aggregationDoc = yourAggregation.toDocument(
        mongoTemplate.getConverter().getMappingContext(),
        db.getCodecRegistry()
);

// 打印完整的聚合语句（无截断）
System.out.println("完整聚合语句：\n" + aggregationDoc.toJson());

另一种Debug方式 #

如果不想写代码，也可以用IDE的Debug模式：

• 在执行aggregate方法前打一个断点
• 查看Aggregation对象的pipeline属性，展开后就能看到每个步骤的完整转换结果

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