1.新建一个项目：项目大框如下
2.引入pom依赖：
<!--mongodb -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
3、修改application.properties配置文件
spring.mvc.view.prefix=/WEB-INF/jsp/
spring.mvc.view.suffix=.jsp
server.port=8812
spring.jackson.default-property-inclusion=non_null
###datasource
########################################################
spring.data.mongodb.uri=mongodb://localhost:27017/sms
4、编写实体类User.java
package com.hc.entity;
import org.springframework.data.mongodb.core.mapping.Document;
import org.springframework.data.mongodb.core.mapping.Field;
@Document(collection = "sms")
public class User {
@Field("userid")
private String userid;
@Field("name")
private String name;
@Field("age")
private int age;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
public String getUserid() {
return userid;
}
public void setUserid(String userid) {
this.userid = userid;
}
}
5.编写IUserService 接口
package com.hc.service;
import java.util.List;
import com.hc.entity.User;
import com.mongodb.client.result.UpdateResult;
public interface IUserService {
public void save(User user);
public void insert(User user);
public void remove(String uid);
public UpdateResult update(User user);
public List<User> findByUid(String uid);
public List<User> findByUidAndTimestamp(String uid,String name);
public List<User> page(int page,String uid);
}
6.编写UserService
package com.hc.service.impl;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Sort;
import org.springframework.data.mongodb.core.MongoOperations;
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.stereotype.Service;
import com.hc.entity.User;
import com.hc.service.IUserService;
import com.mongodb.client.result.UpdateResult;
@Service("userService")
public class UserService implements IUserService {
@Autowired
private MongoOperations mongoOperations;
/*@Autowired
private MongoTemplate mongoTemplate;*/
//save存在则更新，不存在则插入
public void save(User user){
mongoOperations.save(user);
}
//insert存在则不做处理，不存在则插入
public void insert(User user){
mongoOperations.insert(user);
}
//根据userid删除文档
public void remove(String uid){
Query query = new Query();
query.addCriteria(Criteria.where("userid").is(uid));
mongoOperations.remove(query,User.class);
}
//根据id更新文档
public UpdateResult update(User user){
Query query = new Query();
query.addCriteria(Criteria.where("userid").is(user.getUserid()));
Update update = new Update();
update.set("name",user.getName());
update.set("age",user.getAge());
return mongoOperations.updateFirst(query, update,User.class); //只修改第一个数据
//return mongoOperations.updateMulti(query,update,User.class).getN(); //修改所有符合数据
}
//单条件查询，find查询所有
public List<User> findByUid(String uid){
Query query = new Query();
query.addCriteria(Criteria.where("userid").is(uid));
return mongoOperations.find(query,User.class);
}
//多条件查询，find查询所有
public List<User> findByUidAndTimestamp(String uid,String name){
Query query = new Query();
query.addCriteria(Criteria.where("userid").is(uid).and("name").is(name));
return mongoOperations.find(query,User.class);
}
//根据uid分页查询
public List<User> page(int page,String uid){
Query query = new Query();
query.addCriteria(Criteria.where("userid").is(uid));
query.with(new Sort(new Sort.Order(Sort.Direction.DESC,"age")));
query.limit(5);
query.skip((page-1)*2);
return mongoOperations.find(query,User.class);
}
}
7.编写UserController 控制层
package com.hc.controller;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.hc.entity.User;
import com.hc.service.IUserService;
@RestController()
@RequestMapping(value = "/User", produces = MediaType.APPLICATION_JSON_VALUE)
public class UserController {
@Autowired
private IUserService userService;
//添加用户
@RequestMapping("save")
public String save() {
User user = new User();
user.setUserid("1.0");
user.setName("ss");
user.setAge(2000);
//userService.save(user);
userService.insert(user);
return "SSUCCESS";
}
//根据userid删除用户
@RequestMapping("deleteByuserid")
public String deleteByuserid(String userid) {
userService.remove(userid);
return "SSUCCESS";
}
//根据id更新文档
@RequestMapping("updateByuserid")
public String updateByusserid() {
User user = new User();
user.setUserid("1.0");
user.setName("sss");
user.setAge(20);
userService.update(user);
return "SSUCCESS";
}
//单条件查询，find查询所有
@RequestMapping("findByuserid")
public List<User> findByuserid(String userid) {
return userService.findByUid(userid);
}
//多条件查询，find查询所有
@RequestMapping("findByuseridandname")
public List<User> findByuseridandname(String userid,String name) {
return userService.findByUidAndTimestamp(userid, name);
}
//根据uid分页查询
@RequestMapping("page")
public List<User> page(int page,String userid){
return userService.page(page, userid);
}
}
8.编写MongoConfig 配置
package com.hc.config;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.beans.factory.NoSuchBeanDefinitionException;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.mongodb.MongoDbFactory;
import org.springframework.data.mongodb.core.convert.*;
import org.springframework.data.mongodb.core.mapping.MongoMappingContext;
/**
* @description:
* When using spring data mongo it by default adds a _class key to your collection to be able to handle inheritance.
* But if your domain model is simple and flat, you can remove it by overriding the default MappingMongoConverter
* @author:@luomouren.
* @Date:2017-12-03 21:26
*/
@Configuration
public class MongoConfig {
@Bean
public MappingMongoConverter mappingMongoConverter(MongoDbFactory factory, MongoMappingContext context, BeanFactory beanFactory) {
DbRefResolver dbRefResolver = new DefaultDbRefResolver(factory);
MappingMongoConverter mappingConverter = new MappingMongoConverter(dbRefResolver, context);
try {
mappingConverter.setCustomConversions(beanFactory.getBean(CustomConversions.class));
} catch (NoSuchBeanDefinitionException ignore) {
}
// Don't save _class to mongo
mappingConverter.setTypeMapper(new DefaultMongoTypeMapper(null));
return mappingConverter;
}
}