spring boot集成mongodb的增删改查的示例代码

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

spring.data.mongodb.host=127.0.0.1
spring.data.mongodb.port=27017
spring.data.mongodb.database=enterprise_dc_db
spring.data.mongodb.username=enterprise_dc_dba
spring.data.mongodb.password=123456
 
server.port=8081

package com.example.springbootmongodb.domian; 
import org.springframework.data.mongodb.core.mapping.Document;
 
@Document(collection = "mydb")
public class Users {
  private String userId;
  private String name;
  private Integer age;
 
  public String getUserId() {
    return userId;
  }
 
  public void setUserId(String userId) {
    this.userId = userId;
  }
 
  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;
  }
}

package com.example.springbootmongodb.controller;
public class ResultObject {
 
  private int code;
 
  private String desc;
 
  private Object data;
 
  public ResultObject() {
 
  }
 
  public ResultObject(int code) {
    this.code = code;
  }
 
  public ResultObject(int code, Object data) {
    this.code = code;
    this.data = data;
  }
 
  public Object getData() {
    return data;
  }
 
  public void setData(Object data) {
    this.data = data;
  }
 
  public int getCode() {
    return code;
  }
 
  public void setCode(int code) {
    this.code = code;
  }
 
  public String getDesc() {
    return desc;
  }
 
  public void setDesc(String desc) {
    this.desc = desc;
  }
}

package com.example.springbootmongodb.controller;
 
import com.example.springbootmongodb.domian.Users;
import org.springframework.beans.factory.annotation.Autowired;
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.web.bind.annotation.*;
 
import java.util.List;
 
@RequestMapping("/mongo")
@RestController
public class UserController {
 
  @Autowired
  private MongoTemplate mongoTemplate;
 
  @RequestMapping(value = "/hello",method = RequestMethod.GET)
  public String hello(){
    return "hello";
  }
 
  /**
   * 新增
   */
  @ResponseBody
  @RequestMapping(value = "/insert", method = RequestMethod.GET)
  public ResultObject insert(){
    Users user = new Users();
    user.setUserId("1002");
    user.setName("eric");
    user.setAge(18);
    mongoTemplate.insert(user);
  return new ResultObject(200);
  }
 
  /**删除
   *
   * @return
   */
  @ResponseBody
  @RequestMapping("/delete")
  public ResultObject delete(){
    Query query = Query.query(Criteria.where("userId").is("1001"));
    mongoTemplate.remove(query,"mydb");
    return new ResultObject(200);
  }
 
  /**
   * 删除
   * @return
   */
  @ResponseBody
  @RequestMapping("/update")
  public ResultObject update(){
    Query query = Query.query(Criteria.where("userId").is("1002"));
    Update update = new Update();
    update.set("name","name1");
    update.set("age",18);
    mongoTemplate.updateFirst(query,update,"mydb");
    return new ResultObject(200);
  }
 
  /**
   * 查询
   * @return
   */
  @ResponseBody
  @RequestMapping("/query")
  public ResultObject query(){
    Query query = Query.query(Criteria.where("userId").is("1001"));
    List<Users> list = mongoTemplate.find(query,Users.class);
    return new ResultObject(200,list);
  }
}