SpringBoot系列之MongoDB Aggregations用法詳解

Posted on by

1、前言

在上一章的學習中，我們知道瞭Spring Data MongoDB的基本用法，但是對於一些聚合操作，還是不熟悉的，所以本博客介紹一些常用的聚合函數

2、什麼是聚合？

MongoDB 中使用聚合（Aggregations）來分析數據並從中獲取有意義的信息。在這個過程，一個階段的輸出作為輸入傳遞到下一個階段

常用的聚合函數

聚合函數 SQL類比 描述
project SELECT 類似於select關鍵字，篩選出對應字段
match WHERE 類似於sql中的where，進行條件篩選
group GROUP BY 進行group by分組操作
sort ORDER BY 對應字段進行排序
count COUNT 統計計數，類似於sql中的count
limit LIMIT 限制返回的數據，一般用於分頁
out SELECT INTO NEW_TABLE 將查詢出來的數據，放在另外一個document(Table) ， 會在MongoDB數據庫生成一個新的表

3、環境搭建

  • 開發環境
  • JDK 1.8
  • SpringBoot2.2.1
  • Maven 3.2+
  • 開發工具
  • IntelliJ IDEA
  • smartGit
  • Navicat15

使用阿裡雲提供的腳手架快速創建項目：
https://start.aliyun.com/bootstrap.html

也可以在idea裡，將這個鏈接復制到Spring Initializr這裡，然後創建項目

jdk選擇8的

選擇spring data MongoDB

4、數據initialize

private static final String DATABASE = "test";
private static final String COLLECTION = "user";
private static final String USER_JSON = "/userjson.txt";
private static MongoClient mongoClient;
private static MongoDatabase mongoDatabase;
private static MongoCollection<Document> collection;

@BeforeClass
public static void init() throws IOException {
    mongoClient = new MongoClient("192.168.0.61", 27017);
    mongoDatabase = mongoClient.getDatabase(DATABASE);
    collection = mongoDatabase.getCollection(COLLECTION);
    collection.drop();
    InputStream inputStream = MongodbAggregationTests.class.getResourceAsStream(USER_JSON);
    BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
    reader.lines()
            .forEach(l->collection.insertOne(Document.parse(l)));
    reader.close();
}

5、例子應用

本博客，不每一個函數都介紹，通過一些聚合函數配置使用的例子，加深讀者的理解

統計用戶名為User1的用戶數量

 @Test
 public void matchCountTest() {
     Document first = collection.aggregate(
             Arrays.asList(match(Filters.eq("name", "User1")), count()))
             .first();
     log.info("count:{}" , first.get("count"));
     assertEquals(1 , first.get("count"));
 }

skip跳過記錄，隻查看後面5條記錄

@Test
 public void skipTest() {
      AggregateIterable<Document> iterable = collection.aggregate(Arrays.asList(skip(5)));
      for (Document next : iterable) {
          log.info("user:{}" ,next);
      }

  }

對用戶名進行分組，避免重復，group第一個參數$name類似於group by name，調用Accumulators的sum函數，其實類似於SQL，SELECT name ,sum(1) as sumnum FROMusergroup by name

@Test
 public void groupTest() {
     AggregateIterable<Document> iterable = collection.aggregate(Arrays.asList(
             group("$name" , Accumulators.sum("sumnum" , 1)),
             sort(Sorts.ascending("_id"))
             ));
     for (Document next : iterable) {
         log.info("user:{}" ,next);
     }

 }

參考資料

MongoDB 聚合 https://www.runoob.com/

MongoDB Aggregations Using Java

到此這篇關於SpringBoot系列之MongoDB Aggregations用法的文章就介紹到這瞭,更多相關SpringBoot MongoDB Aggregations用法內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：