springBoot集成mongoDB通俗易懂小demo

今天药忘吃喽~ 2022-09-04 07:48 110阅读 0赞

#### 1.引入 maven ####

注：这里我没有把mongo的maven贴出来，以下是我本地的所有maven依赖，可以看需求引入

<?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.2.6.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>com.springboot</groupId>
        <artifactId>redisdemo</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>redisdemo</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-redis-reactive</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-mail</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-thymeleaf</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
                <dependency>
                    <groupId>org.mybatis</groupId>
                    <artifactId>mybatis</artifactId>
                    <version>3.4.5</version>
                </dependency>
    
                <dependency>
                    <groupId>mysql</groupId>
                    <artifactId>mysql-connector-java</artifactId>
                </dependency>
    
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-mongodb</artifactId>
            </dependency>
    
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>fastjson</artifactId>
                <version>1.2.60</version>
            </dependency>
    
    
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <scope>runtime</scope>
            </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>
                <exclusions>
                    <exclusion>
                        <groupId>org.junit.vintage</groupId>
                        <artifactId>junit-vintage-engine</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
                <version>2.1.3.RELEASE</version>
            </dependency>
    
    
            <dependency>
                <groupId>io.projectreactor</groupId>
                <artifactId>reactor-test</artifactId>
                <scope>test</scope>
            </dependency>
    
            <dependency>
                <groupId>org.redisson</groupId>
                <artifactId>redisson-spring-boot-starter</artifactId>
                <version>3.13.3</version>
            </dependency>
    
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

##### 1.1配置文件配置 #####

spring:
        data:
            mongodb:
                host: 127.0.0.1
                port: 27017
                database: test
                username: admin
                password: 123456

#### 2.建立bean ####

需要了解的知识：MongoDB的注解作用，如：@Document

package com.springboot.redisdemo.bean;
    
    import com.alibaba.fastjson.JSONObject;
    import lombok.Data;
    import org.springframework.data.annotation.Id;
    import org.springframework.data.mongodb.core.mapping.Document;
    import org.springframework.data.mongodb.core.mapping.Field;
    
    import java.util.Date;
    
    @Data
    @Document(collection = "users")
    public class User { 
    
        @Id
        private String id;
    
        @Field("name")
        private String name;
    
        @Field("password")
        private String password;
    
        @Field("address")
        private String address;
    
        @Field("create_time")
        private Date createTime;
    
        @Field("last_update_time")
        private Date lastUpdateTime;
    
        // ... ignore getter and setter methods
    
        @Override
        public String toString() { 
            return JSONObject.toJSONString(this);
        }
    }

### 3.创建返回类 ###

package com.springboot.redisdemo.controller;
    
    import com.alibaba.fastjson.JSONObject;
    import lombok.Data;
    
    import java.util.HashMap;
    import java.util.Map;
    
    @Data
    public class JsonResult { 
    
        /** * 未登录 */
        public static final int NO_LOGIN = 400;
    
        /** * 登录失败 */
        public static final int LOGIN_FAILED = 401;
    
        /** * TOKEN过期 */
        public static final int TOKEN_EXPIRED = 402;
    
        /** * 无权限 */
        public static final int NO_PERMISSION = 403;
    
    
        private Boolean success;
        private Integer code;
        private String msg;
        private Object data;
    
        public JsonResult(Boolean success) { 
            this.success = success;
        }
    
        public JsonResult(Boolean success, String msg) { 
            this.success = success;
            this.msg = msg;
        }
    
        public JsonResult(Integer code, Boolean success, String msg) { 
            this.code = code;
            this.success = success;
            this.msg = msg;
        }
    
        public JsonResult(Boolean success, Object data) { 
            this.success = success;
            this.data = data;
        }
    
        public JsonResult(Boolean success, Integer code, String msg, Object data) { 
            this.success = success;
            this.code = code;
            this.msg = msg;
            this.data = data;
        }
    
        // ... ignore getter and setter methods
    
        public void put(String key, Object value) { 
            if (data == null) { 
                data = new HashMap<>();
            }
            ((Map) data).put(key, value);
        }
    
        public void putAll(Map<String, Object> map) { 
            if (data == null) { 
                data = new HashMap<>();
            }
            ((Map) data).putAll(map);
        }
    
    
    }

#### 4.创建测试controller ####

package com.springboot.redisdemo.controller;
    
    import com.mongodb.client.result.DeleteResult;
    import com.mongodb.client.result.UpdateResult;
    import com.springboot.redisdemo.bean.User;
    import io.micrometer.core.instrument.util.StringUtils;
    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.Date;
    import java.util.List;
    
    @RestController
    @RequestMapping(value = "user")
    public class UserController { 
    
        @Autowired
        private MongoTemplate mongoTemplate;
    
        @GetMapping(value = "")
        public JsonResult list() { 
            List<User> userList = mongoTemplate.findAll(User.class);
            return new JsonResult(true, userList);
        }
    
        public UserController(MongoTemplate mongoTemplate) { 
            this.mongoTemplate = mongoTemplate;
        }
    
        @PostMapping(value = "")
        public JsonResult add(User user) { 
            String msg = verifySaveForm(user);
            if (!StringUtils.isEmpty(msg)) { 
                return new JsonResult(false, msg);
            }
    
            if (user.getId() == null) { 
                user.setCreateTime(new Date());
                user.setLastUpdateTime(new Date());
                User newUser = mongoTemplate.insert(user);
                return new JsonResult(true, newUser);
            } else { 
                Query query = new Query();
                query.addCriteria(Criteria.where("_id").is(user.getId()));
    
                Update update = new Update();
                update.set("name", user.getName());
                update.set("password", user.getPassword());
                update.set("address", user.getAddress());
                update.set("last_update_time", new Date());
    
                UpdateResult updateResult = mongoTemplate.updateFirst(query, update, "user");
                return new JsonResult(true, updateResult);
            }
        }
    
        @DeleteMapping(value = "{id}")
        public JsonResult delete(@PathVariable String id) { 
            Query query = new Query();
            query.addCriteria(Criteria.where("_id").is(id));
            DeleteResult deleteResult = mongoTemplate.remove(query, User.class);
            return new JsonResult(true, deleteResult);
        }
    
        @PostMapping(value = "{id}")
        public JsonResult update(@PathVariable String id) { 
            Query query = new Query(Criteria.where("_id").is(id));
            Update update = new Update().set("password", "777888999");
            UpdateResult deleteResult = mongoTemplate.updateFirst(query,update,User.class);
            return new JsonResult(true, deleteResult);
        }
        // private methods
    
        private String verifySaveForm(User user) { 
            if (user == null || StringUtils.isEmpty(user.getName())) { 
                return "用户名不能为空";
            } else if (user.getPassword() == null) { 
                return "密码不能为空";
            }
    
            return null;
        }
    }

#### 5.测试 ####

##### 5.1新增用户 #####

*  postman请求  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E5ODQxNzEyODE_size_16_color_FFFFFF_t_70]
 *  mongo可视化平台 Robo 3T查看插入结果

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

##### 5.2删除用户 #####

*  postman请求  
    这里的ID是刚刚插入的id 可以看到删除结果1条  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E5ODQxNzEyODE_size_16_color_FFFFFF_t_70 2]
 *  mongo可视化平台 Robo 3T查看删除结果  
    可以看出 刚刚插入的那条是已经删除了。  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E5ODQxNzEyODE_size_16_color_FFFFFF_t_70 3]

##### 5.3 查询用户测试 #####

*  postman测试  
    可以插到我们的collection里面就只有一条数据  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E5ODQxNzEyODE_size_16_color_FFFFFF_t_70 4]
 *  可视化平台看看结果  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E5ODQxNzEyODE_size_16_color_FFFFFF_t_70 5]

可以看到字段什么的也对的上

##### 5.4修改用户数据 #####

*  postman测试
 *  注：这里我们把password改成2222222  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E5ODQxNzEyODE_size_16_color_FFFFFF_t_70 6]
 *  测试结果  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E5ODQxNzEyODE_size_16_color_FFFFFF_t_70 7]
 *  可视化工具查看结果  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E5ODQxNzEyODE_size_16_color_FFFFFF_t_70 8]  
    至此，一套CRUD就结束了

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E5ODQxNzEyODE_size_16_color_FFFFFF_t_70]: /images/20220829/7e1216a8a27c4970ab99abbd899d5242.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E5ODQxNzEyODE_size_16_color_FFFFFF_t_70 1]: /images/20220829/71d2e4d092d84520a8660b4108e9f929.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E5ODQxNzEyODE_size_16_color_FFFFFF_t_70 2]: /images/20220829/5f240145282848a5b300be9d5f840769.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E5ODQxNzEyODE_size_16_color_FFFFFF_t_70 3]: /images/20220829/04d1f89e2d5a4c2f94c3e715c58ebe3b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E5ODQxNzEyODE_size_16_color_FFFFFF_t_70 4]: /images/20220829/038525f3171c49469fd7169f553652f4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E5ODQxNzEyODE_size_16_color_FFFFFF_t_70 5]: /images/20220829/116c2a18c5904ba1ba2ece7c4188be94.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E5ODQxNzEyODE_size_16_color_FFFFFF_t_70 6]: /images/20220829/2083e7428b85485a9fc445704364fbd2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E5ODQxNzEyODE_size_16_color_FFFFFF_t_70 7]: /images/20220829/e76ee084cf544032be1dcd77de0efede.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E5ODQxNzEyODE_size_16_color_FFFFFF_t_70 8]: /images/20220829/c56b787171934f19b5fca52024885583.png