MongoDB提供聚合管道技術進行處理輸入的資料，資料經過一個一個的stage，每個stage將資料處理後的結果傳遞給下一個stage，最終得到多重處理後的結果。 

Aggregate提供了多種stage可供選擇，match、match、sort、limit、limit、limit等。對於巢狀資料的處理可以在Aggregate中實現，減少在程式碼上的編寫

上篇文章介紹了Mongodb按照時間天進行分組，但是返回的資料是統計的效果，不能得到自己想要的資料。

今天來介紹一下如何對天進行分組後，還能獲取到自己想要顯示的資料並進行分頁。

根據業務的需求，對會員ID進行分組，並獲取會員的手機，地址等等

// 查詢條件
 Criteria criteria = Criteria.where("欄位").is(傳參);

 List<Order> sortOrders = new ArrayList<Order>();
        sortOrders.add(new Order(Direction.DESC, "count"));// 降序
  MatchOperation matchOper = Aggregation.match(criteria);// 查詢條件

    // 聚合統計，按照memberId欄位聚合，count計數顯示資料
   // group("memberId","browseTime")按會員和瀏覽時間排序
//自己想得到顯示的資料
  AggregationOperation aggOper = Aggregation.group("memberId").count().as("count")
                    .first("memberId").as("memberId")
                    .first("browseMemberId").as("browseMemberId")
                    .first("browseTime").as("browseTime")
                    .first("companyName").as("companyName")
                    .first("memberlevel").as("memberlevel")；

  AggregationOperation aggSort = Aggregation.sort(new Sort(sortOrders));// 排序欄位
    
    // 分頁操作，pageNumber為當前頁數，pageSize為每頁顯示條數
   AggregationOperation aggPageSkip = Aggregation.skip((int) ((page.getPage() - 1) * page.getRows()));
   AggregationOperation aggPagelimit = Aggregation.limit(page.getRows());
//聚合管道
  Aggregation agg = Aggregation.newAggregation(matchOper, aggOper, aggSort, aggPageSkip, aggPagelimit);
 //得到結果集    
   AggregationResults<Map> results = mongoTemplate.aggregate(agg, TradeBrowseDto.class, Map.class);

    List<Map> listVehicleSensors = results.getMappedResults();
 

總結：

聚合管道在處理巢狀資料時，可以對一個文件進行多重處理。輸入資料為一條，多次處理，每次處理後將結果直接傳遞給下一個stage，最終得到一個輸出結果；

在處理巢狀文件時提供很大遍歷；

提供兩個集合之間聯合查詢的介面。