devbox
你好赵伟
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

【MongoDB】万字长文，命令与代码一一对应SpringBoot整合MongoDB之MongoTemplate

作者：你好赵伟 | 2024-07-16 13:51:17

赞

踩

mongotemplate

目录

一、导入依赖与配置信息

二、导入测试数据创建实体类

三、插入数据

1、Insert默认集合插入

2、Insert指定集合插入 

3、Insert批量插入数据 

 4、save默认集合插入

5、save指定集合插入 

6、insert与save的区别 

四、修改数据

1、修改符合条件的第一条数据

2、全部修改

五、删除数据

1、删除满足条件的所有文档

2、删除集合里所有文档

3、删除满足条件的单个文档并返回

4、删除满足条件的所有文档并返回

六、查找数据

1、查询全部文档

2、查询指定id的文档

3、查询满足条件的一条文档

4、查询满足条件的所有文档

5、And查询

6、Or查询

7、In查询

8、比较查询

9、正则查询

10、排序查询

11、分页查询

12、统计查询

一、导入依赖与配置信息

首先我们需要在项目中导入所需要的依赖，有两种方式：在项目创建之初选择对应的依赖

image.png

如果项目已经创建则在pom.xml文件中加入以下依赖

  1.         <dependency>
  2. 			<groupId>org.springframework.boot</groupId>
  3. 			<artifactId>spring-boot-starter-data-mongodb</artifactId>
  4. 		</dependency>

在依赖导入后，我们需要在项目的配置文件中配置相对应的信息

spring:
  data:
    mongodb:
      host: IP
      port: 27017
      database: 数据库

二、导入测试数据创建实体类

在MongoDB中导入数据

db.comment.insertMany([{_id:"1",nickname:"zs",content:"这是一本好书",userId:1,createTime:"2021-01-01T00:00:00",like:1,parentId:0},{_id:"2",nickname:"ls",content:"可是一本好书",userId:2,createTime:"2021-01-01T12:00:00",like:11,parentId:0},{_id:"3",nickname:"ls",content:"不是一本好书",userId:2,createTime:"2021-01-11T12:00:00",like:111,parentId:0}])

创建对应的实体类

  1. package com.example.demo.pojo.mongodbVo;
  2.  
  3. import lombok.Data;
  4. import org.springframework.data.annotation.Id;
  5. import org.springframework.data.mongodb.core.index.Indexed;
  6. import org.springframework.data.mongodb.core.mapping.Document;
  7.  
  8. import java.io.Serializable;
  9. import java.time.LocalDateTime;
  10.  
  11. @Data
  12. @Document(collection = "comment")
  13. public class Comment implements Serializable {
  14.     @Id
  15.     private String id;
  16.     private String nickname;
  17.     private String content;
  18.     @Indexed
  19.     private Integer userId;
  20.     private LocalDateTime createTime;
  21.     private Integer like;
  22.     private Integer parentId;
  23. }

三、插入数据

1、Insert默认集合插入

命令：db.comment.insert({_id:"4",nickname:"ww",content:"这位是谁啊",userId:3,createTime:……})

这种方式插入数据会插入到实体类上Document注解对应的集合中

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         Comment comment = new Comment("4","ww","这位是谁啊",3, LocalDateTime.now(),1,0);
  9.         mongoTemplate.insert(comment);
  10.     }
  11. }

2、Insert指定集合插入 

命令：db.comment.insert({})

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 构建数据
  9.         Comment comment = new Comment("5","ww","这位是老师",3, LocalDateTime.now(),1,0);
  10.         // 2. 存储数据库
  11.         mongoTemplate.insert(comment,"comment");
  12.     }
  13. }

3、Insert批量插入数据 

命令：db.comment.insert([{},{}])

使用insert进行批量插入时必须指定集合名

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 构建数据
  9.         Comment comment1 = new Comment("4","ww","这位是老师啊",3, LocalDateTime.now(),1,0);
  10.         Comment comment2 = new Comment("6","ww","这位是啊",3, LocalDateTime.now(),1,0);
  11.         List<Comment> list = new ArrayList<>();
  12.         list.add(comment1);
  13.         list.add(comment2);
  14.  
  15.         // 2. 存储数据库
  16.         mongoTemplate.insert(list,"comment");
  17.     }
  18. }

 4、save默认集合插入

命令：db.comment.save({})

使用save进行插入时会根据id进行判断，如果要插入数据中的id在数据库存在，则会将旧的数据覆盖，如果不存在则插入数据

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 构建数据
  9.         Comment comment = new Comment("4","ww","这位是老师啊12",3, LocalDateTime.now(),1,0);
  10.       
  11.  
  12.         // 2. 存储数据库
  13.         mongoTemplate.save(comment);
  14.     }
  15. }

5、save指定集合插入 

命令：db.comment.save({})

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 构建数据
  9.         Comment comment = new Comment("4","ww","这位是老师啊12",3, LocalDateTime.now(),1,0);
  10.       
  11.  
  12.         // 2. 存储数据库
  13.         mongoTemplate.save(comment,"comment");
  14.     }
  15. }

6、insert与save的区别 

在MongoTemplate中，save()和insert()方法有以下区别：

  1. save()方法：save()方法用于插入新文档或更新现有文档。如果要保存的文档没有id字段，将插入一个新文档。如果文档具有id字段，MongoDB将尝试使用匹配的id值更新文档。如果找不到具有匹配id的文档，则插入一个新文档。
     
  2. insert()方法：insert()方法用于向集合中插入新文档。如果要插入的文档已经具有id字段，并且集合中已经存在具有相同id值的文档，则会抛出异常。这确保插入的文档具有唯一的_id值。

    总结：save()方法用于插入和更新操作，而insert()方法专门用于插入新文档，并确保_id字段的唯一性。

四、修改数据

1、修改符合条件的第一条数据

命令：db.comment.update({},{})

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 构建更新的数据
  9.         Comment comment = new Comment("4","ww","这位是老师啊12",3, LocalDateTime.now(),1,0);
  10.  
  11.         // 2. 构建更新的条件
  12.         Query query = new Query(Criteria.where("id").is(comment.getId()));
  13.  
  14.         // 3. 构建更新值
  15.         Update update = new Update().set("content",comment.getContent()).set("createTime",comment.getCreateTime());
  16.  
  17.         // 4. 更新第一条满足条件的数据
  18.         UpdateResult updateResult = mongoTemplate.updateFirst(query, update, Comment.class);
  19.  
  20.         // 5. 判断是否更新
  21.         System.out.println(update);
  22.     }
  23. }

2、全部修改

命令：db.comment.update({},{},{multi:true})

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 构建更新的数据
  9.         Comment comment = new Comment("4","ww","修改全部数据",3, LocalDateTime.now(),1,0);
  10.  
  11.         // 2. 构建更新的条件
  12.         Query query = new Query(Criteria.where("nickname").is(comment.getNickname()));
  13.  
  14.         // 3. 构建更新值
  15.         Update update = new Update().set("content",comment.getContent()).set("createTime",comment.getCreateTime());
  16.  
  17.         // 4. 更新第一条满足条件的数据
  18.         UpdateResult updateResult = mongoTemplate.updateMulti(query, update, Comment.class);
  19.  
  20.         // 5. 判断是否更新
  21.         System.out.println(update);
  22.     }
  23. }

五、删除数据

1、删除满足条件的所有文档

命令：db.comment.remove({})

  1.  
  2. @SpringBootTest
  3. class CommentServiceTest {
  4.     @Autowired
  5.     private MongoTemplate mongoTemplate;
  6.  
  7.     @Test
  8.     void testInsert() {
  9.         // 1. 构建筛选条件
  10.         Query query = new Query(Criteria.where("userId").is(2));
  11.  
  12.         // 2. 执行删除操作
  13.         DeleteResult remove = mongoTemplate.remove(query, Comment.class);
  14.     }
  15. }

2、删除集合里所有文档

命令：db.comment.remove({})

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 执行删除操作
  9.         DeleteResult remove = mongoTemplate.remove(new Query(), Comment.class);
  10.     }
  11. }

3、删除满足条件的单个文档并返回

命令：db.comment.remove({})

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 构建删除条件
  9.         Query query = new Query(Criteria.where("userId").is(1));
  10.  
  11.         // 2. 删除数据接收返回的文档
  12.         Comment andRemove = mongoTemplate.findAndRemove(query, Comment.class);
  13.  
  14.         // 3. 打印删除的文档
  15.         System.out.println(andRemove);
  16.     }
  17. }

4、删除满足条件的所有文档并返回

命令：db.comment.remove({})

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 删除所有满足条件并返回
  9.         List<Comment> comments = mongoTemplate.findAllAndRemove(new Query(Criteria.where("userId").is(3)), Comment.class);
  10.  
  11.         // 2. 打印删除
  12.         System.out.println(comments);
  13.     }
  14. }

六、查找数据

1、查询全部文档

命令：db.comment.find()

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 查询全部文档
  9.         List<Comment> comments = mongoTemplate.findAll(Comment.class);
  10.         // 2. 打印结果
  11.         System.out.println(comments);
  12.     }
  13. }

2、查询指定id的文档

命令：db.comment.find({_id:"id"})

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 查询文档
  9.         Comment comment = mongoTemplate.findById("1", Comment.class);
  10.         // 2. 打印结果
  11.         System.out.println(comment);
  12.     }
  13. }

3、查询满足条件的一条文档

命令：db.comment.findOne({})

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 查询文档
  9.         Comment comment = mongoTemplate.findOne(new Query(Criteria.where("nickname").is("ww")),Comment.class);
  10.         // 2. 打印结果
  11.         System.out.println(comment);
  12.     }
  13. }

4、查询满足条件的所有文档

命令：db.comment.find({})

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 查询文档
  9.         List<Comment> comments = mongoTemplate.find(new Query(Criteria.where("nickname").is("ww")),Comment.class);
  10.         // 2. 打印结果
  11.         System.out.println(comments);
  12.     }
  13. }

5、And查询

命令：db.comment.find({$and:[{},{}]})

  1. @SpringBootTest
  2. public class PersonServiceTest {
  3.  
  4.     @Autowired
  5.     private MongoTemplate mongoTemplate;
  6.  
  7.     @Test
  8.     public void findByAndCondition() {
  9.         // 1.创建将要and的条件
  10.         Criteria criteriaNickName = Criteria.where("nickame").is("ww");
  11.         Criteria criteriaLike = Criteria.where("like").is(1);
  12.         // 2.将上面条件进行and关联
  13.         Criteria criteria = new Criteria().andOperator(criteriaNickName, criteriaLike);
  14.         // 3.条件对象添加到其中
  15.         Query query = new Query(criteria);
  16.         List<Comment> result = mongoTemplate.find(query, Comment.class);
  17.         System.out.println("查询结果：" + result.toString());
  18.     }
  19. }

6、Or查询

命令：db.comment.find({$or:[{},{}]})

下面代码简写，具体可参照上述and写法，效果一致

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 查询文档
  9.         List<Comment> comments = mongoTemplate.find(new Query(
  10.                 new Criteria().orOperator(
  11.                         Criteria.where("nickname").is("ww"),
  12.                         Criteria.where("like").is(10)
  13.                 )
  14.         ), Comment.class);
  15.         // 2. 打印结果
  16.         System.out.println(comments);
  17.     }
  18. }

7、In查询

命令：db.comment.find({count:{$in:[11,12]}})

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 查询文档
  9.         List<Integer> ins = Arrays.asList(1,0,2);
  10.         List<Comment> comments = mongoTemplate.find(new Query(Criteria.where("like").in(ins)), Comment.class);
  11.         
  12.         // 2. 打印结果
  13.         System.out.println(comments);
  14.     }
  15. }

8、比较查询

命令：db.comment.find({ "like": { $gt: 0, $lt: 5 } })

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 查询文档
  9.         Query query = new Query(Criteria.where("like").gt(0).lt(5));   // 查询大于0小于5
  10.         List<Comment> comments = mongoTemplate.find(query, Comment.class);
  11.  
  12.         // 2. 打印结果
  13.         System.out.println(comments);
  14.     }
  15. }

9、正则查询

命令：db.collectionName.find({ "nickname": { $regex: '^w' } })

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 查询文档
  9.         List<Comment> comments = mongoTemplate.find(new Query(Criteria.where("nickname").regex("^w")), Comment.class);  // 查询nickname中w开头的数据
  10.  
  11.         // 2. 打印结果
  12.         System.out.println(comments);
  13.     }
  14. }

10、排序查询

命令：db.collectionName.find({ "nickname": "ww" }).sort({ "like": 1 })

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 查询文档
  9.         Query query = new Query(Criteria.where("nickname").is("ww")).with(Sort.by("id").descending());
  10.         List<Comment> comments = mongoTemplate.find(query, Comment.class);
  11.  
  12.         // 2. 打印结果
  13.         System.out.println(comments);
  14.     }
  15. }

 

11、分页查询

命令：db.comment.find({}).skip(2).limit(2)

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 查询文档
  9.         Query query = new Query(Criteria.where("nickname").is("ww")).skip(2).limit(2);
  10.         List<Comment> comments = mongoTemplate.find(query, Comment.class);
  11.  
  12.         // 2. 打印结果
  13.         System.out.println(comments);
  14.     }
  15. }

12、统计查询

命令：db.comment.count({})

  1. @SpringBootTest
  2. class CommentServiceTest {
  3.     @Autowired
  4.     private MongoTemplate mongoTemplate;
  5.  
  6.     @Test
  7.     void testInsert() {
  8.         // 1. 查询文档
  9.         Query query = new Query(Criteria.where("nickname").is("ww"));
  10.         long count = mongoTemplate.count(query, Comment.class);
  11.  
  12.         // 2. 打印结果
  13.         System.out.println(count);
  14.     }
  15. }

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/你好赵伟/article/detail/834491
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号