spring boot集成mongodb的增刪改查的示例代碼

更新時間：2021年03月22日 09:30:15 作者：公號:Java高級架構(gòu)師

這篇文章主要介紹了spring boot集成mongodb的增刪改查的示例代碼，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

添加依賴

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

properties配置

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

創(chuàng)建實體類

@Document為mongodb集合名

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;
  }
}

controller

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);
  }
}

到此這篇關(guān)于spring boot集成mongodb的增刪改查的示例代碼的文章就介紹到這了,更多相關(guān)springboot mongodb增刪改查內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: