SpringBoot系列之MongoDBAggregations用法详解-木庄网络博客

本文整理自网络，侵删。

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