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

   }

}