spring boot 中使用mongoDB (个人学习记录)

<dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-data-mongodb</artifactId>
    </dependency>

spring:
  data:
    mongodb:
      uri: mongodb://IP*******:27017/库名

import lombok.Data;
import org.springframework.data.mongodb.core.mapping.Document;
import org.springframework.data.mongodb.core.mapping.Field;
import java.io.Serializable;
@Data
@Document(collection = "user")
public class User implements Serializable {
    private static final Long serialVersionUID = 1l;
    @Field("id")
    private String id;
    public String getId() {
        return id;
    }
    public void setId(String id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public String getPhone() {
        return phone;
    }
    public void setPhone(String phone) {
        this.phone = phone;
    }
    public String getAdd() {
        return add;
    }
    public void setAdd(String add) {
        this.add = add;
    }
    @Field("name")
    private String name;
    @Field("phone")
    private String phone;
    @Field("add")
    private String add;
}

import java.util.HashMap;
public interface IUserService {
    HashMap<Object, Object> queryList();
    User findUserByUserName(String name);
    long updateUser(User user);
    boolean deleteUserById(String id);
    String saveUser(User user);
}

import com.mongodb.client.result.UpdateResult;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
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 org.springframework.stereotype.Service;
import cn.javaguide.springbootkafka01sendobjects.service.IUserService;
import javax.annotation.Resource;
import java.util.HashMap;
import java.util.List;
@Service
public class UserServiceImpl implements IUserService {
    private static Logger logger = LoggerFactory.getLogger(UserContrller.class);
    @Resource
    private MongoTemplate mongoTemplate;
    /**
     * 时间 2022年3月1日
     * 查询user表所有集合
     *
     * @return
     */
    @Override
    public HashMap<Object, Object> queryList() {
        HashMap<Object, Object> map = new HashMap<>();
        Query query = new Query();
        List<User> all = mongoTemplate.findAll(User.class);
//        List<AlarmRtTime> all1 = mongoTemplate.findAll(AlarmRtTime.class);
        long count = mongoTemplate.count(query, User.class);
//        boolean empty = all.isEmpty();
//        Assert.isTrue(empty==false,"***********************查询信息为空***********************");
//        Assert.isNull(all,"***********************查询信息为空***********************");
        User user = new User();
        if (all.isEmpty()) {
//        user.setId("001");
//        user.setName("tom");
//        user.setPhone("1234568910");
            System.out.println("***********************查询信息为空***********************");
//            all.add(user);
        }
        map.put("user table info :", all);
        map.put("user table count :", count);
//        map.put("user table AlarmRtTime :", all1);
        return map;
    }
    @Override
    public String saveUser(User user) {
        mongoTemplate.save(user);
        return "添加成功";
    }
    /**
     * 根据name查询mongodb信息
     * date 2022年3月1日 15点19分
     *
     * @param name
     * @return
     */
    @Override
    public User findUserByUserName(String name) {
        Query query = new Query(Criteria.where("name").is(name));
        User user = mongoTemplate.findOne(query, User.class);
//        Assert.isNull(user,"***********************查询信息为空***********************");
        return user;
    }
    /**
     * 根据id，修改用户信息
     * 时间 2022年3月1日
     *
     * @param user
     */
    @Override
    public long updateUser(User user) {
        System.out.println(user);
        Query query = new Query(Criteria.where("id").is(user.getId()));
        Update update = new Update().set("name", user.getName()).set("phone", user.getPhone()).set("add", user.getAdd());
        //更新查询返回结果集的第一条
        UpdateResult result = mongoTemplate.updateFirst(query, update, User.class);
        //更新查询返回结果集的所有
        // mongoTemplate.updateMulti(query,update,UserEntity.class);
        if (result != null) {
            return result.getMatchedCount();
        } else {
            return 0;
        }
    }
    /**
     * 根据id删除对象
     * 时间 2022年3月1日
     * @param id
     */
    @Override
    public boolean deleteUserById(String id) {
        Query query=new Query(Criteria.where("id").is(id));
        User user = mongoTemplate.findOne(query, User.class);
        System.out.println(user);
//        Assert.notNull(user,"找不到对应id数据");
        if (user==null){
            System.out.println("找不到对应id数据");
            return false;
        }
        mongoTemplate.remove(query,User.class);
        return true;
    }
}

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import cn.javaguide.springbootkafka01sendobjects.service.IUserService;
import javax.annotation.Resource;
import java.util.HashMap;
@RestController
@RequestMapping("/user")
public class UserContrller {
    private static Logger logger = LoggerFactory.getLogger(UserContrller.class);
    @Resource
    private IUserService userService;
    @PostMapping("/getInfo")
    private HashMap<Object, Object> getAllInfo() {
        return userService.queryList();
    }
    @PostMapping("/findUserByUserName")
    private User findUserByUserName(String name) {
        return userService.findUserByUserName(name);
    }
    @PostMapping("/updateUser")
    private long updateUser(@RequestBody User user) {
        return userService.updateUser(user);
    }
    @PostMapping("/deleteUserById")
    private boolean deleteUserById(String id) {
        return userService.deleteUserById(id);
    }
    @PostMapping("/saveUser")
    private String saveUser(@RequestBody User user) {
        return userService.saveUser(user);
    }
}