• Springboot 集成 MongoDB

    在SpringBoot项目中集成MongoDB后的一些基本操作。

    前言

    本文介绍的内容是Springboot如何集成MongoDB，以及对MongoDB进行基本的增加、查询数据的操作。

    提示：以下是本篇文章正文内容，下面案例可供参考

    一、MongoDB是什么？

    MongoDB是一个基于分布式文件存储的数据库。由C++语言编写。旨在为 WEB 应用提供可扩展的高性能数据存储解决方案。MongoDB 是一个高性能，开源，无模式的文档型数据库，是当前 NoSql 数据库中比较热门的一种。MongoDB 中的一条记录就是一个文档，与JSON类似。
     

    二、使用步骤一

    1、引入库

    代码如下（示例）：

    2.     org.springframework.boot
    3.     spring-boot-starter-data-mongodb

    2、配置Mongodb连接地址

    代码如下（示例）：

    spring.data.mongodb.uri=mongodb://127.0.0.1:27017/admin 


    3、创建实体类：

    1. package com.hjxmongodb.mongdb.entity;
    2.  
    3. import org.springframework.data.mongodb.core.mapping.Document;
    4.  
    5. import lombok.Data;
    6.  
    7. /**
    8. * 包名称：com.hjxmongodb.mongdb.entity
    9. * @version 创作时间:2023年11月6日上午11:16:04
    10. *
    11. */
    12. @Document
    13. @Data
    14. public class User {
    15. 	
    16. 	private String id;
    17. 	
    18. 	private String name;
    19. 	
    20. 	private int age;
    21. 	
    22. 	private String gender;
    23. 	
    24. 	private String email;
    25. 	
    26. 	
    27.  
    28. }

    4、创建自己的Repository接口类并实现 MongoRepository 接口

    1. package com.hjxmongodb.mongdb.repository;
    2.  
    3. import org.springframework.data.mongodb.repository.MongoRepository;
    4.  
    5. import com.hjxmongodb.mongdb.entity.User;
    6.  
    7. /**
    8. * 包名称：com.hjxmongodb.mongdb.repository
    9. * @version 创作时间:2023年11月9日上午10:16:06
    10. *
    11. */
    12.  
    13. public interface UserRepository extends MongoRepository {
    14.  
    15. }
    16.

    5、增加、查询数据

    查询代码如下：

    1. package com.hjxmongodb.mongdb;
    2.  
    3. import java.util.ArrayList;
    4. import java.util.Collection;
    5. import java.util.List;
    6. import java.util.Optional;
    7. import java.util.Random;
    8. import java.util.UUID;
    9.  
    10. import org.junit.jupiter.api.Test;
    11. import org.springframework.beans.factory.annotation.Autowired;
    12. import org.springframework.boot.test.context.SpringBootTest;
    13. import org.springframework.data.domain.Example;
    14. import org.springframework.data.domain.ExampleMatcher;
    15. import org.springframework.data.domain.Page;
    16. import org.springframework.data.domain.PageRequest;
    17. import org.springframework.data.domain.Pageable;
    18.  
    19. import com.hjxmongodb.mongdb.entity.User;
    20. import com.hjxmongodb.mongdb.repository.UserRepository;
    21.  
    22. /**
    23. * 包名称：com.hjxmongodb.mongdb
    24. * @version 创作时间:2023年11月9日上午10:58:19
    25. *
    26. */
    27.  
    28. @SpringBootTest
    29. public class MongoRepositoryTest {
    30.  
    31.  
    32. 	@Autowired
    33. 	private UserRepository userRepository;
    34.  
    35.  
    36. 	/**
    37. 	 * 批量增加数据
    38. 	 * 使用MongoRepository 批量插入数据
    39. 	 */
    40. 	@Test
    41. 	void createUsers() {
    42. 		
    43. 		Random random = new Random();
    44. 		Collection userList = new ArrayList();
    45. 		for (int i = 0; i < 100000; i++) {
    46. 			User user = new User();
    47. 			user.setId(UUID.randomUUID().toString().replace("-", ""));
    48. 			user.setAge(random.nextInt(22, 50));
    49. 			user.setGender(random.nextInt(0, 2)+"");
    50. 			user.setName("hjx" + random.nextInt(10000));
    51. 			user.setEmail("hjx"+random.nextInt(10000)+"wm@163.com");
    52. 			userList.add(user);
    53. 		}
    54.  
    55. 		System.out.println("批量插入数据：" + userList.size());
    56. 		
    57. 		userList = userRepository.insert(userList);
    58. 		
    59. 		System.out.println("保存成功 ： " + userList.size());
    60.  
    61. 	}
    62. 	
    63. 	@Test
    64. 	void findUser() {
    65. 		System.out.println("使用MongoRepository 来查询数据...");
    66. 		
    67. 		//查询所有的数据
    68. 		List userList =userRepository.findAll();
    69. 		for (User user : userList) {
    70. 			System.out.println(user);
    71. 		}
    72. 		
    73. 		//根据ID查询单个数据
    74. 		Optional user = userRepository.findById("f777728d4779450e81c30fcf2c38dfe0");
    75. 		
    76. 		System.out.println(user.get());
    77. 	}
    78. 	
    79. 	@Test
    80. 	void findByCondition() {
    81. 		System.out.println("根据条件配置来查询数据...");
    82. 		
    83. 		User user = new User();
    84. 		user.setAge(32);
    85. 		
    86. 		Example example = Example.of(user);
    87. 		
    88. 		List tempUser =userRepository.findAll(example);
    89. 		
    90. 		System.out.println(tempUser.size());
    91. 		
    92. 	}
    93. 	
    94. 	@Test
    95. 	void findByConditions() {
    96. 		System.out.println("根据条件模糊查询数据...");
    97. 		ExampleMatcher exampleMatcher = ExampleMatcher.matching().withStringMatcher(ExampleMatcher.StringMatcher.CONTAINING).withIgnoreCase(true);
    98. 		
    99. 		User userExample = new User();
    100. 		userExample.setName("99");
    101. 		userExample.setAge(32);
    102. 		userExample.setGender("1");
    103. 		
    104. 		Example example = Example.of(userExample,exampleMatcher);
    105. 		
    106. 		List resultList =userRepository.findAll(example);
    107. 		
    108. 		System.out.println(resultList.size());
    109. 		
    110. 	}
    111. 	
    112. 	@Test
    113. 	void findByPages() {
    114. 		System.out.println("分页查询数据...");
    115. 		
    116. 		for (int i = 0; i < 10; i++) {
    117. 			Pageable pageable =PageRequest.of(i, 10);
    118. 			
    119. 			User userExample = new User();
    120. 			userExample.setAge(32);
    121. 			
    122. 			Example example = Example.of(userExample);
    123. 			
    124. 			Page pages =userRepository.findAll(example, pageable);
    125. 			System.out.println(pages.getContent());
    126. 			System.out.println(pages.getContent().size());
    127. 			System.out.println(pages.getNumber());
    128. 			System.out.println(pages.getSize());
    129. 			System.out.println("------------------------");
    130. 		}
    131. 		
    132. 	}
    133.  
    134.  
    135.  
    136. }
    137.

    三、方式二：使用MongoTemplate 来操作数据库

    全部代码如下：

    1. package com.hjxmongodb.mongdb;
    2.  
    3. import java.util.ArrayList;
    4. import java.util.Collection;
    5. import java.util.List;
    6. import java.util.Random;
    7. import java.util.UUID;
    8.  
    9. import org.junit.jupiter.api.Test;
    10. import org.springframework.beans.factory.annotation.Autowired;
    11. import org.springframework.boot.test.context.SpringBootTest;
    12. import org.springframework.data.domain.PageRequest;
    13. import org.springframework.data.domain.Pageable;
    14. import org.springframework.data.mongodb.core.MongoTemplate;
    15. import org.springframework.data.mongodb.core.query.Criteria;
    16. import org.springframework.data.mongodb.core.query.Query;
    17. import org.springframework.data.mongodb.core.query.Update;
    18.  
    19. import com.hjxmongodb.mongdb.entity.User;
    20. import com.mongodb.client.MongoCollection;
    21. import com.mongodb.client.result.DeleteResult;
    22. import com.mongodb.client.result.UpdateResult;
    23.  
    24. /**
    25.  * 包名称：com.hjxmongodb.mongdb
    26.  * @version 创作时间:2023年11月9日上午10:09:09
    27.  *
    28.  */
    29.  
    30. @SpringBootTest
    31. public class MongoTemplateTest {
    32.  
    33. 	@Autowired
    34. 	private MongoTemplate mongoTemplate;
    35.  
    36. 	static final String collectionName = "user";
    37.  
    38. 	@Test
    39. 	void collectionExists() {
    40. 		System.out.println("创建集合，即数据库");
    41.  
    42. 		// 判断是否已经存在该集合名称
    43. 		boolean collectionNameExists = mongoTemplate.collectionExists(collectionName);
    44. 		if (!collectionNameExists) {
    45. 			MongoCollection document = mongoTemplate.createCollection(collectionName);
    46. 			System.out.println(document.toString());
    47. 		} else {
    48. 			System.out.println(collectionName + " is exists.");
    49. 		}
    50.  
    51. 	}
    52.  
    53. 	@Test
    54. 	void create() {
    55. 		System.out.println("批量增加数据...");
    56. 		Random random = new Random();
    57. 		Collection userList = new ArrayList();
    58. 		for (int i = 0; i < 100000; i++) {
    59. 			User user = new User();
    60. 			user.setId(UUID.randomUUID().toString().replace("-", ""));
    61. 			user.setAge(random.nextInt(22, 50));
    62. 			user.setGender(random.nextInt(0, 2) + "");
    63. 			user.setName("hjx" + random.nextInt(10000));
    64. 			user.setEmail("hjx" + random.nextInt(10000) + "wm@163.com");
    65. 			userList.add(user);
    66. 		}
    67.  
    68. 		System.out.println("批量插入：" + userList.size() + "条数据。");
    69. 		List t = (List) mongoTemplate.insert(userList, collectionName);
    70. 		System.out.println("保存成功 ： " + t.size());
    71.  
    72. 	}
    73.  
    74. 	@Test
    75. 	void findUser() {
    76. 		System.out.println("根据条件查找用户信息...");
    77. 		Query query = new Query();
    78. 		Criteria criteria = Criteria.where("age").gte(30); // 年龄等于30
    79. 		Criteria nameCriteria = Criteria.where("name").regex("99"); // 名称中包括99
    80.  
    81. 		Criteria andCriteria = new Criteria();
    82. 		andCriteria.andOperator(criteria, nameCriteria);
    83.  
    84. 		query.addCriteria(andCriteria);
    85.  
    86. 		query.limit(400);
    87. 		List userList = mongoTemplate.find(query, User.class, collectionName);
    88. 		System.out.println(userList.size());
    89. 		userList.forEach(item -> System.out.println(item));
    90.  
    91. 	}
    92.  
    93. 	@Test
    94. 	void findAll() {
    95. 		System.out.println("分页按条件查询数据....");
    96.  
    97. 		Query query = new Query();
    98.  
    99. 		Criteria criteria = Criteria.where("age").gte(30); // 年龄大于等于30
    100. 		Criteria nameCriteria = Criteria.where("name").regex("99"); // 名称中包含有99
    101.  
    102. 		Criteria andCriteria = new Criteria();
    103. 		andCriteria.andOperator(criteria, nameCriteria);
    104.  
    105. 		query.addCriteria(andCriteria);
    106.  
    107. 		for (int i = 0; i < 10; i++) {
    108. 			
    109. 			Pageable pageable = PageRequest.of(i, 10);//每页查询10条数据
    110. 			query.with(pageable);
    111.  
    112. 			List pages = mongoTemplate.find(query, User.class, collectionName);
    113.  
    114. 			System.out.println(pages.size());
    115. 			System.out.println(pages);
    116. 			System.out.println("------------------------");
    117. 		}
    118.  
    119. 	}
    120. 	
    121. 	@Test
    122. 	void findallUser() {
    123. 		System.out.println("查询所有数据，循环输出....");
    124. 		
    125. 		List user = mongoTemplate.findAll(User.class, collectionName);
    126.  
    127. 		// 第一种循环打印数据的方式：
    128. 		user.forEach(item -> System.out.println(item));
    129.  
    130. 		// 第二种循环打印数据的方式：
    131. 		user.forEach(System.out::println);
    132. 	}
    133. 	
    134.  
    135. 	@Test
    136. 	void update() {
    137. 		System.out.println("更新用户信息...");
    138. 		Criteria updateCriteria = Criteria.where("age").is(22);
    139.  
    140. 		Update updateItem = new Update();
    141. 		updateItem.set("age", 32);
    142.  
    143. 		UpdateResult result = mongoTemplate.updateMulti(new Query(updateCriteria), updateItem, User.class,
    144. 				collectionName);
    145.  
    146. 		System.out.println(result.toString());
    147.  
    148. 	}
    149.  
    150. 	@Test
    151. 	void delete() {
    152. 		System.out.println("删除用户信息...");
    153. 		Criteria updateCriteria = Criteria.where("age").is(35);
    154.  
    155. 		DeleteResult result = mongoTemplate.remove(new Query(updateCriteria), User.class, collectionName);
    156.  
    157. 		System.out.println(result);
    158. 	}
    159.  
    160. //	@Test
    161. 	void deleteAll() {
    162. 		System.out.println("删除所有用户信息...");
    163.  
    164. 		//方式1：删除所有数据
    165. //		DeleteResult result = mongoTemplate.remove(new Query(), collectionName);
    166. //		System.out.println(result);
    167.  
    168. 		//方式2：删除所有数据,删除集合就可以了。
    169. 		mongoTemplate.dropCollection(collectionName);
    170.  
    171.  
    172.  
    173. 	}
    174.  
    175. }

    总结

    以上就是在SpringBoot项目中集成MongoDB后的一些基本操作。本文简单介绍了MongoDB增加、查询、分页查询、删除数据等的操作，希望对伙伴们有一点点帮助。

  • 相关阅读:
    1024程序节特辑：一文读懂小程序支付流程
    数字时代，医疗健康企业如何通过数字营销创造用户价值
    编程架构演化史：远古时代，从打孔卡（Punched Card）开始
    LQ0250 n进制小数【程序填空】
    相机专业模型详解，各个参数作用，专业模式英文全称和缩写
    关于城市旅游的HTML网页设计——中国旅游HTML+CSS+JavaScript 出游旅游主题度假酒店 计划出行网站设计
    Spring 如何使用注解装配Bean呢？
    《MongoDB》Mongo Shell中基本操作-ObjectId和文档创建详解
    BIM知识 | BIM管线综合原则
    pytorch 32 onnx模型每次输出的结果都会变的解决方案
  • 原文地址：https://blog.csdn.net/hjx_code/article/details/134369679