Springboot与mongodb集成及聚合查询

Spring Boot 与 MongoDB 的集成为开发者提供了一种简便的方式来构建高性能、基于文档的数据驱动应用程序。MongoDB 是一个非关系型数据库(NoSQL),它使用 JSON 格式的文档进行数据存储,非常适合处理大量的、半结构化的数据。而 Spring Boot 则通过其自动配置和 Starter 项目简化了应用开发过程。结合 Spring Data MongoDB,可以非常方便地在 Spring Boot 应用中实现对 MongoDB 的操作,包括复杂的数据聚合查询。

1. 集成 Spring Boot 与 MongoDB

首先,确保你的开发环境中已经安装了 MongoDB,并且正在运行。接下来,我们将在 Spring Boot 项目中集成 MongoDB。

添加依赖

pom.xml 文件中添加 Spring Boot Starter for MongoDB 的依赖:

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-mongodb</artifactId></dependency>
</dependencies>
配置 MongoDB

application.propertiesapplication.yml 中配置 MongoDB 的连接信息:

spring:data:mongodb:uri: mongodb://username:password@localhost:27017/databaseName

2. 使用 MongoTemplate 进行聚合查询

MongoTemplate 是 Spring Data MongoDB 提供的一个主要类,用于执行数据库操作,包括复杂的聚合查询。以下是一些基本聚合查询的示例。

准备工作

假设我们有一个 User 集合,包含用户的姓名(name)、年龄(age)和注册日期(registrationDate)字段。

public class User {@Idprivate String id;private String name;private int age;private Date registrationDate;// 省略构造器、getter 和 setter
}
聚合查询示例
示例 1:计数

计算集合中的文档总数:

long count = mongoTemplate.count(new Query(), User.class);
示例 2:分组统计

按年龄分组统计用户数量:

Aggregation agg = Aggregation.newAggregation(Aggregation.group("age").count().as("userCount"));
AggregationResults<Document> results = mongoTemplate.aggregate(agg, "User", Document.class);
results.forEach(result -> System.out.println("Age: " + result.get("age") + ", Count: " + result.get("userCount")));

 

示例 3:匹配与排序

查找年龄大于 25 岁的用户,并按年龄降序排序:

Aggregation agg = Aggregation.newAggregation(Aggregation.match(Criteria.where("age").gt(25)),Aggregation.sort(Sort.Direction.DESC, "age")
);
List<User> users = mongoTemplate.aggregate(agg, "User", User.class).getMappedResults();
示例 4:投影与限制

只获取用户名和年龄,限制结果数量为前 10 条:

Aggregation agg = Aggregation.newAggregation(Aggregation.project("name", "age"),Aggregation.limit(10)
);
List<Document> projectedUsers = mongoTemplate.aggregate(agg, "User", Document.class).getMappedResults();
示例 5:使用管道操作符(更复杂的聚合)

例如,找出每个年龄段的最年轻用户:

Aggregation agg = Aggregation.newAggregation(Aggregation.group("age").first("name").as("youngestUser").min("registrationDate").as("oldestRegistrationDate"),Aggregation.sort(Sort.Direction.ASC, "_id")
);
AggregationResults<Document> results = mongoTemplate.aggregate(agg, "User", Document.class);
results.forEach(result -> System.out.println(result.toJson()));

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/bicheng/21804.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

mybatisplus 字段存的是json 在查询的时候怎么映射成对象

数据库交互对象 TableName(value "表名", autoResultMap true)TableField(typeHandler JacksonTypeHandler.class, value "user_info")private User user;autoResultMap 是一个 MyBatis-Plus 中的注解属性&#xff0c;用于控制是否自动生成结果映射。…

部署metrics-server

kubeadm部署metrics-server 需求&#xff1a;生产环境是kubeadm部署的v1.22.2版本的k8s&#xff0c;统计资源时发现这套环境没有部署metrics-server这个服务&#xff0c;今天来部署一下 1、在github社区找到这个项目并下载 rootjumpserver-cmcc:~# wget https://github.com/…

你需要知道关于 Java 线程一些最基本的事情

你好&#xff0c;我是 shengjk1&#xff0c;多年大厂经验&#xff0c;努力构建 通俗易懂的、好玩的编程语言教程。 欢迎关注&#xff01;你会有如下收益&#xff1a; 了解大厂经验拥有和大厂相匹配的技术等 希望看什么&#xff0c;评论或者私信告诉我&#xff01; 文章目录 一…

百度云下载不限速方式集合

使用解析网站配合Motrix工具软件 下载Motrix工具&#xff1a;Motrix下载链接打开解析网址&#xff1a;解析网站获取&#xff0c;将百度网盘链接粘贴到解析网站&#xff0c;获取下载链接。在Motrix中配置Aria2 RPC地址&#xff1a;ws://localhost:16800/jsonrpc开始下载&#x…

《SpringBoot3+Vue3实战》系列文章目录

前后端分离&#xff08;Frontend-Backend Separation&#xff09;是一种软件架构设计模式&#xff0c;它将传统的Web应用中的前端&#xff08;用户界面&#xff09;和后端&#xff08;服务器逻辑和数据存储&#xff09;从应用层面进行解耦&#xff0c;使得两者可以独立地开发、…

stm32标准库usart1,usrat2,usart3三个串口的配置以及printf重定向(串口输出)

我刚开始学串口时&#xff0c;因为要用到多个串口&#xff0c;自己又懒得改&#xff0c;总是在网上要找半天。下面将stm32的三个串口配置罗列下来&#xff0c;方便大家直接copy。 1、串口1 引脚&#xff1a;TX&#xff1a;PA9&#xff1b; RX&#xff1a;PA10&#xff1b; 重…

Deno入门:Node.js的现代替代品

Deno 作为 Node.js 的现代替代品&#xff0c;提供了许多改进和创新&#xff0c;尤其是在安全性、模块系统和开发体验方面。虽然它仍处于发展阶段&#xff0c;但对于寻求简洁、安全和现代化 JavaScript/TypeScript 开发环境的开发者来说&#xff0c;Deno 是一个值得考虑的选择。…

【封装】Unity切换场景不销毁物体

在切换场景时&#xff0c;如果物体不需要销毁&#xff0c;可以直接使用下方脚本 代码 public class DontDestroyLoader : MonoBehaviour{ //所有不销毁的物体预制体[SerializeField] private GameObject[] dontDestroyPrefabs;//实例化预制体public void Load(){foreach (var …

Linux CFS调度器简介

文章目录 前言一、概要二、实现2.1 简介2.2 算法实现2.3 内核源码 三、特点四、调度策略五、调度类参考资料 前言 早期的Linux调度器采用了简化的设计&#xff0c;显然并不针对具有许多处理器甚至超线程的大规模架构。Linux 1.2调度器使用循环队列对可运行任务进行管理&#x…

flink实战--大状态任务调优指南

Flink 状态(State)简介 在 Flink 中,状态管理是流处理应用的核心概念之一,它允许算子(operators)在处理事件时保持和操作状态信息。在 Flink 中,状态可以被视为算子的“记忆”,它使得算子能够在处理无界流数据时保持对历史数据的跟踪。状态可以是简单的键值对,也可以是…

昆仑万维官宣开源2000亿稀疏大模型Skywork-MoE

6月3日&#xff0c;昆仑万维宣布开源2千亿稀疏大模型Skywork-MoE&#xff0c;性能强劲&#xff0c;同时推理成本更低。 据「TMT星球」了解&#xff0c;Skywork-MoE基于之前昆仑万维开源的Skywork-13B模型中间checkpoint扩展而来&#xff0c;是首个完整将MoE Upcycling技术应用…

北京Profinet转Modbus网关配置调试详解

一、背景&#xff1a;在工业自动化系统中&#xff0c;PLC&#xff08;可编程逻辑控制器&#xff09;与流量计之间的通信是非常重要的&#xff0c;以确保数据准确传输并实现控制功能。然而&#xff0c;由于PLC和流量计可能采用不同的通信协议&#xff08;如Profinet和Modbus&…

探索Java的DNA-JVM字节码深度解析

引言 在Java的世界里&#xff0c;JVM&#xff08;Java虚拟机&#xff09;是我们程序运行的心脏。而字节码&#xff0c;作为JVM的血液&#xff0c;携带着程序的执行指令。今天&#xff0c;我们将深入探索Java字节码的奥秘&#xff0c;一窥JVM如何将人类可读的代码转化为机器可执…

洛谷 P1438 无聊的数列

题意 给定一个序列 A ( A 1 , A 2 , ⋯ , A n ) A(A_1,A_2,\cdots,A_n) A(A1​,A2​,⋯,An​)。 现在进行 m m m次操作&#xff0c;分为以下两种: 1 l r k d&#xff1a;给定一个长度为 r − l 1 r-l1 r−l1的等差序列&#xff0c;首项为 k k k&#xff0c;公差为 d d d&am…

【小白向】微信小程序解密反编译教程

# 前言 最近笔者有做到微信小程序的渗透测试&#xff0c;其中有一个环节就是对微信小程序的反编译进行源码分析&#xff0c;所谓微信小程序反编译&#xff0c;就是将访问的小程序进行反向编译拿到部分源码&#xff0c;然后对源码进行安全审计&#xff0c;分析出其中可能存在的…

图形学初识--颜色混合

文章目录 前言正文为什么要有颜色混合&#xff1f;颜色混合常见实现方式&#xff1f;上述颜色混合注意点 结尾&#xff1a;喜欢的小伙伴点点关注赞哦! 前言 本章节补充一下颜色混合的内容&#xff0c;主要包含&#xff1a;为什么要有颜色混合&#xff1f;颜色混合常实现方式&a…

BGP——边界网关路由协议

BGP -边界网关路由协议 OSPF RIP EIGRP AS——自治系统 标准编号16位二进制 0-65535 1-64511公有 64512 -私有 扩展编号 32位二进制 动态路由协议: GP ——内部网关路由协议 —— AS之内 或企业网、局域网 RIP OSPF EIGRP EGP-外部网关路由协议 - …

Centos 7 安装刻录至硬件服务器

前言 在日常测试中&#xff0c;会遇到很多安装的场景&#xff0c;今天给大家讲一下centos 7 的安装&#xff0c;希望对大家有所帮助。 一.下载镜像 地址如下&#xff1a; centos官方镜像下载地址https://www.centos.org/download/ 按照需求依次点击下载 二.镜像刻录 镜像刻…

idea springboot woff/woff2/eot/ttf/svg等小图标不显示的问题 - 第515篇

历史文章&#xff08;文章累计500&#xff09; 《国内最全的Spring Boot系列之一》 《国内最全的Spring Boot系列之二》 《国内最全的Spring Boot系列之三》 《国内最全的Spring Boot系列之四》 《国内最全的Spring Boot系列之五》 《国内最全的Spring Boot系列之六》 《…