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

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

2021-08-26 11:54Java高级架构师 Java教程

这篇文章主要介绍了spring boot集成mongodb的增删改查的示例代码，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

添加依赖

				?

									<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

创建实体类

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

									  }

									}