将 mongodb 聚合转换为 Spring Boot 等效项

Question

我有一个工作聚合：

db.getCollection("policies").aggregate([

                      { $match: { "policyData.QuoteOrPolicy.Policy.RatingStateProvCd.Value": "IL" , "policyData.QuoteOrPolicy.Policy.CompanyProductCd.Value" :  "027" , 
                                         "policyData.QuoteOrPolicy.Policy.InitialDataOrderLineCd.Value"  :   "010" } },

                 { $project:{            "policyData.QuoteOrPolicy.PersAutoLineBusiness.PersAutoVeh.Coverage.CoverageCd": 1        }    }                  ,
                   { $unwind: { path: "$policyData.QuoteOrPolicy", preserveNullAndEmptyArrays: true } } ,
                 { $unwind: { path: "$policyData.QuoteOrPolicy.PersAutoLineBusiness", preserveNullAndEmptyArrays: true } } ,
                 { $unwind: { path: "$policyData.QuoteOrPolicy.PersAutoLineBusiness.PersAutoVeh", preserveNullAndEmptyArrays: true } } ,
                   { $unwind: { path: "$policyData.QuoteOrPolicy.PersAutoLineBusiness.PersAutoVeh.Coverage", preserveNullAndEmptyArrays: true } } ,
                    { $group: { _id: "$policyData.QuoteOrPolicy.PersAutoLineBusiness.PersAutoVeh.Coverage.CoverageCd.Value", count: { $sum: 1 } } },
                    {$group:{"_id":null,"coverage_counts":{$push:{"coverage_value":"$_id",
                                               "count":"$count"}}}},
                    {$project:{"_id":0,"coverage_counts":1}}

             ])

按预期工作。 使用它的 mongodb 支持聚合在 Spring Boot 中获得等效的工作，我并不高兴。

任何人都可以“翻译”它吗？ 感谢您提供所有信息。

Answer 1

您需要熟悉 org.springframework.data.mongodb.core.aggregation.Aggregation 库，以更好地了解如何在 spring 中使用 mongodb 的聚合。

这是一个示例，说明如何使用查询来使用它：

mongoOperation.aggregate( Aggregation.newAggregation(
                Aggregation.match( Criteria.where( "policyData.QuoteOrPolicy.Policy.RatingStateProvCd.Value" ).is( "IL" )
                .and( "policyData.QuoteOrPolicy.Policy.CompanyProductCd.Value" ).is( "027" )
                .and( "policyData.QuoteOrPolicy.Policy.InitialDataOrderLineCd.Value" ).is( "010" ) ),
                Aggregation.project().and( "policyData.QuoteOrPolicy" ).as( "QuoteOrPolicy" ),
                Aggregation.unwind( "QuoteOrPolicy", true ),
                Aggregation.unwind( "QuoteOrPolicy.PersAutoLineBusiness", true ),
                Aggregation.unwind( "QuoteOrPolicy.PersAutoLineBusiness.PersAutoVeh", true ),
                Aggregation.unwind( "QuoteOrPolicy.PersAutoLineBusiness.PersAutoVeh.Coverage", true ),
                Aggregation.group( "QuoteOrPolicy.PersAutoLineBusiness.PersAutoVeh.Coverage.CoverageCd.Value" ).count().as( "count" ),
                Aggregation.group().push( new Document( "coverage_value", "$_id" ).append( "count", "$count" ) ).as( "coverage_counts" ),
                Aggregation.project( "coverage_counts" )
             ), "NameOfYourCollection", Document.class );

如果最后的 Document.class 具有与您的查询输出匹配的字段，则可以将其更改为一个类。