springboot mongo CRUD+
工具
idea
maven
postman
navicat
文件結(jié)構(gòu)
代碼
pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
? ? ? ? xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
? ? <modelVersion>4.0.0</modelVersion>
? ? <parent>
? ? ? ? <groupId>org.springframework.boot</groupId>
? ? ? ? <artifactId>spring-boot-starter-parent</artifactId>
? ? ? ? <version>2.5.2</version>
? ? ? ? <relativePath/> <!-- lookup parent from repository -->
? ? </parent>
? ? <groupId>com.vue</groupId>
? ? <artifactId>demo</artifactId>
? ? <version>0.0.1-SNAPSHOT</version>
? ? <name>demo</name>
? ? <description>Demo project for Spring Boot</description>
? ? <properties>
? ? ? ? <java.version>1.8</java.version>
? ? </properties>
? ? <dependencies>
? ? ? ? <dependency>
? ? ? ? ? ? <groupId>org.springframework.boot</groupId>
? ? ? ? ? ? <artifactId>spring-boot-starter-web</artifactId>
? ? ? ? </dependency>
? ? ? ? <dependency>
? ? ? ? ? ? <groupId>org.projectlombok</groupId>
? ? ? ? ? ? <artifactId>lombok</artifactId>
? ? ? ? ? ? <version>1.16.20</version>
? ? ? ? </dependency>
? ? ? ? <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-data-mongodb -->
? ? ? ? <dependency>
? ? ? ? ? ? <groupId>org.springframework.boot</groupId>
? ? ? ? ? ? <artifactId>spring-boot-starter-data-mongodb</artifactId>
? ? ? ? </dependency>
? ? ? ? <!-- https://mvnrepository.com/artifact/org.mockito/mockito-core -->
? ? ? ? <dependency>
? ? ? ? ? ? <groupId>org.mockito</groupId>
? ? ? ? ? ? <artifactId>mockito-core</artifactId>
? ? ? ? ? ? <version>2.23.4</version>
? ? ? ? ? ? <scope>compile</scope>
? ? ? ? </dependency>
? ? ? ? <dependency>
? ? ? ? ? ? <groupId>org.junit.jupiter</groupId>
? ? ? ? ? ? <artifactId>junit-jupiter-api</artifactId>
? ? ? ? ? ? <version>5.3.2</version>
? ? ? ? ? ? <scope>compile</scope>
? ? ? ? </dependency>
? ? </dependencies>
? ? <build>
? ? ? ? <plugins>
? ? ? ? ? ? <plugin>
? ? ? ? ? ? ? ? <groupId>org.springframework.boot</groupId>
? ? ? ? ? ? ? ? <artifactId>spring-boot-maven-plugin</artifactId>
? ? ? ? ? ? ? ? <configuration>
? ? ? ? ? ? ? ? ? ? <mainClass>com.example.demo.DemoApplication</mainClass>
? ? ? ? ? ? ? ? </configuration>
? ? ? ? ? ? </plugin>
? ? ? ? </plugins>
? ? </build>
</project>
application.properties
server.port=8888
spring.data.mongodb.database=test
spring.data.mongodb.host=localhost
spring.data.mongodb.port=27017
User
public class User {
? ? private int id;
? ? private String name;
? ? private String password;
? ? public int getId() {
? ? ? ? return id;
? ? }
? ? public void setId(int id) {
? ? ? ? this.id = id;
? ? }
? ? public String getName() {
? ? ? ? return name;
? ? }
? ? public void setName(String name) {
? ? ? ? this.name = name;
? ? }
? ? public String getPassword() {
? ? ? ? return password;
? ? }
? ? public void setPassword(String password) {
? ? ? ? this.password = password;
? ? }
}
UserRepository
public interface UserRepository extends MongoRepository<User,Integer> {
? ? User getByName(String name);
}
UserService
public interface UserService {
? ? public void saveUser(User user);
? ? public void removeUserByUserName(String name,String collectionName);
? ? public void updatePasswordByName(User user);
? ? public List<User> getByUserName(String name,String collectionName);
? ? public List<User> getByUserNameLike(String name, String collectionName);
? ? public void getByUserPage();
? ? public List<User> selectByRegex(String name,String collectionName);
? ? public long countByName(String name,String collectionName);
? ? public List<User> selectByAggregation(String name,String collectionName);
//? ? public List<User> selectNameBySort(String name,String collectionName);
? ? public List<User> selectByNameSort(String name,String collectionName);
? ? public List<User> selectByCompare(String password,String collectionName);
? ? public List<User> selectByAnd(String name,String password,String collectionName);
? ? public List<User> selectByIn(String name,List<String> names,String collectionName);
? ? public List<User> selectByPage(String name,String collectionName,int page,int size);
}
UserServiceImpl
@Service
public class UserServiceImpl implements UserService{
? ? @Resource
? ? private MongoTemplate mongoTemplate;
? ? @Resource
? ? private UserRepository userRepository;
? ? @Override
? ? public void saveUser(User user){
? ? ? ? userRepository.save(user);
? ? }
? ? @Override
? ? public void removeUserByUserName(String name,String collectionName){
? ? ? ? Query query = new Query(new Criteria("name").is(name));//
? ? ? ? mongoTemplate.remove(query,collectionName);
? ? }
? ? @Override
? ? public void updatePasswordByName(User user){
? ? ? ? Query query = new Query(new Criteria("name").is(user.getName()));//new Criteria("id").is(user.getId())
? ? ? ? Update update = new Update().set("password",user.getPassword());
? ? ? ? mongoTemplate.updateMulti(query,update,User.class);
? ? }
? ? @Override
? ? public List<User> getByUserName(String name,String collectionName){
? ? ? ? Query query = Query.query(Criteria.where("name").is(name));
? ? ? ? List<User> result = mongoTemplate.find(query, User.class, collectionName);
? ? ? ? return result;
? ? }
? ? @Override
? ? public List<User> getByUserNameLike(String name,String collectionName){
? ? ? ? Query query = Query.query(Criteria.where("name").all(Arrays.asList(name)));
? ? ? ? List<User> result = mongoTemplate.find(query, User.class,collectionName);
? ? ? ? //滿足所有條件的數(shù)據(jù)
? ? ? ? return result;
? ? }
? ? @Override
? ? public void getByUserPage(){
? ? }
? ? @Override
? ? public List<User> selectByRegex(String name,String collectionName){
? ? ? ? Query query = new Query(Criteria.where("name").regex(name));
? ? ? ? List<User> result = mongoTemplate.find(query, User.class,collectionName);
? ? ? ? return result;
? ? }
? ? @Override
? ? public long countByName(String name,String collectionName){
? ? ? ? Query query = new Query(Criteria.where("name").is(name));
? ? ? ? long num = mongoTemplate.count(query,collectionName);
? ? ? ? return num;
? ? }
? ? @Override//聚合的先后順序很重要
? ? public List<User> selectByAggregation(String name,String collectionName) {
? ? ? ? Aggregation aggregation = Aggregation.newAggregation(
? ? ? ? ? ? ? ? Aggregation.match(Criteria.where("name").is(name)),
? ? ? ? ? ? ? ? Aggregation.limit(3),
? ? ? ? ? ? ? ? Aggregation.skip(1l),
? ? ? ? ? ? ? ? Aggregation.sort(Sort.Direction.DESC,"password"),//不能以id降序
? ? ? ? ? ? ? ? Aggregation.limit(3)
//? ? ? ? ? ? ? ? ,Aggregation.group("name").count().as("userName")
? ? ? ? );
? ? ? ? AggregationResults<User> result = mongoTemplate.aggregate(aggregation,collectionName, User.class);
? ? ? ? return result.getMappedResults();
? ? }
//? ? @Override
//? ? public List<User> selectNameBySort(String name,String collectionName){
//? ? ? ? Query query = Query.query(Criteria.where("name").is(name).within());
//? ? }
? ? @Override
? ? public List<User> selectByNameSort(String name,String collectionName) {
? ? ? ? Query query = new Query();
? ? ? ? query = Query.query(Criteria.where("name").is(name));
? ? ? ? List<User> list = mongoTemplate.find(query, User.class, collectionName);
? ? ? ? return list;
? ? }
? ? @Override
? ? public List<User> selectByCompare(String password,String collectionName){
? ? ? ? Query query = Query.query(Criteria.where("password").gte(password));
? ? ? ? List<User> list = mongoTemplate.find(query, User.class,collectionName);
? ? ? ? return list;
? ? }
? ? @Override
? ? public List<User> selectByAnd(String name,String password,String collectionName){
? ? ? ? Query query = Query.query(Criteria.where("name").is(name).and("password").is(password));
? ? ? ? List<User> list = mongoTemplate.find(query, User.class,collectionName);
? ? ? ? return list;
? ? }
? ? @Override
? ? public List<User> selectByIn(String name,List<String> names,String collectionName){
? ? ? ? Query query = Query.query(Criteria.where("name").is(name).in(names));
? ? ? ? List<User> list = mongoTemplate.find(query, User.class,collectionName);
? ? ? ? return list;
? ? }
//? ? @Override
//? ? public List<User> selectByOr(String name,List<String> names,String collectionName){
//? ? ? ? Query query = Query.query(Criteria.where("name"));
//? ? ? ? List<User> list = mongoTemplate.find(query, User.class,collectionName);
//? ? ? ? return list;
//? ? }
? ? @Override
? ? public List<User> selectByPage(String name,String collectionName,int page,int size){
? ? ? ? Query query = Query.query(Criteria.where("name").is(name));
//? ? ? ? Query query = new Query();
? ? ? ? PageRequest pageRequest = PageRequest.of(page,size);
? ? ? ? query.with(pageRequest);
? ? ? ? List<User> list = mongoTemplate.find(query, User.class,collectionName);
? ? ? ? return list;
? ? }
}
UserController
@RestController
@RequestMapping("/test")
public class UserController {
? ? @Resource
? ? private UserService userService;
? ? @RequestMapping("/save")
? ? @ResponseBody? ? //id被系統(tǒng)默認(rèn)為主鍵。如果同一個(gè)id save兩個(gè)不同用戶荤崇，原來的用戶會(huì)被取代
? ? public String saveUser(@RequestBody User user){
? ? ? ? userService.saveUser(user);
? ? ? ? return "插入成功";
? ? }
? ? @RequestMapping("/remove")
? ? @ResponseBody
? ? public String removeUserByName(@RequestParam String name,@RequestParam String collectionName){
? ? ? ? userService.removeUserByUserName(name,collectionName);
? ? ? ? return "刪除成功";
? ? }
? ? @RequestMapping("/updatePasswordByName")//把所有名字為指定名字的用戶的密碼換掉
? ? @ResponseBody
? ? public String updatePasswordByName(@RequestBody User user){
? ? ? ? userService.updatePasswordByName(user);
? ? ? ? return "更新成功";
? ? }
//? ? @RequestMapping("/getUserByPage")
//? ? @ResponseBody
//? ? public User getUserByPage(@RequestParam String name){
//? ? ? ? User user = userService.getByUserName(name);
//? ? ? ? return user;
//? ? }
? ? @RequestMapping("/getUserByName")
? ? @ResponseBody
? ? public List<User> getByUserName(@RequestParam String name,@RequestParam String collectionName){
? ? ? ? List<User> list = userService.getByUserName(name,collectionName);
? ? ? ? return list;
? ? }
? ? @RequestMapping("/getUserByNameLike")
? ? @ResponseBody
? ? public List<User> getUserByNameLike(@RequestParam String name,@RequestParam String collectionName){
? ? ? ? List<User> list = userService.getByUserNameLike(name,collectionName);
? ? ? ? return list;
? ? }
? ? @RequestMapping("/countByName")
? ? @ResponseBody
? ? public long countByName(@RequestParam String name,@RequestParam String collectionName){
? ? ? ? long count = userService.countByName(name,collectionName);
? ? ? ? return count;
? ? }
? ? @RequestMapping("/selectByRegex")
? ? @ResponseBody
? ? public List<User> selectByRegex(String name,String collectionName){
? ? ? ? List<User> list = userService.selectByRegex(name,collectionName);
? ? ? ? return list;
? ? }
? ? @RequestMapping("/selectByAggregation")
? ? @ResponseBody
? ? public List<User> selectByAggregation(String name,String collectionName){
? ? ? ? List<User> groupResult = userService.selectByAggregation(name,collectionName);
? ? ? ? return groupResult;
? ? }
? ? @RequestMapping("/selectBySort")
? ? @ResponseBody
? ? public List<User> selectNameBySort(String name,String collectionName){
? ? ? ? List<User> sortResult = userService.selectByNameSort(name,collectionName);
? ? ? ? return sortResult;
? ? }
? ? @RequestMapping("/selectByCompare")
? ? @ResponseBody
? ? public List<User> selectByCompare(String password,String collectionName){
? ? ? ? List<User> compareResult = userService.selectByCompare(password,collectionName);
? ? ? ? return compareResult;
? ? }
? ? @RequestMapping("/selectByAnd")
? ? @ResponseBody
? ? public List<User> selectByAnd(String name,String password,String collectionName){
? ? ? ? List<User> compareResult = userService.selectByAnd(name,password,collectionName);
? ? ? ? return compareResult;
? ? }
? ? @RequestMapping("/selectByIn")
? ? @ResponseBody
? ? public List<User> selectByOr(@RequestParam String name,@RequestParam List<String> names,@RequestParam String collectionName){
? ? ? ? List<User> compareResult = userService.selectByIn(name,names,collectionName);
? ? ? ? return compareResult;
? ? }
? ? @RequestMapping("/selectByPage")
? ? @ResponseBody
? ? public List<User> selectByPage(@RequestParam String name,
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? @RequestParam String collectionName,
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? @RequestParam int page,//page從0開始算第一頁
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? @RequestParam int size){
? ? ? ? List<User> pageResult = userService.selectByPage(name, collectionName, page, size);
? ? ? ? return pageResult;
? ? }
}
