Java中动态构建MongoDB分组聚合查询的结构错误问题

你遇到的核心问题是错误地把求和字段添加到了$group操作符的同级，而不是嵌套在$group对应的对象内部。原来的代码中，group变量直接对应{ "$group": ... }的外层对象，调用group.append()时，是把error1这类字段加到了外层，而不是$group的值里面。

修正后的代码实现 #

我们需要先单独创建$group内部的对象（包含_id和动态的求和字段），再把这个内部对象赋值给$group操作符：

List<String> totalError = new ArrayList<String>();
// 先创建$group的内部对象，初始化_id字段
BasicDBObject groupFields = new BasicDBObject("_id", "$stream.name");
// 根据条件动态添加求和字段
if (error1) {
    groupFields.append("error1", new BasicDBObject("$sum", "$stream.error1"));
}
if (error2) {
    groupFields.append("error2", new BasicDBObject("$sum", "$stream.error2"));
}
if (error3) {
    groupFields.append("error3", new BasicDBObject("$sum", "$stream.error3"));
}
// 最后构建完整的$group阶段
BasicDBObject group = new BasicDBObject("$group", groupFields);

这样生成的查询结构就会完全符合预期：

{ "$group" : { "_id" : "$stream.name", "error1" : { "$sum": "$stream.error1"} , "error2" : { "$sum" : "$stream.error2"} } }

补充：MongoDB Java驱动新版本写法（推荐） #

如果你使用的是MongoDB Driver 3.x及以上版本，官方推荐使用Document替代老旧的BasicDBObject，写法更简洁且兼容性更好：

List<String> totalError = new ArrayList<>();
Document groupFields = new Document("_id", "$stream.name");
if (error1) {
    groupFields.append("error1", new Document("$sum", "$stream.error1"));
}
if (error2) {
    groupFields.append("error2", new Document("$sum", "$stream.error2"));
}
if (error3) {
    groupFields.append("error3", new Document("$sum", "$stream.error3"));
}
Document group = new Document("$group", groupFields);

这个写法逻辑和之前一致，只是用更现代的Document类替代了旧的BasicDBObject，可读性和后续维护性会更强。

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