Spring Boot整合Mongdb

港控/mmm° 2022-02-17 15:08 146阅读 0赞

## 创建项目 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDkxNDc4NA_size_16_color_FFFFFF_t_70]

## 1.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 http://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.1.4.RELEASE</version>
    		<relativePath/> 
    	</parent>
    	<groupId>com.mr</groupId>
    	<artifactId>springboot_mongdb</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<name>springboot_mongdb</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-data-mongodb</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    
    		<dependency>
    			<groupId>org.projectlombok</groupId>
    			<artifactId>lombok</artifactId>
    			<optional>true</optional>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</dependency>
    	</dependencies>
    
    	<build>
    		<plugins>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    			</plugin>
    		</plugins>
    	</build>
    
    </project>

## 2.application.yml ##

spring:
      data:
        mongodb:
          uri:  mongodb://localhost:27017
          database:   #指定数据库名字
    server:
      port: 8085

## 3.Car.java ##

package com.mr.model;
    
    import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.NoArgsConstructor;
    import org.springframework.data.annotation.Id;
    
    /**
     * 
     */
    @Data
    @AllArgsConstructor
    @NoArgsConstructor
    public class Car {
        @Id
        private Integer carId;
        private String carName;
        private Integer carPrice;
    }

## 4.CarController.java ##

package com.mr.controller;
    
    import com.mr.model.Car;
    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.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.util.List;
    
    /**
     * 
     */
    @RestController
    public class CarController {
        @Autowired
        private MongoTemplate mongoTemplate;
    
        /**
         * 新增
         */
        @RequestMapping("addCar")
        public String addCar(){
            Car car=new Car(2,"法拉利",1200);
            mongoTemplate.save(car);
            return "新增成功";
        }
        /**
         * 查询所有
         */
        @RequestMapping("queryCar")
        public List<Car> queryCar(){
            List<Car> list= mongoTemplate.findAll(Car.class);
            return list;
        }
        /**
         * 条件查询
         */
        @RequestMapping("queryTiao")
        public String queryTiao(){
            //条件查询需要用到Query和Criteria
            Query query=new Query();
            Criteria where=new Criteria();
            where.and("carPrice").is(1200);
            query.addCriteria(where);
             List<Car> cars=mongoTemplate.find(query,Car.class);
            System.err.println(cars);
            return "ok";
    
        }
        //多条件查询
        @RequestMapping("queryDuo")
        public String queryDuo(){
            Query query=new Query();
            Criteria where=new Criteria();
            where.and("carPrice").is(1200);
            Query query2=new Query();
            Criteria where2=new Criteria();
            where2.and("carName").is("劳斯莱斯");
            query.addCriteria(new Criteria().andOperator(where,where2));
            List<Car> list = mongoTemplate.find(query, Car.class);
            System.err.println(list);
            return "yes";
        }
        /**
         *分页查询
         */
        @RequestMapping("queryFen")
        public String queryFen(){
            int page=1; //当前页
            int rows=2; //每页条数
            Query query = new Query();
            query.skip((page-1)*rows).limit(rows);
            List<Car> cars = mongoTemplate.find(query, Car.class);
            System.out.println(cars);
            return "success";
        }
        /**
         * 修改
         */
        @RequestMapping("update")
        public String update(){
            Query query=new Query();
            Criteria where=new Criteria();
            where.and("carPrice").is(1200);
            query.addCriteria(where);
            Update update=new Update();
            update.set("carName","兰博基尼");
            //mongoTemplate.updateMulti(query,update,Car.class);//修改所有符合条件的数据
             mongoTemplate.updateFirst(query,update,Car.class); //修改第一条符合条件的数据
            return "修改成功";
    
        }
        /**
         * 删除
         */
        @RequestMapping("delete")
        public String delete(){
            Query query=new Query();
            Criteria where=new Criteria();
            where.and("carName").is("大奔");
            query.addCriteria(where);
            mongoTemplate.remove(query,Car.class);
            return "删除成功";
    
        }
    
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDkxNDc4NA_size_16_color_FFFFFF_t_70]: /images/20220217/f3d0f47c10fb4928a64d83a508e3dfe5.png