个人中心
gpt4 book ai didi

SpringBoot系列之MongoDB Aggregations用法

转载 作者：知者 更新时间：2024-03-13 08:23:14 26 4
gpt4 key购买 nike

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);
     }

 }

参考资料

26 4 0
文章推荐： Java多线程-Semaphore(限流)
文章推荐： 重学SpringCloud系列八之微服务网关安全认证-JWT篇
文章推荐： LeetCode_前缀和_简单_303.区域和检索 - 数组不可变
文章推荐： 分布式系统的CAP定理
知者
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com