添加依赖
-
<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);
-
}
-
}
关注公号“Java高级架构师”,回复“面试题” 获取：高清3585页大厂面试真题
转载：https://blog.csdn.net/qq_17010193/article/details/114861203
查看评论