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

}

到此这篇关于spring boot集成mongodb的增删改查的示例代码的文章就介绍到这了,更多相关springboot mongodb增删改查内容请搜索快网idc以前的文章或继续浏览下面的相关文章希望大家以后多多支持快网idc！

原文链接：https://blog.csdn.net/qq_17010193/article/details/114861203

相关文章

微信

快网idc优惠网

QQ交流群