java – Spring Data MongoDB – 聚合方法

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了java – Spring Data MongoDB – 聚合方法，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1509字，纯文字阅读大概需要3分钟。

内容图文

有谁知道如何使用Spring-data将以下聚合函数转换为java代码？

db.myCollection.aggregate([
    {$match:{"status" : {$in:["WORKING","UNASSIGNED"]}}},
    {$group:{
            _id:{
                "status":"$status",
                "queue":"$queueName"
             },
             "count":{$sum:1},
             "oldest":{$min:"$queueTime"},
             "slow":{$sum:{$cond:[
                                {$lte: ["$queueServiceTs", new Date()]},
                                        1,
                                        0]}
                          }

        }
    }
]);

解决方法:

Spring mongo目前不支持：

>具有自定义键名的复合聚合_id,当然您可以接受defualt字段名称转换
>使用$cond操作或$sum中的任何表达式,因为它仅支持映射字段.

所以第二种情况是在这种情况下会破坏聚合辅助函数的使用.您可以通过首先执行$项目来解决这个问题,但这需要额外的执行阶段来影响性能.

但您可以做的是创建自己的抽象类,该类在标准构建器函数中工作,但允许您使用标准对象构建管道阶段：

public class CustomGroupOperation implements AggregationOperation {
    private DBObject operation;

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

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

然后您可以将它与标准构建器一起使用,如下所示：

    Aggregation aggregation = newAggregation(
            new CustomGroupOperation(
                    new BasicDBObject("$group",
                        new BasicDBObject("_id",
                            new BasicDBObject("status","$status")
                                .append("queue","$queueName")
                        )
                        .append("count",new BasicDBObject("$sum",1))
                        .append("oldest", new BasicDBObject("$min","$queueTime"))
                        .append("slow",
                            new BasicDBObject("$sum",
                                new BasicDBObject("$cond",Arrays.asList(
                                    new BasicDBObject("$lte",Arrays.asList(
                                        "$queueServiceTs",
                                        new Date()
                                    )),
                                    1,
                                    0
                                ))
                            )
                        )
                    )
            )
    );

并且正如您所定义的那样,使用$group阶段构建管道.

内容总结

以上是互联网集市为您收集整理的java – Spring Data MongoDB – 聚合方法全部内容，希望文章能够帮你解决java – Spring Data MongoDB – 聚合方法所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端