在java中使用$ group阶段实现MongoDB聚合管道Spring

Question

我想在java中使用Spring mongo实现MongoDB查询。

这是本地的MongoDB查询：

db.ShieldReport.aggregate([ 
    {$match:{"sellerCode":"e1aaf3"}}, 
    {$project:{bucketName:"$bucketName", brandName: "$brandName", createdTime : "$createdTime", sellerCode : "$sellerCode"}}, 
    {$sort:{"createdTime":-1}}, 
    {$group: 
      { 
       _id: { sellerCode: "$sellerCode", bucketName: "$bucketName", brandName: "$brandName"}, 
       itemsSold: { $first: { bucketName: "$bucketName", brandName: "$brandName", createdTime : "$createdTime"} } 
      } 

    }, 
    {$sort:{"itemsSold.createdTime":-1}}, 
    {$project : { _id : "$_id.sellerCode", bucketName :"$itemsSold.bucketName", brandName : "$itemsSold.brandName"}} 
]) 

在我的Spring Java版本，我有这么远：

Aggregation agg = newAggregation(
    match(Criteria.where("sellerCode").is(filterR‌​equest.getSellerCode‌​())), 
    Aggregation.project("bucketName") 
       .andInclude("brandName") 
       .an‌​dInclude("createdTim‌​e") 
       .andInclude("sell‌​erCode"), 
    sort(Sort.Direction.DESC, "createdTime"), 
    group("sellerCode", "brandName", "bucketName") 
); 

但问题是我不能够创建itemSold领域。我如何创建？

Answer 1

你可以在重组春您的管道如下：

Aggregation agg = Aggregation.newAggregation( 
    Aggregation.match(Criteria.where("sellerCode").is(filterR‌​equest.getSellerCode‌​())), 
    Aggregation.sort(Sort.Direction.DESC, "createdTime"), 
    Aggregation.group("sellerCode", "bucketName", "brandName") 
     .first("bucketName").as("bucketName") 
     .first("brandName").as("brandName") 
     .first("createdTime ").as("createdTime "), 
    Aggregation.sort(Sort.Direction.DESC, "createdTime"), 
    Aggregation.project("bucketName", "brandName") 
     .and("sellerCode").previousOperation()    
); 

正如你可以看到一些流水线阶段，因为他们真的没有必要被省略了。例如，$group步骤之前$project管道就可以来$group管道运营商采取关闭将适用于蓄电池

在组步骤中，您组中间过滤文件由三个字段，并存储在新的其他字段值由$first操作员辅助。

将中间结果按前一组操作的createdTime字段参考排序。

最后，在第四步中，从前面的组操作中选择“bucketName”和“brandName”字段。请注意，“sellerCode”又隐含地引用了一个group-id字段。