SpringBoot集成Mongo

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

spring:
  application:
    name: Mongo APP
  data:
    mongodb:
      uri: mongodb://{用户名}:{密码}@{IP}:{PORT}/{数据库名}?authSource={鉴权数据库名}

未做鉴权时，uri如下：
    mongodb://{IP}:{PORT}/{数据库名}

package com.watrix.mongo;

import com.mongodb.client.result.DeleteResult;
import com.mongodb.client.result.UpdateResult;
import com.watrix.mongo.po.User2PO;
import com.watrix.mongo.po.UserPO;
import lombok.extern.slf4j.Slf4j;
import org.bson.BSONObject;
import org.bson.types.ObjectId;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;

import java.util.List;

@Slf4j
@SpringBootTest
public class MongobaseTest {
    @Autowired
    private MongoTemplate mongoTemplate;

    @Test
    @DisplayName("objectId生成")
    public void objectIdGenerateTest() {
        for (int i = 0; i < 10; i++) {
            ObjectId objectId = ObjectId.get();
            log.info("xxx>>> " + objectId.toString());
        }
    }

    @Test
    @DisplayName("插入一个对象,ID属性为Long,指定ID")
    public void insertoneWithId() {
        UserPO userPO = new UserPO(1L, "张飞", 24, "丈八蛇矛");
        UserPO insertResult = mongoTemplate.insert(userPO);
        log.info(insertResult.toString());
    }

    @Test
    @DisplayName("插入一个对象,ID属性为ObjectId,不指定ID")
    public void insertoneNoId() {
        User2PO userPO = new User2PO("张飞", 24, "丈八蛇矛");
        User2PO insertResult = mongoTemplate.insert(userPO);
        log.info(insertResult.toString());
    }

    @Test
    @DisplayName("查询")
    public void queryTest() {
        List user2POS = mongoTemplate.find(new Query(), User2PO.class);
        log.info(user2POS.toString());
    }

    @Test
    @DisplayName("修改")
    public void queryByCondationTest() {
        Query query = new Query();
        query.addCriteria(Criteria.where("userName").is("张飞"));
        List user2POS = mongoTemplate.find(query, User2PO.class);
        log.info("修改前数据：" + user2POS.toString());

        Update update = new Update();
        // set操作需保证字段已存在
        update.set("age", 50)
                .set("prop","战士");
        UpdateResult updateResult = mongoTemplate.updateMulti(query, update, User2PO.class);
        log.info("updateResult: >>> {}",updateResult);
        log.info("修改后数据：{}" , mongoTemplate.find(query, User2PO.class));
    }

    @Test
    @DisplayName("删除")
    public void deleteTest() {
        Query query = new Query();
        query.addCriteria(Criteria.where("userName").is("张飞"));
        List user2POS = mongoTemplate.find(query, User2PO.class);
        log.info("删除前数据：" + user2POS.toString());

        DeleteResult remove = mongoTemplate.remove(query, User2PO.class);
        log.info("updateResult: >>> {}",remove);
        log.info("删除后数据：{}" , mongoTemplate.find(query, User2PO.class));
    }
}

package com.watrix.mongo.po;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.bson.types.ObjectId;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.document;

@Data
@document("user2")
@AllArgsConstructor
@NoArgsConstructor
public class User2PO {
    @Id
    private ObjectId userId;

    private String userName;

    private Integer age;

    private String weapon;

    public User2PO(String userName, int age, String weapon) {
        this(null,userName,age,weapon);
    }
}

package com.watrix.mongo.po;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.document;

@Data
@document("user")
@AllArgsConstructor
@NoArgsConstructor
public class UserPO {
    @Id
    private Long userId;

    private String userName;

    private Integer age;

    private String weapon;

    public UserPO(String userName, int age, String weapon) {
        this(null,userName,age,weapon);
    }
}

    如果通过Mongo生成ID,则使ID属性定义为ObjectId,插入数据时忽略ID。
    如果不通过Mongo生成，则自定义ID属性，插入数据时自行生成ID。