SpringBoot整合MongoDB

• NoSQL(Not Only SQL)，即反SQL运动或者是不仅仅SQL，指的是非关系型的数据库，是一项全新的数据库革命运动，是一种全新的思维注入
  
• NoSQL优点
  
  
  
  • 数据库高并发读写
    
  • 海量数据高效率存储和访问
    
  • 数据库高扩展性和高可用性
    
  
  
• NoSQL缺点
  
  
  
  • 数据库事务一致性需求
    
  • 数据库的写实时性和读实时性需求
    
  • 复杂的SQL查询，特别是夺标关联查询的需求
    
  
  
• MongoDB概述
  
  
  
  • 由C++语言编写，是一个基于分布式文件存储的开源数据库系统；在高负载的情况下，添加更多的节点，可以保证服务器性能
    
  • MongoDB旨在为WEB应用提供可扩展的高性能数据存储解决方案；将数据存储为一个文档，数据结构由键值对组成。MongoDB文档类似于JSON对象字段值可以包含其他问你当、数组及文档数组
    
  
  
• MongoDB特点
  
  
  
  • MongoDB是一个面向文档存储的数据库，操作起来比较简单和容易
    
  • MongoDB记录总可以设置任何属性的索引
    
  • 可以通过本地后者网络创建数据镜像，这使得MongoDB有更强的扩展性
    
  • 如果负载的增减（需要跟多的存储空间和更强的处理能力），它可以分布在计算机网络中的其他节点上，这就是所谓的分片
    
  • MongoDB支持丰富的查询表达式，查询指令使用JSON形式的标记，可轻易查询文档中内嵌的对象和数组
    
  • MongoDB使用update()命令可以实现替换完成的文档（数据）或者一些指定的数据字段
    
  • MongoDB中的Map/reduce主要是用来对数据进行批量处理和聚合操作
    
  • Map和Reduce
    
    
    
    • Map函数调用emit(key, value)便利集合中所有的记录，将key域value传给Reduce函数进行处理
      
    • Map和Reduce函数是使用JavaScript编写的，把那个可以通过db.runCommand或mapreduce命令来执行MapReduce操作
      
    
    
  • GridFS是MongoDB中的一个内置功能，可以用于存放大量的小文件
    
  • MongoDB允许在服务端执行脚本，可以用JavaScript编写某个函数，直接在服务端执行，也可以把函数的定义存储在服务端，下次直接调用即可
    
  • MongoDB支持跟中编程语言：RUBY、PYTHON、JAVA、C++、PHP、C#
    
  • 安装简单
    
  
  
• MongoDB语法：略
  
• SpringBoot整合MongoDB
  
  
  
  • 集成简介：spring-data-mongodb提供了MongoTemplate和MongoRepository两种方式访问MongoDB；MongoTemplate操作灵活，MongoRepository操作简单，不够灵活
    
  • 添加相关依赖
    
  
  

1. <dependency>
2.     <groupId>org.springframework.boot</groupId>
3.     <artifactId>spring-boot-starter-data-mongodb</artifactId>
4.     <version>2.2.1.RELEASE</version>
5. </dependency>
6. <dependency>
7.     <groupId>org.springframework.boot</groupId>
8.     <artifactId>spring-boot-starter-web</artifactId>
9.     <version>2.2.1.RELEASE</version>
10. </dependency>
11. <dependency>
12.     <groupId>org.projectlombok</groupId>
13.     <artifactId>lombok</artifactId>
14.     <version>1.18.10</version>
15. </dependency>
16. <dependency>
17.     <groupId>joda-time</groupId>
18.     <artifactId>joda-time</artifactId>
19.     <version>2.10.1</version>
20. </dependency>
21. <dependency>
22.     <groupId>org.springframework.boot</groupId>
23.     <artifactId>spring-boot-starter-test</artifactId>
24.     <scope>test</scope>
25.     <exclusions>
26.         <exclusion>
27.             <groupId>org.junit.vintage</groupId>
28.             <artifactId>junit-vintage-engine</artifactId>
29.         </exclusion>
30.     </exclusions>
31. </dependency>

复制代码

• 添加配置
  

1. spring.data.mongodb.uri=mongodb://Your IP:27017/your database

复制代码

• 创建与集合对应的实体类
  

1. @Data
2. @Document("User")   // 表示操作的是your database下的User集合
3. public class User {
4.     @Id
5.     private String id;
6.     private String name;
7.     private Integer age;
8. }

复制代码

• 测试MongoTemplate访问MongoDB（CRUD）
  

1. @SpringBootTest
2. public class MongoDBTest {
3.     @Autowired
4.     private MongoTemplate mongoTemplate;
6.     /** 新增 */
7.     @Test
8.     public void insert() {
9.         User user = new User();
10.         user.setName("xiansen");
11.         user.setAge(18);
12.         User u = mongoTemplate.insert(user);
13.         System.out.println("user = " + u);
14.     }
15.     /** 查询所有记录 */
16.     @Test
17.     public void findAll() {
18.         List<User> all = mongoTemplate.findAll(User.class);
19.         System.out.println("all = " + all);
20.     }
21.     /** ID查询 */
22.     @Test
23.     public void findById() {
24.         User u = mongoTemplate.findById("rge8vcuxdfsfdfsdf", User.class);
25.         System.out.println("u = " + u);
26.     }
27.     /** 条件查询 */
28.     @Test
29.     public void findUserList() {
30.         Query query = new Query(Criteria.where("name").is("xiansen").and("age").is(18));
31.         List<User> users = mongoTemplate.find(query, User.class);
32.         System.out.println("users = " + users);
33.     }
34.     /** 模糊查询 */
35.     @Test
36.     public void findUserListByLike() {
37.         String name = "xian";
38.         String regex = String.format("%s%s%s", "^.*", name, ".*$");
39.         Pattern pattern = Pattern.compile(regex, Pattern.CASE_INSENSITIVE);  // 大小写敏感
40.         Query query = new Query(Criteria.where("name").regex(pattern));   // 使用正则表达式实现模糊查询
41.         List<User> users = mongoTemplate.find(query, User.class);
42.         System.out.println("users = " + users);
43.     }
44.     /** 分页查询 */
45.     @Test
46.     public void findPageUserList() {
47.         int current = 1;
48.         int limit = 3;
49.         String name = "xian";
50.         String regex = String.format("%s%s%s", "^.*", name, ".*$");
51.         Pattern pattern = Pattern.compile(regex, Pattern.CASE_INSENSITIVE);  // 大小写敏感
52.         Query query = new Query(Criteria.where("name").regex(pattern));
53.         // 查询的记录数
54.         Long count = mongoTemplate.count(query, User.class);
55.         System.out.println("count = " + count);
56.         // 分页查询
57.         List<User> users = mongoTemplate.find(query.skip((current-1)*limit).limit(limit), User.class);
58.         System.out.println("users = " + users);
59.     }
60.     /** 修改 */
61.     @Test
62.     public void updateUser() {
63.         User u = mongoTemplate.findById("ds98h98sdhds6gt7u", User.class);
64.         u.setName("hello");
65.         u.setAge(20);
66.         Query query = new Query(Criteria.where("_id").is(u.getId()));
67.         Update update = new Update();
68.         update.set("name", u.getName());
69.         update.set("age", u.getAge());
70.         UpdateResult upsert = mongoTemplate.upsert(query, update, User.class);
71.         long modifiedCount = upsert.getModifiedCount();  // 影响的行数
72.         System.out.println("modifiedCount = " + modifiedCount);
73.     }
74.     /** 删除 */
75.     @Test
76.     public void deleteUser() {
77.         Query query = new Query(Criteria.where("_id").is("ds98h98sdhds6gt7u"));
78.         DeleteResult remove = mongoTemplate.remove(query, User.class);
79.         long deletedCount = remove.getDeletedCount();  // 影响的行数
80.         System.out.println("deletedCount = " + deletedCount);
81.     }
82. }

复制代码

• 相比于MongoTemplate，MongoRepository实现CRUD操作，还需要创建一个继承MongoRepository接口的接口，如
  

1. @Repository
2. public interface UserRepository extends MongoRepository<User, String> {}

复制代码

• 测试MongoRepository访问MongoDB（CRUD）
  

1. @SpringBootTest
2. public class MongoDBTest {
3.     @Autowired
4.     private UserRepository userRepository;
7.     /** 新增 */
8.     @Test
9.     public void insert() {
10.         User user = new User();
11.         user.setName("xiansen");
12.         user.setAge(18);
13.         User u = userRepository.save(user);
14.         System.out.println("user = " + u);
15.     }
16.     /** 查询所有记录 */
17.     @Test
18.     public void findAll() {
19.         List<User> all = userRepository.findAll();
20.         System.out.println("all = " + all);
21.     }
22.     /** ID查询 */
23.     @Test
24.     public void findById() {
25.         User u = userRepository.findById("rge8vcuxdfsfdfsdf").get();
26.         System.out.println("u = " + u);
27.     }
28.     /** 条件查询 */
29.     @Test
30.     public void findUserList() {
31.         User user = new User();
32.         user.setName("xiansen");
33.         user.setAge(18);
34.         Example<User> userExample = Example.of(user);
35.         List<User> users = userRepository.findAll(userExample);
36.         System.out.println("users = " + users);
37.     }
38.     /** 模糊查询 */
39.     @Test
40.     public void findUserListByLike() {
41.         User user = new User();
42.         user.setName("xian");
43.         user.setAge(18);
44.         ExampleMatcher matcher = ExampleMatcher.matching()
45.                 .withStringMatcher(ExampleMatcher.StringMatcher.CONTAINING)    // 表示模糊查询
46.                 .withIgnoreCase(true);   // 忽略大小写
47.         Example<User> userExample = Example.of(user, matcher);
48.         List<User> users = userRepository.findAll(userExample);
49.         System.out.println("users = " + users);
50.     }
51.     /** 分页查询 */
52.     @Test
53.     public void findPageUserList() {
54.         // 分页设置参数
55.         Pageable pageable = PageRequest.of(0, 3);// 0表示第一页
56.         User user = new User();
57.         user.setName("xiansen");
58.         user.setAge(18);
59.         Example<User> userExample = Example.of(user);
60.         Page<User> page = userRepository.findAll(userExample, pageable);
61.         System.out.println("page = " + page);
62.     }
63.     /** 修改 */
64.     @Test
65.     public void updateUser() {
66.         User u = userRepository.findById("ds98h98sdhds6gt7u").get();
67.         u.setName("hello");
68.         u.setAge(20);
69.         User user = userRepository.save(u);
70.         System.out.println("user = " + user);
71.     }
72.     /** 删除 */
73.     @Test
74.     public void deleteUser() {
75.         userRepository.deleteById("ds98h98sdhds6gt7u");
76.     }
77. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！