ToB企服应用市场:ToB评测及商务社交产业平台

标题: Mongodb操作与Java（四）MongoTemplate的利用 [打印本页]

---

作者: 小秦哥    时间: 2024-7-26 22:20
标题: Mongodb操作与Java（四）MongoTemplate的利用
目次
mongoClient和MongoTemplate二者区别
代码实践
配置
SpringBoot 工程依靠和配置
准备代码
创建实体类
新增 
插入文档
存储文档
更新
删除文档
查询
变乱

---

媒介-与正文无关
​    生活远不止眼前的苦劳与奔忙，它还充满了无数值得我们去体验和珍惜的美功德物。在这个快节奏的天下中，我们往往容易陷入工作的漩涡，忘记了停下脚步，感受周围的天下。让我们一起提醒本身，要适时放慢脚步，欣赏生活中的每一道风景，享受与家人朋侪的温馨韶光，发现那些平凡日子里隐蔽的幸福时刻。由于，这些点点滴滴汇聚起来的，才是构成我们丰富多彩生活的本质。渴望每个人都能在繁忙的生活中找到本身的快乐之源，不仅仅为了生存而工作，更为了更好的生活而生活.
​       送你张美图！渴望你开心！

mongoClient和MongoTemplate二者区别

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>
8. <dependency>
9.     <groupId>org.springframework.boot</groupId>
10.     <artifactId>spring-boot-starter-data-mongodb</artifactId>
11. </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;
8.     /**
9.      * 使用@Id注解指定MongoDB中的 _id 主键
10.      */
11.     @Id
12.     private Long id;
14.     private String userName;
16.     private String passWord;
18.     private Integer age;
20.     private Date createTime;
22.     //...get/set
24.     @Override
25.     public String toString() {
26.         return "Person{" +
27.                 "id=" + id +
28.                 ", userName='" + userName + '\'' +
29.                 ", passWord='" + passWord + '\'' +
30.                 ", age=" + age +
31.                 ", createTime=" + createTime +
32.                 '}';
33.     }
34. }

复制代码

新增 

插入文档

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

• 用于插入文档
  

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

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

复制代码

• 自界说集合名称，插入文档
  

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

复制代码

• 自界说集合，批量插入文档
  

   假如采用批量插入文档，必须指定集合名称

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

复制代码

存储文档

MongoTemplate提供了save()方法，用于存储文档。
在存储文档的时候会通过主键 ID 进行判断，假如存在就更新，否则就插入，示例代码如下：

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

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

复制代码

• 自界说集合，存储文档
  

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

复制代码

更新

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

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

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

复制代码

• 更新文档，匹配查询到的文档数据中的所有数据
  

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

复制代码

删除文档

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

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

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

复制代码

• 删除符合条件的单个文档，并返回删除的文档
  

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

复制代码

• 删除符合条件的所有文档，并返回删除的文档
  

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

复制代码

查询


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

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

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

复制代码

• 查询集合中指定的ID文档数据
  

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

复制代码

• 根据条件查询集合中符合条件的文档，返回第一条数据
  

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

复制代码

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

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

复制代码

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

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

复制代码

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

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

复制代码

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

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

复制代码

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

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

复制代码

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

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

复制代码

• 根据单个条件查询集合中的文档数据，并按指定字段进行排序与限制指定命目
  

1. @RunWith(SpringRunner.class)
2. @SpringBootTest
3. public class PersonServiceTest {
5.     @Autowired
6.     private MongoTemplate mongoTemplate;
8.    /**
9.      * 根据单个条件查询集合中的文档数据，并按指定字段进行排序与限制指定数目
10.      */
11.     @Test
12.     public void findByConditionAndSortLimit() {
13.         String userName = "张三";
14.         //从第一行开始，查询2条数据返回
15.         Query query = new Query(Criteria.where("userName").is(userName)).with(Sort.by("createTime")).limit(2).skip(1);
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 {
5.     @Autowired
6.     private MongoTemplate mongoTemplate;
8.    /**
9.      * 统计集合中符合【查询条件】的文档【数量】
10.      */
11.     @Test
12.     public void countNumber() {
13.         // 设置查询条件参数
14.         String regex = "^张*";
15.         Criteria criteria = Criteria.where("userName").regex(regex);
16.         // 创建查询对象，然后将条件对象添加到其中
17.         Query query = new Query(criteria);
18.         long count = mongoTemplate.count(query, Person.class);
19.         System.out.println("统计结果：" + count);
20.     }
21. }

复制代码

变乱

单节点 mongodb 不支持变乱，需要搭建 MongoDB 复制集才有变乱，利用方式和mysql一样在springboot中。


------------------------------------------与正文内容无关------------------------------------ 假如觉的文章写对各位读者老爷们有资助的话，麻烦点赞加关注呗！作者在这拜谢了!
混口饭吃了！假如你需要Java 、Python毕设、商务合作、技术交换、就业引导、技术支持度过试用期。请在关注私信我，本人看到肯定马上回复！
这是我全部文章所在目次，看看是否有你需要的，假如遇到以为不对地方请留言，看到后我会查阅进行改正。
A乐神-CSDN博客
关注在文章左上角，作者信息处。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

---

欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/)

Powered by Discuz! X3.4