本站消息

站长简介/公众号

  出租广告位,需要合作请联系站长


+关注
已关注

分类  

暂无分类

标签  

暂无标签

日期归档  

2024-11(1)

Mongodb操作与Java(四)MongoTemplate的使用

发布于2024-11-02 10:14     阅读(495)     评论(0)     点赞(4)     收藏(2)


目录

mongoClient和MongoTemplate二者区别

代码实践

配置

SpringBoot 工程依赖和配置

准备代码

创建实体类

新增 

插入文档

存储文档

更新

删除文档

查询

事务


前言-与正文无关

​    生活远不止眼前的苦劳与奔波,它还充满了无数值得我们去体验和珍惜的美好事物。在这个快节奏的世界中,我们往往容易陷入工作的漩涡,忘记了停下脚步,感受周围的世界。让我们一起提醒自己,要适时放慢脚步,欣赏生活中的每一道风景,享受与家人朋友的温馨时光,发现那些平凡日子里隐藏的幸福时刻。因为,这些点点滴滴汇聚起来的,才是构成我们丰富多彩生活的本质。希望每个人都能在繁忙的生活中找到自己的快乐之源,不仅仅为了生存而工作,更为了更好的生活而生活.

​       送你张美图!希望你开心!

mongoClientMongoTemplate二者区别

Springboot 操作 MongoDB 有两种方式。

第一种方式是采用 Springboot 官方推荐的 JPA 方式,这种操作方式,使用简单但是灵活性比较差。也就是MongoClient

第二种方式是采用 Spring Data MongoDB 基于 MongoDB 官方 Java API 封装的 MongoTemplate 操作类对 MongoDB 进行操作,这种方式非常灵活,能满足绝大部分需求。也就是MongoTemplate

本文将采用第二种方式进行介绍!

MongoClient

MongoClient 是 MongoDB 官方 Java 驱动库提供的类。可以理解为是mysql的Jdbc框架,它直接与 MongoDB 服务器进行通信,负责建立连接、发送查询和命令以及接收响应。使用 MongoClient 通常涉及到编写比较底层的代码。你需要自己管理连接、编写查询语句、处理结果集等。它提供了与 MongoDB 交互的最大灵活性,允许你执行几乎所有类型的数据库操作,包括那些 Spring Data MongoDB 可能尚未提供支持的操作。

MongoTemplate

定义MongoTemplate 是 Spring Data MongoDB 提供的一个高级抽象,它封装了 MongoClient,提供了一个更高层次的模板方法 API 来简化 MongoDB 的操作。可以理解为是mysql的Mybatis框架。MongoTemplate 提供了相对简单的方法来执行查询、更新、删除等操作,同时集成了 Spring 的转换和异常处理机制。使用 MongoTemplate,你不需要关心低层次的数据库连接和错误处理。

代码实践

配置

SpringBoot 工程依赖和配置

  1. <!-- 引入springboot -->
  2. <parent>
  3. <groupId>org.springframework.boot</groupId>
  4. <artifactId>spring-boot-starter-parent</artifactId>
  5. <version>2.1.0.RELEASE</version>
  6. </parent>
  7. <dependency>
  8. <groupId>org.springframework.boot</groupId>
  9. <artifactId>spring-boot-starter-data-mongodb</artifactId>
  10. </dependency>

添加配置文件

在application.properties文件中添加mongodb相关配置!

#配置数据库连接地址
spring.data.mongodb.uri=mongodb://userName:password@127.0.0.1:27017/dbName

  • userName:表示用户名,根据实际情况填写即可

  • password:表示用户密码,根据实际情况填写即可

  • dbName:表示数据库,可以自定义,初始化数据的时候,会自动创建

准备代码

创建实体类

创建一个实体类Person,其中注解@Document(collection="persons")表示当前实体类对应的集合名称是persons,类似于关系型数据库中的表名称。

注解@Id表示当前字段,在集合结构中属于主键类型。

  1. /**
  2. * 使用@Document注解指定集合名称
  3. */
  4. @Document(collection="persons")
  5. public class Person implements Serializable {
  6. private static final long serialVersionUID = -3258839839160856613L;
  7. /**
  8. * 使用@Id注解指定MongoDB中的 _id 主键
  9. */
  10. @Id
  11. private Long id;
  12. private String userName;
  13. private String passWord;
  14. private Integer age;
  15. private Date createTime;
  16. //...get/set
  17. @Override
  18. public String toString() {
  19. return "Person{" +
  20. "id=" + id +
  21. ", userName='" + userName + '\'' +
  22. ", passWord='" + passWord + '\'' +
  23. ", age=" + age +
  24. ", createTime=" + createTime +
  25. '}';
  26. }
  27. }

新增 

插入文档

MongoTemplate提供了insert()方法,用于插入文档,示例代码如下:

  • 用于插入文档

没指定集合名称时,会取 @Document注解中的集合名称

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 插入文档
  8. * @throws Exception
  9. */
  10. @Test
  11. public void insert() throws Exception {
  12. Person person =new Person();
  13. person.setId(1l);
  14. person.setUserName("张三");
  15. person.setPassWord("123456");
  16. person.setCreateTime(new Date());
  17. mongoTemplate.insert(person);
  18. }
  19. }
  • 自定义集合名称,插入文档

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 自定义集合,插入文档
  8. * @throws Exception
  9. */
  10. @Test
  11. public void insertCustomCollection() throws Exception {
  12. Person person =new Person();
  13. person.setId(1l);
  14. person.setUserName("张三");
  15. person.setPassWord("123456");
  16. person.setCreateTime(new Date());
  17. mongoTemplate.insert(person, "custom_person");
  18. }
  19. }
如果采用批量插入文档,必须指定集合名称
  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 自定义集合,批量插入文档
  8. * @throws Exception
  9. */
  10. @Test
  11. public void insertBatch() throws Exception {
  12. List<Person> personList = new ArrayList<>();
  13. Person person1 =new Person();
  14. person1.setId(10l);
  15. person1.setUserName("张三");
  16. person1.setPassWord("123456");
  17. person1.setCreateTime(new Date());
  18. personList.add(person1);
  19. Person person2 =new Person();
  20. person2.setId(11l);
  21. person2.setUserName("李四");
  22. person2.setPassWord("123456");
  23. person2.setCreateTime(new Date());
  24. personList.add(person2);
  25. mongoTemplate.insert(personList, "custom_person");
  26. }
  27. }
存储文档

MongoTemplate提供了save()方法,用于存储文档。

在存储文档的时候会通过主键 ID 进行判断,如果存在就更新,否则就插入,示例代码如下:

  • 存储文档,如果没有插入,否则通过主键ID更新

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 存储文档,如果没有插入,否则更新
  8. * @throws Exception
  9. */
  10. @Test
  11. public void save() throws Exception {
  12. Person person =new Person();
  13. person.setId(13l);
  14. person.setUserName("八八");
  15. person.setPassWord("123456");
  16. person.setAge(40);
  17. person.setCreateTime(new Date());
  18. mongoTemplate.save(person);
  19. }
  20. }
  • 自定义集合,存储文档

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 自定义集合,存储文档
  8. * @throws Exception
  9. */
  10. @Test
  11. public void saveCustomCollection() throws Exception {
  12. Person person =new Person();
  13. person.setId(1l);
  14. person.setUserName("张三");
  15. person.setPassWord("123456");
  16. person.setCreateTime(new Date());
  17. mongoTemplate.save(person, "custom_person");
  18. }
  19. }

更新

MongoTemplate提供了updateFirst()和updateMulti()方法,用于更新文档,示例代码如下:

  • 更新文档,匹配查询到的文档数据中的第一条数据

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 更新文档,匹配查询到的文档数据中的第一条数据
  8. * @throws Exception
  9. */
  10. @Test
  11. public void updateFirst() throws Exception {
  12. //更新对象
  13. Person person =new Person();
  14. person.setId(1l);
  15. person.setUserName("张三123");
  16. person.setPassWord("123456");
  17. person.setCreateTime(new Date());
  18. //更新条件
  19. Query query= new Query(Criteria.where("id").is(person.getId()));
  20. //更新值
  21. Update update= new Update().set("userName", person.getUserName()).set("passWord", person.getPassWord());
  22. //更新查询满足条件的文档数据(第一条)
  23. UpdateResult result =mongoTemplate.updateFirst(query,update, Person.class);
  24. if(result!=null){
  25. System.out.println("更新条数:" + result.getMatchedCount());
  26. }
  27. }
  28. }
  • 更新文档,匹配查询到的文档数据中的所有数据

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 更新文档,匹配查询到的文档数据中的所有数据
  8. * @throws Exception
  9. */
  10. @Test
  11. public void updateMany() throws Exception {
  12. //更新对象
  13. Person person =new Person();
  14. person.setId(1l);
  15. person.setUserName("张三");
  16. person.setPassWord("123456");
  17. person.setCreateTime(new Date());
  18. //更新条件
  19. Query query= new Query(Criteria.where("id").is(person.getId()));
  20. //更新值
  21. Update update= new Update().set("userName", person.getUserName()).set("passWord", person.getPassWord());
  22. //更新查询满足条件的文档数据(全部)
  23. UpdateResult result = mongoTemplate.updateMulti(query, update, Person.class);
  24. if(result!=null){
  25. System.out.println("更新条数:" + result.getMatchedCount());
  26. }
  27. }
  28. }

删除文档

MongoTemplate提供了remove()、findAndRemove()和findAllAndRemove()方法,用于删除文档,示例代码如下:

  • 删除符合条件的所有文档

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 更新文档,匹配查询到的文档数据中的所有数据
  8. * @throws Exception
  9. */
  10. @Test
  11. public void updateMany() throws Exception {
  12. //更新对象
  13. Person person =new Person();
  14. person.setId(1l);
  15. person.setUserName("张三");
  16. person.setPassWord("123456");
  17. person.setCreateTime(new Date());
  18. //更新条件
  19. Query query= new Query(Criteria.where("id").is(person.getId()));
  20. //更新值
  21. Update update= new Update().set("userName", person.getUserName()).set("passWord", person.getPassWord());
  22. //更新查询满足条件的文档数据(全部)
  23. UpdateResult result = mongoTemplate.updateMulti(query, update, Person.class);
  24. if(result!=null){
  25. System.out.println("更新条数:" + result.getMatchedCount());
  26. }
  27. }
  28. }
  • 删除符合条件的单个文档,并返回删除的文档

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 删除符合条件的单个文档,并返回删除的文档
  8. * @throws Exception
  9. */
  10. @Test
  11. public void findAndRemove() throws Exception {
  12. Person person =new Person();
  13. person.setId(1l);
  14. person.setUserName("张三");
  15. person.setPassWord("123456");
  16. person.setCreateTime(new Date());
  17. Query query = new Query(Criteria.where("id").is(person.getId()));
  18. Person result = mongoTemplate.findAndRemove(query, Person.class);
  19. System.out.println("删除的文档数据:" + result.toString());
  20. }
  21. }
  • 删除符合条件的所有文档,并返回删除的文档

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 删除符合条件的所有文档,并返回删除的文档
  8. * @throws Exception
  9. */
  10. @Test
  11. public void findAllAndRemove() throws Exception {
  12. Person person =new Person();
  13. person.setId(1l);
  14. person.setUserName("张三");
  15. person.setPassWord("123456");
  16. person.setCreateTime(new Date());
  17. Query query = new Query(Criteria.where("id").is(person.getId()));
  18. List<Person> result = mongoTemplate.findAllAndRemove(query, Person.class);
  19. System.out.println("删除的文档数据:" + result.toString());
  20. }
  21. }

查询

MongoTemplate提供了非常多的文档查询方法,日常开发中用的最多的就是find()方法,示例代码如下:

  • 查询集合中的全部文档数据

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 查询集合中的全部文档数据
  8. * @throws Exception
  9. */
  10. @Test
  11. public void findAll() throws Exception {
  12. List<Person> result = mongoTemplate.findAll(Person.class);
  13. System.out.println("查询结果:" + result.toString());
  14. }
  15. }
  • 查询集合中指定的ID文档数据

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 查询集合中指定的ID文档数据
  8. * @throws Exception
  9. */
  10. @Test
  11. public void findById() {
  12. long id = 1l;
  13. Person result = mongoTemplate.findById(id, Person.class);
  14. System.out.println("查询结果:" + result.toString());
  15. }
  16. }
  • 根据条件查询集合中符合条件的文档,返回第一条数据

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 根据条件查询集合中符合条件的文档,返回第一条数据
  8. */
  9. @Test
  10. public void findOne() {
  11. String userName = "张三";
  12. Query query = new Query(Criteria.where("userName").is(userName));
  13. Person result = mongoTemplate.findOne(query, Person.class);
  14. System.out.println("查询结果:" + result.toString());
  15. }
  16. }

  • 根据条件查询集合中符合条件的文档

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 根据条件查询集合中符合条件的文档
  8. */
  9. @Test
  10. public void findByCondition() {
  11. String userName = "张三";
  12. Query query = new Query(Criteria.where("userName").is(userName));
  13. List<Person> result = mongoTemplate.find(query, Person.class);
  14. System.out.println("查询结果:" + result.toString());
  15. }
  16. }

  • 根据【AND】关联多个查询条件,查询集合中的文档数据

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 根据【AND】关联多个查询条件,查询集合中的文档数据
  8. */
  9. @Test
  10. public void findByAndCondition() {
  11. // 创建条件
  12. Criteria criteriaUserName = Criteria.where("userName").is("张三");
  13. Criteria criteriaPassWord = Criteria.where("passWord").is("123456");
  14. // 创建条件对象,将上面条件进行 AND 关联
  15. Criteria criteria = new Criteria().andOperator(criteriaUserName, criteriaPassWord);
  16. // 创建查询对象,然后将条件对象添加到其中
  17. Query query = new Query(criteria);
  18. List<Person> result = mongoTemplate.find(query, Person.class);
  19. System.out.println("查询结果:" + result.toString());
  20. }
  21. }
  • 根据【OR】关联多个查询条件,查询集合中的文档数据

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 根据【OR】关联多个查询条件,查询集合中的文档数据
  8. */
  9. @Test
  10. public void findByOrCondition() {
  11. // 创建条件
  12. Criteria criteriaUserName = Criteria.where("userName").is("张三");
  13. Criteria criteriaPassWord = Criteria.where("passWord").is("123456");
  14. // 创建条件对象,将上面条件进行 OR 关联
  15. Criteria criteria = new Criteria().orOperator(criteriaUserName, criteriaPassWord);
  16. // 创建查询对象,然后将条件对象添加到其中
  17. Query query = new Query(criteria);
  18. List<Person> result = mongoTemplate.find(query, Person.class);
  19. System.out.println("查询结果:" + result.toString());
  20. }
  21. }

  • 根据【IN】关联多个查询条件,查询集合中的文档数据

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 根据【IN】关联多个查询条件,查询集合中的文档数据
  8. */
  9. @Test
  10. public void findByInCondition() {
  11. // 设置查询条件参数
  12. List<Long> ids = Arrays.asList(1l, 10l, 11l);
  13. // 创建条件
  14. Criteria criteria = Criteria.where("id").in(ids);
  15. // 创建查询对象,然后将条件对象添加到其中
  16. Query query = new Query(criteria);
  17. List<Person> result = mongoTemplate.find(query, Person.class);
  18. System.out.println("查询结果:" + result.toString());
  19. }
  20. }

  • 根据【逻辑运算符】查询集合中的文档数据

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 根据【逻辑运算符】查询集合中的文档数据
  8. */
  9. @Test
  10. public void findByOperator() {
  11. // 设置查询条件参数
  12. int min = 20;
  13. int max = 35;
  14. Criteria criteria = Criteria.where("age").gt(min).lte(max);
  15. // 创建查询对象,然后将条件对象添加到其中
  16. Query query = new Query(criteria);
  17. List<Person> result = mongoTemplate.find(query, Person.class);
  18. System.out.println("查询结果:" + result.toString());
  19. }
  20. }

  • 根据【正则表达式】查询集合中的文档数据

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 根据【正则表达式】查询集合中的文档数据
  8. */
  9. @Test
  10. public void findByRegex() {
  11. // 设置查询条件参数
  12. String regex = "^张*";
  13. Criteria criteria = Criteria.where("userName").regex(regex);
  14. // 创建查询对象,然后将条件对象添加到其中
  15. Query query = new Query(criteria);
  16. List<Person> result = mongoTemplate.find(query, Person.class);
  17. System.out.println("查询结果:" + result.toString());
  18. }
  19. }
  • 根据单个条件查询集合中的文档数据,并按指定字段进行排序与限制指定数目

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 根据单个条件查询集合中的文档数据,并按指定字段进行排序与限制指定数目
  8. */
  9. @Test
  10. public void findByConditionAndSortLimit() {
  11. String userName = "张三";
  12. //从第一行开始,查询2条数据返回
  13. Query query = new Query(Criteria.where("userName").is(userName)).with(Sort.by("createTime")).limit(2).skip(1);
  14. List<Person> result = mongoTemplate.find(query, Person.class);
  15. System.out.println("查询结果:" + result.toString());
  16. }
  17. }

  • 统计集合中符合【查询条件】的文档【数量】

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class PersonServiceTest {
  4. @Autowired
  5. private MongoTemplate mongoTemplate;
  6. /**
  7. * 统计集合中符合【查询条件】的文档【数量】
  8. */
  9. @Test
  10. public void countNumber() {
  11. // 设置查询条件参数
  12. String regex = "^张*";
  13. Criteria criteria = Criteria.where("userName").regex(regex);
  14. // 创建查询对象,然后将条件对象添加到其中
  15. Query query = new Query(criteria);
  16. long count = mongoTemplate.count(query, Person.class);
  17. System.out.println("统计结果:" + count);
  18. }
  19. }

事务

单节点 mongodb 不支持事务,需要搭建 MongoDB 复制集才有事务,使用方式和mysql一样在springboot中。

------------------------------------------与正文内容无关------------------------------------ 如果觉的文章写对各位读者老爷们有帮助的话,麻烦点赞加关注呗!作者在这拜谢了!

混口饭吃了!如果你需要Java 、Python毕设、商务合作、技术交流、就业指导、技术支持度过试用期。请在关注私信我,本人看到一定马上回复!

这是我全部文章所在目录,看看是否有你需要的,如果遇到觉得不对地方请留言,看到后我会查阅进行改正。

A乐神-CSDN博客

关注在文章左上角,作者信息处。



所属网站分类: 技术文章 > 博客

作者:我长得真不赖

链接:http://www.javaheidong.com/blog/article/691589/e35903920fb4710242ec/

来源:java黑洞网

任何形式的转载都请注明出处,如有侵权 一经发现 必将追究其法律责任

4 0
收藏该文
已收藏

评论内容:(最多支持255个字符)