SpringBoot系列之MongoDB？Aggregations用法详解（mongodb项目使用说明）深度揭秘

文章摘要

这篇文章介绍了MongoDB中聚合操作的应用，重点讲解了常用聚合函数及其应用场景。文章首先解释了聚合的定义和作用，即通过一系列操作对数据进行筛选、分组、排序等处理，以获取更有价值的信息。接着，文章详细列举了几个常用函数，包括： 1. **match**：用于进行条件筛选。 2. **count**：用于统计符合条件的文档数量。 3. **group**：用于按指定字段分组。 4. **sort**：用于对结果进行排序。文章还提供了具体的示例代码，展示了如何结合这些函数完成实际的数据查询和分析任务，例如统计用户名为“User1”的用户数量、跳过前5条记录并查看后续数据等。此外，文章还详细介绍了开发环境的搭建方法，包括所需的JDK、SpringBoot、Maven及相关工具的使用，并提供了完整的开发步骤和初始化代码。文章最后还附上了相关的参考资料，方便读者进一步学习和实践。总体而言，文章内容简洁明了，既介绍了聚合操作的理论，又提供了实际应用示例，帮助读者更好地理解MongoDB聚合功能的使用方法。

目录1、前言2、什么是聚合？3、环境搭建4、数据initialize5、例子应用参考资料

在上一章的学习中，我们知道了Spring Data MongoDB的基本用法，但是对于一些聚合操作，还是不熟悉的，所以本博客介绍一些常用的聚合函数

MongoDB 中使用聚合（Aggregations）来分析数据并从中获取有意义的信息。在这个过程，一个阶段的输出作为输入传递到下一个阶段

常用的聚合函数

聚合函数SQL类比描述projectSELECT类似于select关键字，筛选出对应字段matchWHERE类似于sql中的where，进行条件筛选groupGROUP BY进行group by分组操作sortORDER BY对应字段进行排序countCOUNT统计计数，类似于sql中的countlimitLIMIT限制返回的数据，一般用于分页outSELECT INTO NEW_TABLE将查询出来的数据，放在另外一个document(Table) ，会在MongoDB数据库生成一个新的表

开发环境JDK 1.8SpringBoot2.2.1Maven 3.2+开发工具
IntelliJ IDEAsmartGitNavicat15

使用阿里云提供的脚手架快速创建项目：

https://start.aliyun.com/bootstrap.html

也可以在idea里，将这个链接复制到Spring Initializr这里，然后创建项目

jdk选择8的

选择spring data MongoDB

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

本博客，不每一个函数都介绍，通过一些聚合函数配置使用的例子，加深读者的理解

统计用户名为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);
}

}

对用户名进行分组，避免重复，第一个参数类似于，调用的函数，其实类似于SQL，user

@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用法内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:SpringBoot中使用MongoDB的连接池配置SpringBoot整合MongoDB的实现步骤SpringBoot 使用Mongo的GridFs实现分布式文件存储操作使用Springboot整合GridFS实现文件操作SpringBoot配置MongoDB多数据源的方法步骤SpringBoot MongoDB与MongoDB GridFS基本使用