一切福田，不離方寸，從心而覓，感無不通。

Spring boot集成mongodb

1、Spring boot集成mongodb简介

spring-data-mongodb提供了MongoTemplate与MongoRepository两种方式访问mongodb。

  • MongoRepository操作简单
  • MongoTemplate操作灵活

我们在项目中可以灵活适用这两种方式操作mongodb，MongoRepository的缺点是不够灵活，MongoTemplate正好可以弥补不足。

2、搭建项目环境

2.1、创建springboot工程

在这里插入图片描述

2.2、引入依赖

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

 

2.3、添加配置

在application.properties文件添加MongoDB配置

1
spring.data.mongodb.uri=mongodb://127.0.0.1:27017/test

 

3、基于MongoTemplate 开发CRUD

3.1、MongoTemplate常用方法

mongoTemplate.findAll(User.class): 查询User文档的全部数据
mongoTemplate.findById(, User.class): 查询User文档id为id的数据
mongoTemplate.find(query, User.class);: 根据query内的查询条件查询
mongoTemplate.upsert(query, update, User.class): 修改
mongoTemplate.remove(query, User.class): 删除
mongoTemplate.insert(User): 新增
Query对象
1、创建一个query对象（用来封装所有条件对象)，再创建一个criteria对象（用来构建条件）
2、 精准条件：criteria.and(“key”).is(“条件”)
模糊条件：criteria.and(“key”).regex(“条件”)
3、封装条件：query.addCriteria(criteria)
4、大于（创建新的criteria）：Criteria gt = Criteria.where(“key”).gt（“条件”）
小于（创建新的criteria）：Criteria lt = Criteria.where(“key”).lt（“条件”）
5、Query.addCriteria(new Criteria().andOperator(gt,lt));
6、一个query中只能有一个andOperator()。其参数也可以是Criteria数组。
7、排序 ：query.with（new Sort(Sort.Direction.ASC, “age”). and(new Sort(Sort.Direction.DESC, “date”)))

3.2、创建实体类

1
2
3
4
5
6
7
8
9
10
11
@Data
@Document("User")
public class User {
 
    @Id
    private String id;
    private String name;
    private Integer age;
    private String email;
    private String createDate;
}

 

3.3、编写测试类，测试基于MongoTemplate 开发的增删改查

3.3.1、新增数据

在这里插入图片描述

1
2
3
4
5
6
7
8
9
10
11
12
13
@Autowired
    private MongoTemplate mongoTemplate;
 
    //添加操作
    @Test
    void contextLoads() {
        User user = new User();
        user.setAge(20);
        user.setName("test");
        user.setEmail("123@qq.com");
        User user1 = mongoTemplate.insert(user);
        System.out.println(user1);
    }

 

控制台输出
在这里插入图片描述

3.3.2、查询集合（表）全部

在这里插入图片描述

1
2
3
4
5
6
//查询所有记录
@Test
public void findAll(){
     List<User> all = mongoTemplate.findAll(User.class);
     System.out.println(all);
}

 

在这里插入图片描述

3.3.3、根据id查询

在这里插入图片描述

1
2
3
4
5
6
//根据id查询
@Test
public void findId(){
     User user = mongoTemplate.findById("60b4b3ca861699233d33f3e2", User.class);
     System.out.println(user);
}

 

在这里插入图片描述

3.3.4、条件查询

在这里插入图片描述

1
2
3
4
5
6
7
//条件查询
@Test
public void findUserList(){
     Query query = new Query(Criteria.where("name").is("test").and("age").is(20));
     List<User> users = mongoTemplate.find(query, User.class);
     System.out.println(users);
}

 

在这里插入图片描述

3.3.5、模糊查询

Pattern.compile函数用法

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
//模糊条件查询
    @Test
    public void findLikeUserList(){
//        name like test
        String name = "est";
        String regex = String.format("%s%s%s", "^.*", name, ".*$");
        /*1、在使用Pattern.compile函数时，可以加入控制正则表达式的匹配行为的参数：
        Pattern Pattern.compile(String regex, int flag)
        2、regex设置匹配规则
        3、Pattern.CASE_INSENSITIVE,这个标志能让表达式忽略大小写进行匹配。*/
        Pattern pattern = Pattern.compile(regex,Pattern.CASE_INSENSITIVE);
        //创建一个query对象（用来封装所有条件对象)，再创建一个criteria对象（用来构建条件）
        Query query = new Query(//构建查询条件
                Criteria.where("name").regex(pattern));
        List<User> users = mongoTemplate.find(query, User.class);
        System.out.println(users);
    }

 

查询结果：查询出来了名字里包好est的用户
在这里插入图片描述

3.3.6、分页查询带条件

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
//分页查询（带条件）
@Test
public void pageLikeUserList(){
     int pageNo = 1;//设置当前页
     int pageSize = 3;//设置每页显示的记录数
 
     //条件构建
     String name = "est";
     String regex = String.format("%s%s%s", "^.*", name, ".*$");
     /*1、在使用Pattern.compile函数时，可以加入控制正则表达式的匹配行为的参数：
     Pattern Pattern.compile(String regex, int flag)
     2、regex设置匹配规则
     3、Pattern.CASE_INSENSITIVE,这个标志能让表达式忽略大小写进行匹配。*/
     Pattern pattern = Pattern.compile(regex,Pattern.CASE_INSENSITIVE);
     //创建一个query对象（用来封装所有条件对象)，再创建一个criteria对象（用来构建条件）
     Query query = new Query(//构建查询条件
             Criteria.where("name").regex(pattern));
 
     //分页构建
     //查询数来集合（表）中的总记录数
     long count = mongoTemplate.count(query, User.class);
     List<User> users = mongoTemplate.find(
             query.skip((pageNo - 1) * pageSize).limit(pageSize), User.class);
     System.out.println(count);
     System.out.println(users);
}

 

在这里插入图片描述

3.3.7、修改操作

在这里插入图片描述

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
//修改操作
@Test
public void  updateUser(){
    //根据id查询
    User user = mongoTemplate.findById("60b4f89db925b61fbf529591", User.class);
    //修改值
    user.setName("test_02");
    user.setAge(2);
    user.setEmail("test_02@qq.com");
 
    //调用方法实现修改
    Query query = new Query(Criteria.where("_id").is(user.getId()));
    Update update = new Update();
    update.set("name",user.getName());
    update.set("age",user.getAge());
    update.set("email",user.getEmail());
    //调用mongoTemplate的修改方法实现修改
    UpdateResult upsert = mongoTemplate.upsert(query, update, User.class);
    long modifiedCount = upsert.getModifiedCount();//获取到修改受影响的行数
    System.out.println("受影响的条数："+modifiedCount);
}

 

在这里插入图片描述

3.3.8、删除操作

在这里插入图片描述

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
//删除条件
@Test
public void deleteUser(){
     Query query = new Query(Criteria.where("_id").is("60b4b3ca861699233d33f3e2"));
     DeleteResult remove = mongoTemplate.remove(query, User.class);
     long deletedCount = remove.getDeletedCount();
     System.out.println("删除的条数："+deletedCount);
}//删除条件
@Test
public void deleteUser(){
     Query query = new Query(Criteria.where("_id").is("60b4b3ca861699233d33f3e2"));
     DeleteResult remove = mongoTemplate.remove(query, User.class);
     long deletedCount = remove.getDeletedCount();
     System.out.println("删除的条数："+deletedCount);
}

 

控制台输出：
在这里插入图片描述
查看mongoDB,已经删除了该条数据
在这里插入图片描述

4、 基于MongoRepository开发CRUD

Spring Data提供了对mongodb数据访问的支持，我们只需要继承MongoRepository类，按照Spring Data规范就可以了。

4.1、SpringData 方法定义规范

在这里插入图片描述在这里插入图片描述

1、不是随便声明的，而需要符合一定的规范
2、 查询方法以find | read | get开头
3、 涉及条件查询时，条件的属性用条件关键字连接
4、 要注意的是：条件属性首字母需要大写
5、 支持属性的级联查询，但若当前类有符合条件的属性则优先使用，而不使用级联属性,若需要使用级联属性，则属性之间使用_强制进行连接

4.2、添加Repository接口

在这里插入图片描述

1
2
3
4
5
6
7
8
9
10
11
import com.demomongodb.entity.User;
import org.springframework.data.mongodb.repository.MongoRepository;
import org.springframework.stereotype.Repository;
/**
* @Description :
* @Author :lenovo
* @Date :2021/6/1 10:54
*/
@Repository
public interface UserRepository extends MongoRepository<User,String> {
}

 

4.3 添加测试类，测试CRUD

4.3.1、添加操作

在这里插入图片描述

1
2
3
4
5
6
7
8
9
10
11
12
13
@Autowired
private UserRepository userRepository;
 
//添加操作
@Test
public void save(){
     User user = new User();
     user.setName("ertong");
     user.setAge(20);
     user.setEmail("ertong@qq.com");
     User user1 = userRepository.save(user);
     System.out.println(user1);
}

 

在这里插入图片描述

4.3.2、查询所有

1
2
3
4
5
6
7
8
//查询所有
@Test
public void findAll(){
    List<User> lists = userRepository.findAll();
    for(User user:lists){
        System.out.println(user);
    }
}

 

在这里插入图片描述

4.3.2、根据id查询

1
2
3
4
5
6
//根据id查询
@Test
public void findById(){
    User user = userRepository.findById("60b4b491861699233d33f3e3").get();
    System.out.println(user);
}

 

在这里插入图片描述

4.3.3、条件查询

使用 Example example = Example.of(user);封装查询条件

1
2
3
4
5
6
7
8
9
10
//条件查询
@Test
public void findUserList(){
     User user = new User();
     user.setName("ertong");
     user.setAge(20);
     Example<User> example = Example.of(user);
     List<User> all = userRepository.findAll(example);
     System.out.println(all);
}

 

在这里插入图片描述

4.3.4、模糊条件查询

在这里插入图片描述

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
//模糊条件查询
@Test
public void findLikeUserList(){
    ///创建匹配器，即如何使用查询条件
    ExampleMatcher matcher = ExampleMatcher.matching()//构建对象
            .withStringMatcher(ExampleMatcher.StringMatcher.CONTAINING)//改变默认字符串匹配方式：模糊查询
            .withIgnoreCase(true);//改变默认大小写忽略方式：忽略大小写
 
    User user = new User();
    user.setName("e");
    user.setAge(20);
    Example<User> example = Example.of(user,matcher);
    List<User> all = userRepository.findAll(example);
    System.out.println(all);
}

 

在这里插入图片描述

4.3.5、分页查询

1
2
3
4
5
6
7
8
9
10
11
12
13
//分页查询
@Test
public void findPageUserAll(){
    //设置分页参数
    //0代表第一页
    Pageable pageable = PageRequest.of(0, 3);
    //查询条件
    User user = new User();
    user.setName("test");
    Example<User> userExample = Example.of(user);//查询条件
    Page<User> page = userRepository.findAll(userExample, pageable);
    System.out.println(page.getContent());
}

 

在这里插入图片描述

4.3.6、修改

在这里插入图片描述

1
2
3
4
5
6
7
8
9
10
11
12
//修改操作
@Test
public void updateUser(){
    //先根据id出要修改的用户
    User user = userRepository.findById("60b5a37209aa4d6face6bacd").get();
    //设置修改的值
    user.setName("haha");
    user.setAge(23);
    user.setEmail("hah@qq.com");
    User user1 = userRepository.save(user);
    System.out.println(user1);
}

 

在这里插入图片描述

4.3.6、删除

执行删除前，首先查询一些=下数据库user表中的数据
在这里插入图片描述
执行删除操作

1
2
3
4
5
//删除
@Test
public void delete(){
   userRepository.deleteById("60b5a37209aa4d6face6bacd");
}

 

再次查询test数据库的user表，数据已删除
在这里插入图片描述

 

from:https://blog.csdn.net/qq_46112274/article/details/117425532

Copyright © 2026 Longsheng All rights reserved