MongoDB - 整合 SpringBoot 操作全流程

2024-06-04 2409阅读

一、MongoDB 整合 SpringBoot

1.1、引入依赖

1.2、配置文件

1.3、集合操作

1.4、相关注解

1.5、文档操作

Tips：重要提示

1.5.1、查询

1.5.2、分页查询 + 排序

1.5.3、更新

1.5.4、删除

1.6、事务

一、MongoDB 整合 SpringBoot

1.1、引入依赖

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

1.2、配置文件

spring:
  data:
    mongodb:
      uri: mongodb://192.168.73.3:27017/demo
      field-naming-strategy: org.springframework.data.mapping.model.SnakeCaseFieldNamingStrategy # 自动转驼峰
#      mongodb 一般不设置密码
#      username: root
#      password: 1111

uri 格式为： mongodb://ip 地址:mongodb 端口号/集合名

1.3、集合操作

Ps：以 demo 集合为例

a）创建集合

        if(!mongoTemplate.collectionExists("demo")) {
            //不存在才能创建，如果以及存在再创建就会报错
            mongoTemplate.createCollection("demo");
        }

b）删除集合

        mongoTemplate.dropCollection("demo1");

1.4、相关注解

a）@Document

修饰范围：在类上.
作用：映射当前类的一个对象为 mongo 的一条文档.

属性：value 和 collection 都是用来表示操作的集合名.

b）@Id

修饰范围：成员变量、方法.

作用：将值映射成文档的 _id.

c）@Field

修饰范围：成员变量、方法.

作用：将值映射为文档中的一个 key 名称.

d）@Transient

修饰范围：成员变量、方法.

租用：指定值不参与文档序列化.

以 User 类为例：

@Document("demo") //表示当前文档属于哪个集合
public class User {
    @Id //当前类的 id 映射文档中的 _id
    private Integer id;
    private String name;
    private Integer age;
    @Field("work_day")  //当前类的 workDay 映射文档中的 work_day
    private Date workDay;
    public User(Integer id, String name, Integer age, Date workDay) {
        this.id = id;
        this.name = name;
        this.age = age;
        this.workDay = workDay;
    }
    @Override
    public String toString() {
        return "User{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", age=" + age +
                ", workDay=" + workDay +
                '}';
    }
    public Integer getId() {
        return id;
    }
    public void setId(Integer id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public Integer getAge() {
        return age;
    }
    public void setAge(Integer age) {
        this.age = age;
    }
    public Date getWorkDay() {
        return workDay;
    }
    public void setWorkDay(Date workDay) {
        this.workDay = workDay;
    }
}

1.5、文档操作

Tips：重要提示

mongo 对类型有严格的要求. 例如根据 id 查询用户，你使用 String 类型的 id 作为查询的参数，而 mongo 文档中保存的是 Long 类型的参数，此时你的查询记不起作用.

这点需要跟 MySQL 区分开！！！

1.5.1、查询

        //1.查询所有
        System.out.println("------------------------------------------------");
        List users = mongoTemplate.findAll(User.class);
        users.forEach(System.out::println);
        //2.根据 id 查询指定文档
        System.out.println("------------------------------------------------");
        User byId = mongoTemplate.findById(1, User.class);
        System.out.println(byId);
        //3.根据查询条件进行查询(参数1: 查询条件, 参数2: 返回类型)
        System.out.println("------------------------------------------------");
//        mongoTemplate.find(new Query(), User.class);  //没有查询条件就是查询所有
        //a) 等值查询
        System.out.println("------------------------------------------------");
        List users1 = mongoTemplate.find(Query.query(Criteria.where("name").is("周杰伦")), User.class);
        users1.forEach(System.out::println);
        //b) > 查询: gt()、>= 查询: gte() 、  
 
1.5.2、分页查询 + 排序 
    public List findPaginated(int page, int size) {  
        // 创建查询对象  
        Query query = new Query();  
  
        // 添加过滤条件，如果有的话  
        // query.addCriteria(Criteria.where("fieldName").is("value"));  
  
        // 添加排序条件，如果有的话  
        // query.with(Sort.by(Sort.Direction.ASC, "fieldName"));  
  
        // 计算跳过的文档数量  
        long skip = (page - 1) * size;  
  
        // 设置查询的起始位置和返回的数量  
        query.skip(skip).limit(size);  
  
        // 执行查询并返回结果  
        return mongoTemplate.find(query, MyDocument.class, "collectionName");  
    } 
 
1.5.3、更新 
更新指定字段的值. 
        //1.更新条件
        Query query = Query.query(Criteria.where("name").is("周杰伦"));
        //2.更新内容
        Update update = new Update();
        update.set("age", 20);
        //a) 更新单条
        mongoTemplate.updateFirst(query, update, User.class);
        //b) 更新多条
        mongoTemplate.updateMulti(query, update, User.class);
        //c) 不存在就插入(存在就更新第一条)
        mongoTemplate.upsert(query, update, User.class);
 
指定某字段自增一，或者自减一. 
            mongoTemplate.updateFirst(
                    Query.query(
                            Criteria
                                    .where("_id")
                                    .is(dto.getTargetId())
                    ),
                    new Update().inc("like_cnt", 1), //如果是 -1，就表示自减一
                    AlbumStatGO.class
            );
 
1.5.4、删除 
        //1.删除所有
        mongoTemplate.remove(new Query(), User.class);
        //2.条件删除
        mongoTemplate.remove(Query.query(Criteria.where("name").is("林俊杰")), User.class);
 
 
1.6、事务 
MongoDB 4.0 之后就支持事务了. 
但是开启事务的前提如下： 
a）开启集群模式（多副本集配置） 
b）进行如下配置： 
@Configuration
class MongoTransaction {
    @Bean
    fun transactionManager(factory: MongoDatabaseFactory): MongoTransactionManager {
        return MongoTransactionManager(factory)
    }
}
 
c）在需要回滚的地方加上 @Transactional 注解  
    @Transactional
    fun handler(dto: RegDto) {
        userIdentRepo.save(dto)
        throw AppException(ApiStatus.INVALID_PARAM, "这里故意触发异常，为了检验事务*-")
        userDetailRepo.save(dto.id!!)
    }
 
 
 Ps：如果没有进行副本集的配置，就会报如下错误：