SpringBoot整合MongoDB

一、环境准备

1、添加 SpringData 依赖：

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>

2、配置 yml 文件

  • 方式一：
spring:data:mongodb:uri: mongodb://root:123456@1.15.76.95:27017/library?authSource=admin
  • 方式二：
spring:data:mongodb:username: rootpassword: 123456host: 1.15.76.95port: 27017database: libraryauthentication-database: admin

3、直接注入 MongoTemplate 进行操作

@Resource
MongoTemplate mongoTemplate;

二、集合操作

@Test
public void testCollection(){boolean exists = mongoTemplate.collectionExists("borrow");if(exists) {// 删除集合mongoTemplate.dropCollection("borrow");}else {// 创建集合mongoTemplate.createCollection("borrow");}Set<String> collectionNames = mongoTemplate.getCollectionNames();System.out.println(collectionNames.toString());  // [borrow, book, user]
}

三、文档操作

3.1 实体类

  • @Document
    • 修饰范围：用在类上。
    • 作用：用来映射这个类的一个对象为 Mongo 中一条文档数据。
    • 属性：(value 、collection) 用来指定操作的集合名称。
  • @MongoId
    • 修饰范围：用在成员变量、方法上。
    • 作用：用来将成员变量的值映射为文档的 _id 的值。
  • @Field
    • 修饰范围：用在成员变量、方法上。
    • 作用：用来将成员变量及其值映射为文档中一个 key:value 对。
    • 属性：(name , value) 用来指定在文档中 key 的名称,默认为成员变量名。
  • @Transient
    • 修饰范围：用在成员变量、方法上。
    • 作用：用来指定此成员变量不参与文档的序列化。
@Data
@AllArgsConstructor
@NoArgsConstructor
@Document("user")
public class User {@MongoIdprivate Integer uid;@Fieldprivate String name;@Fieldprivate String password;@Fieldprivate Integer age;
}

3.2 添加文档

insert 方法返回值是新增的 Document 对象，里面包含了新增后 id 的值。如果集合不存在会自动创建集合。

@Test
public void test1() {// _id存在时更新数据mongoTemplate.save(new User(1, "aaa", "123456", 20));// _id存在时抛出异常mongoTemplate.insert(new User(2, "bbb", "113456", 21));List<User> list = Arrays.asList(new User(3, "ccc", "124266", 22),new User(4, "ddd", "136521", 23),new User(5, "eee", "147258", 24));// 批量插入mongoTemplate.insert(list, User.class);
}

3.3 查询文档

  • Query 类作为查询条件的容器，用于放置 Criteria 条件接口。
  • Criteria 是标准查询的接口，可以引用静态的 Criteria.where() 将字段和条件组合在一起进行查询。
@Test
public void test1() {System.out.println("==========查询所有文档===========");List<User> list = mongoTemplate.findAll(User.class);list.forEach(System.out::println);System.out.println("==========根据_id查询===========");User user = mongoTemplate.findById(3, User.class);System.out.println(user);System.out.println("==========findOne返回第一个文档===========");User one = mongoTemplate.findOne(new Query(), User.class);System.out.println(one);
}

@Test
public void test2() {System.out.println("==========条件查询===========");// 查询name为"eee"的用户Query query1 = new Query(Criteria.where("name").is("eee"));// 查询 age<23 的用户Query query2 = new Query(Criteria.where("age").lt(23));// 查询 21<=age<24 的用户Query query3 = new Query(Criteria.where("age").gte(21).lt(24));// 模糊查询Query query4 = new Query(Criteria.where("password").regex("123"));System.out.println("==========多条件查询===========");// 查询 age<24 且 密码包含"123" 的用户Criteria criteria1 = new Criteria();criteria1.andOperator(Criteria.where("age").lt(24),Criteria.where("password").regex("123"));Query query5 = new Query(criteria1);// 查询 age>23 或 密码包含"456" 的用户Criteria criteria2 = new Criteria();criteria2.orOperator(Criteria.where("age").gt(23), Criteria.where("password").regex("456"));Query query6 = new Query(criteria2);List<User> list = mongoTemplate.find(query6, User.class);list.forEach(System.out::println);
}
@Test
public void test3() {System.out.println("==========排序===========");Query query1 = new Query();query1.with(Sort.by(Sort.Order.desc("age")));System.out.println("==========分页===========");Query query2 = new Query();query2.skip(0).limit(3);List<User> list = mongoTemplate.find(query2, User.class);list.forEach(System.out::println);
}
  • 使用 JSON 字符串方式查询：
@Test
public void testFindByJson() {// 等值查询Query query1 = new BasicQuery("{name:'eee'}");// 多条件查询Query query2 = new BasicQuery("{age:{$lt:24}, password:{$regex:'123'}}");Query query3 = new BasicQuery("{$or:[{age:{$gt:23}}, {password:{$regex:'456'}}]}");List<User> list = mongoTemplate.find(query3, User.class);list.forEach(System.out::println);
}

3.4 修改文档

在 Mongodb 中无论是使用客户端 API 还是使用 Spring Data，更新返回结果一定是受行数影响。如果更新后的结果和更新前的结果是相同，返回 0。

  • updateFirst()：只更新满足条件的第一条记录。
  • updateMulti()：更新所有满足条件的记录。
  • upsert()：没有符合条件的记录则插入数据。
@Test
public void test1() {Query query = new Query(Criteria.where("name").is("eee"));Update update = new Update();update.set("age", 25);// updateFirst() 只更新满足条件的第一条记录UpdateResult updateResult = mongoTemplate.updateFirst(query, update, User.class);System.out.println("返回修改的记录数: " + updateResult.getModifiedCount());
}

@Test
public void test2() {Query query = new Query(Criteria.where("age").gt(23));Update update = new Update();update.inc("age", 1);// updateMulti() 更新所有满足条件的记录UpdateResult updateResult = mongoTemplate.updateMulti(query, update, User.class);System.out.println("返回修改的记录数: " + updateResult.getModifiedCount());
}

@Test
public void test3() {// query查询结果不存在Query query = new Query(Criteria.where("name").is("ggg"));Update update = new Update();update.set("age", 28);update.setOnInsert("_id", 7); //不存在时插入// upsert() 没有符合条件的记录则插入数据UpdateResult updateResult = mongoTemplate.upsert(query, update, User.class);System.out.println("返回修改的记录数: " + updateResult.getModifiedCount());
}

3.5 删除文档

@Test
public void testDelete() {//删除所有文档, 不如用dropCollection()//mongoTemplate.remove(new Query(),Employee.class);//条件删除Query query = new Query(Criteria.where("name").is("fff"));mongoTemplate.remove(query, User.class);
}

四、聚合操作

4.1 使用 Aggregation 实现

用 Aggregation 集合接收聚合操作，用 MongoTemplate 对象直接调用 aggregate，传入聚合操作集合、表名、映射对象。

@Test
public void testAggregation() {// 1.先定义聚合操作MatchOperation match = Aggregation.match(Criteria.where("type").is("novel"));SortOperation sort = Aggregation.sort(Sort.Direction.ASC, "favCount");// 2.按顺序组合每一个聚合步骤TypedAggregation<Book2> typedAggregation = Aggregation.newAggregation(Book2.class, match, sort);// 3.执行聚合操作, 可以使用 Document、Map、自定义实体类 接收结果AggregationResults<Document> aggregate = mongoTemplate.aggregate(typedAggregation, Document.class);List<Document> results = aggregate.getMappedResults();results.forEach(System.out::println);
}

4.2 使用 Aggregates 实现

用 Aggregates 和 Bson 构建聚合操作对象，用预先生成的 MongoCollection 对象调用 aggregate 执行。

@Test
public void testAggregates(){// 1.先通过集合名拿到所有文档MongoCollection<Document> collection = mongoTemplate.getCollection("book2");// 2.Aggregates提供各种聚合操作符，返回一个Bson对象Bson matchBson = Aggregates.match(new Document("type", "travel"));
//	Bson matchBson = Aggregates.match(Filters.eq("type", "travel"));//Filters来实现过滤Bson sortBson = Aggregates.sort(Sorts.ascending("favCount"));
//	Bson sortBson = Aggregates.sort(new Document("favCount", 1));// 3.构建一个List<Bson>, 并把每一个聚合操作按顺序加进去List<Bson> bsonList = new ArrayList<>();bsonList.add(matchBson);bsonList.add(sortBson);// 4.最后传入aggregate方法中执行，并且接收结果集AggregateIterable<Document> resultList = collection.aggregate(bsonList);resultList.forEach(System.out::println);
}
  • 示例一：统计文档中的书籍总量、收藏总数、平均收藏量
@Test
public void test1() {MongoCollection<Document> collection = mongoTemplate.getCollection("book2");Bson groupBson = Aggregates.group(null,Accumulators.sum("bookCount", 1),Accumulators.sum("favCount", "$favCount"),Accumulators.avg("favAvg", "$favCount"));List<Bson> bsonList = new ArrayList<>();bsonList.add(groupBson);AggregateIterable<Document> resultList = collection.aggregate(bsonList);resultList.forEach(System.out::println);
}
  • 示例二：统计tag标签的热度排行 (根据favCount总量排行即为热度)
@Test
public void test4() {MongoCollection<Document> collection = mongoTemplate.getCollection("book2");Bson unwindBson = Aggregates.unwind("$tag");Bson groupBson = Aggregates.group("$tag", Accumulators.sum("favCount", "$favCount"));Bson sortBson = Aggregates.sort(new Document("favCount", -1));List<Bson> bsonList = new ArrayList<>();bsonList.add(unwindBson);bsonList.add(groupBson);bsonList.add(sortBson);AggregateIterable<Document> resultList = collection.aggregate(bsonList);resultList.forEach(System.out::println);
}

4.3 应用案例

  • 示例一：统计每个作者的每本book的收藏数
@Test
public void test1() {GroupOperation group = Aggregation.group("$author.name", "$title").sum("$favCount").as("favCount");TypedAggregation<Book2> typedAggregation = Aggregation.newAggregation(Book2.class, group);AggregationResults<Document> aggregate = mongoTemplate.aggregate(typedAggregation, Document.class);List<Document> mappedResults = aggregate.getMappedResults();mappedResults.forEach(System.out::println);
}
  • 示例二：每个作者的book的tag合集
@Test
public void test2() {UnwindOperation unwind = Aggregation.unwind("$tag");GroupOperation group = Aggregation.group("$author.name").addToSet("$type").as("types");TypedAggregation<Book2> typedAggregation = Aggregation.newAggregation(Book2.class, unwind, group);AggregationResults<Document> aggregate = mongoTemplate.aggregate(typedAggregation, Document.class);List<Document> mappedResults = aggregate.getMappedResults();mappedResults.forEach(System.out::println);
}
  • 示例三：联表查询用户以及对应的订单信息
@Test
public void test1() {LookupOperation lookup = Aggregation.lookup("order", "_id", "customerId", "order");TypedAggregation<Customer> orderTypedAggregation = Aggregation.newAggregation(Customer.class, lookup);AggregationResults<Document> aggregate = mongoTemplate.aggregate(orderTypedAggregation, Document.class);List<Document> mappedResults = aggregate.getMappedResults();mappedResults.forEach(System.out::println);
}
  • 示例四：联表查询订单信息以及对应的商品项
@Test
public void test2() {LookupOperation lookup = Aggregation.lookup("orderItem", "_id", "orderId", "orderItem");TypedAggregation<Order> orderItemTypedAggregation = Aggregation.newAggregation(Order.class, lookup);AggregationResults<Document> aggregate = mongoTemplate.aggregate(orderItemTypedAggregation, Document.class);List<Document> mappedResults = aggregate.getMappedResults();mappedResults.forEach(System.out::println);
}

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

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

相关文章

新手安装Anaconda与Miniconda怎么选？

新手安装Anaconda与Miniconda怎么选？

Python使用者的一大挑战是库的管理和环境的隔离&#xff0c; 常使用分布式管理系统&#xff0c;如Anaconda或Miniconda。接下来将探讨一下这两者的相似之处、差异和应用场景。 1、Anaconda和Miniconda的基本情况 Anaconda和Miniconda都是Continuum Analytics的开源项目&#x…
阅读更多...
boost::throw_exception错误：修改VS代码生成异常选项为/EHsc

boost::throw_exception错误：修改VS代码生成异常选项为/EHsc

VS2013添加boost头文件和库文件路径后&#xff0c;代码编译报错&#xff1a; 错误 LNK2019 无法解析的外部符号 “void __cdecl boost::throw_exception(class std::exception const &)” (?throw_exceptionboostYAXAEBVexceptionstdZ)&#xff0c;该符号在函数 “public:…
阅读更多...
uniapp打包的h5项目多了接口调用https://api.next.bspapp.com/client

uniapp打包的h5项目多了接口调用https://api.next.bspapp.com/client

产生跨域问题。 这个实际上是因为该项目在manifest.json文件中勾选了‘uni统计配置’导致的&#xff0c;取消勾选就可以了。 如果是小程序项目&#xff0c;在小程序开发者工具中添加可信任域名就可以了。 可以看看下面这个链接内容 uni-app H5跨域问题解决方案&#xff08;…
阅读更多...
Python实现股票回测框架搭建，回测交易策略可行性。

Python实现股票回测框架搭建，回测交易策略可行性。

文章目录 什么是回测框架?回测框架交易历史数据回测报告回测示例关于Python技术储备一、Python所有方向的学习路线二、Python基础学习视频三、精品Python学习书籍四、Python工具包项目源码合集①Python工具包②Python实战案例③Python小游戏源码五、面试资料六、Python兼职渠道…
阅读更多...
建设纺织企业安全生产风险管控平台，降低生产风险

建设纺织企业安全生产风险管控平台，降低生产风险

纺织行业是一个传统的行业&#xff0c;近年来面临着市场竞争加剧、成本压力上升、环保要求提高等挑战。纺织行业未来的发展需要紧跟市场需求和行业趋势&#xff0c;通过技术创新、消费升级、智能化生产、绿色环保和多元化市场等策略&#xff0c;提高产品附加值和市场竞争力&…
阅读更多...
Footprint Analytics x Future3 万字研报：AI 与 Web3 数据行业融合的现状、竞争格局与未来机遇探析（上）

Footprint Analytics x Future3 万字研报：AI 与 Web3 数据行业融合的现状、竞争格局与未来机遇探析（上）

GPT的横空出世将全球的目光吸引至大语言模型&#xff0c;各行各业都尝试着利用这个“黑科技”提高工作效率&#xff0c;加速行业发展。Future3 Campus携手Footprint Analytics共同深入研究AI与Web3结合的无限可能&#xff0c;联合发布了《AI与Web3数据行业融合现状、竞争格局与…
阅读更多...
写给初学者的 HarmonyOS 教程 -- 页面路由（router）

写给初学者的 HarmonyOS 教程 -- 页面路由（router）

页面路由&#xff08;router&#xff09;是指在应用程序中实现不同页面之间的跳转和数据传递。 HarmonyOS 提供了 Router 模块&#xff0c;通过不同的 url 地址&#xff0c;可以方便地进行页面路由&#xff0c;轻松地访问不同的页面。 类似这样的效果&#xff1a; 页面跳转是…
阅读更多...
香港服务器时间不准，差8小时

香港服务器时间不准，差8小时

解决方案1 1、timedatectl查看系统时间 2、查看系统时区 ls /usr/share/zoneinfo 3、删除当前系统所处时区 rm /etc/localtime 4、创建软链接&#xff0c;以替换当前的时区信息 ln -s /usr/share/zoneinfo/Universal /etc/localtime 解决方案2 手动设置硬件时钟 1、设置系…
阅读更多...
Hadoop学习笔记（HDP）-Part.15 安装HIVE

Hadoop学习笔记（HDP）-Part.15 安装HIVE

目录 Part.01 关于HDP Part.02 核心组件原理 Part.03 资源规划 Part.04 基础环境配置 Part.05 Yum源配置 Part.06 安装OracleJDK Part.07 安装MySQL Part.08 部署Ambari集群 Part.09 安装OpenLDAP Part.10 创建集群 Part.11 安装Kerberos Part.12 安装HDFS Part.13 安装Ranger …
阅读更多...
【MODBUS】libmodbus库从Modbus从站读取值

【MODBUS】libmodbus库从Modbus从站读取值

libmodbus库提供了许多示例代码&#xff0c;用于演示如何使用该库进行Modbus通信。以下是一个简单的libmodbus库示例&#xff0c;用于从Modbus从站读取保持寄存器&#xff08;holding registers&#xff09;的值&#xff1a; #include <stdio.h> #include <stdlib.…
阅读更多...
【蓝桥杯选拔赛真题28】C++口罩分配 第十三届蓝桥杯青少年创意编程大赛C++编程选拔赛真题解析

【蓝桥杯选拔赛真题28】C++口罩分配 第十三届蓝桥杯青少年创意编程大赛C++编程选拔赛真题解析

目录 C/C++口罩分配 一、题目要求 1、编程实现 2、输入输出
阅读更多...
11.Java Spring

11.Java Spring

11.1Spring基础(核心概念,创建和使用,简单读取) 11.2SpringBoot 11.3SpringMVC 11.4MyBatis(基础) 11.5MyBatis(进阶) 11.6AOP 11.7统一功能处理 11.8事务 11.9密码加密,加盐算法(手动实现) 11.10Redis基础​​​​​​​
阅读更多...
uniapp中wx.getSystemInfoSync() 或 wx.getSystemInfo() 踩坑

uniapp中wx.getSystemInfoSync() 或 wx.getSystemInfo() 踩坑

可以通过 wx.getSystemInfoSync() 或 wx.getSystemInfo() 方法获取设备的信息&#xff0c;其中包括 User-Agent。wx.getSystemInfoSync() 方法是同步获取设备信息&#xff0c;返回值是一个对象&#xff0c;包含了设备的详细信息&#xff0c;如系统版本、屏幕宽高等。wx.getSyst…
阅读更多...
今日实施｜解读新国标对数据库审计的能力要求

今日实施｜解读新国标对数据库审计的能力要求

数据库审计是数据安全建设不可或缺的技术工具之一&#xff0c;无论是国家级的法律或标准&#xff0c;还是等保以及行业级的安全标准均对使用数据库审计有明确要求。据相关数据统计显示&#xff0c;数据库审计产品的市场需求已占据中国数据库安全市场容量的6成以上。 12月1日&am…
阅读更多...
黑豹程序员-java发邮件，发送内容支持html，带多附件的案例

黑豹程序员-java发邮件，发送内容支持html，带多附件的案例

介绍 发邮件mail是常见的软件功能&#xff0c;下面利于spring和java的mail库实现发送内容支持html&#xff0c;带多附件的案例 开启SMTP邮件发送协议 谁提供的SMTP邮件服务&#xff0c;就找谁开启。QQ邮箱类似。 依赖 <!--Java MAil 发送邮件API--><dependency&g…
阅读更多...
Linux 进程优先级

Linux 进程优先级

什么是进程的优先级 优先级&#xff1a;对资源的访问顺序&#xff01;注意优先级与权限的区别&#xff0c;优先级决定的是访问资源的顺序&#xff0c;这意味着无论是谁都可以访问到资源&#xff1b;但是如果你没有权限&#xff0c;你是不能访问资源的&#xff01; 这个应该比较…
阅读更多...
el-date-picker时间控制范围为过去时间不可选

el-date-picker时间控制范围为过去时间不可选

<el-date-picker :picker-options"startPickerOptions()" value-format"yyyy-MM-dd HH:mm:ss" v-model"form.applyFixPlan" type"datetime" placeholder"选择日期时间"> </el-date-picker> 在method中定义star…
阅读更多...
c++ 三目运算符在类中的使用

c++ 三目运算符在类中的使用

简介 在类比较方面&#xff0c;三目运算符可以用于重载比较运算符。 代码示例1 #include <iostream> #include <cstring>class Person { public:Person(const char* name, int age) : m_age(age) {m_name new char[strlen(name) 1];strcpy(m_name, name);}~Pe…
阅读更多...
SiR-NHS酯偶联物：用于细胞过程定量分析 星戈瑞

SiR-NHS酯偶联物：用于细胞过程定量分析 星戈瑞

SiR-NHS酯**(源自星戈瑞的花菁染料)**染料的偶联物通常被用于细胞过程的定量分析&#xff0c;这些偶联物是通过将SiR-NHS酯染料与特定的生物分子或分子结构结合而制备的。这些偶联物可用于定量分析细胞内的不同过程&#xff0c;例如蛋白质的定位、分布、表达水平等。以下是一些…
阅读更多...
HNU-电路与电子学-未知年份（不含解析）

HNU-电路与电子学-未知年份（不含解析）

【写在前面】 电路与电子学好像是从2020级开设的课程&#xff0c;故实际上目前只有2020与2021两个年级考过期末考试。 这门课程主要由所谓的“数电”与“模电”组成。而且先学的“模电”后学的“”数电&#xff0c;故期中考试主要以“模电”为主&#xff0c;期末考试主要以“…
阅读更多...
最新文章

Copyright @ 2022~2023