使用投影中大小数组的除法操作编写聚合查询的方法

Question

我想使用 Spring Data MongoDB 运行这个聚合查询。

db.collectionname.aggregate(
   {
        "$group": {
        "_id": "$searchTerm",
        "dateAddToSet": {
            "$addToSet": "$date"
        }
    }
  },
  {
    "$project": {
        "searchTerm": "$_id.searchTerm",
        "percent": {
            "$divide": [{ "$size": "$dateAddToSet" }, 28]
        }
    }
  })

我找不到在 $dataAddToSet 大小上编写除法操作以执行此查询的方法。

非常感谢。

Answer 1

抱歉耽搁了。这里的主要问题是 $size 目前在 spring mongo 中不是受支持的操作。所以构造操作的唯一方法是使用 DBObject 构造。

但是您可以通过提供自己的包装类来混合这两种方法，例如：

public class CustomAggregationOperation implements AggregationOperation {
    private DBObject operation;

    public CustomAggregationOperation (DBObject operation) {
        this.operation = operation;
    }

    @Override
    public DBObject toDBObject(AggregationOperationContext context) {
        return context.getMappedObject(operation);
    }
}

所以通常重写.toDBObject() 方法，只返回提供给类的构造函数的DBObject 数据。

然后在构建聚合时使用：

    Aggregation agg = newAggregation(
            group("searchTerm")
                    .addToSet("date").as("dateAddToSet"),
            new CustomAggregationOperation(
                new BasicDBObject("$project",
                    new BasicDBObject("_id",0)
                        .append("searchTerm","$_id")
                        .append("percent",new BasicDBObject(
                                "$divide", new Object[]{
                                    new BasicDBObject("$size","dateAddToSet"),
                                    28
                                }

                            )
                        )
                )
            )
    );

这会产生一个格式正确的管道：

{ 
    "aggregate" : "__collection__" , 
    "pipeline" : [ 
        { "$group" : { 
            "_id" : "$searchTerm" , 
            "dateAddToSet" : { "$addToSet" : "$date" }
        }}, 
        { "$project" : { 
            "_id" : 0 ,
            "searchTerm" : "$_id" , 
            "percent" : { "$divide" : [ { "$size" : "$dateAddToSet" } , 28] }
        }}
    ]
}

因此，这是将可用构建器与自定义构造混合在一起的一种方法，这样您就可以使用当前不存在构建器的方法。