SpringCloud集成Spring Data MongoDB

我不是女神ヾ 2022-03-10 13:52 499阅读 0赞

### 文章目录 ###

*  MongoDB
 *  源码
 *   *  spring-mongodb
 *  运行

# MongoDB #

MongoDB 是一个基于分布式文件存储的数据库。由 C++ 语言编写。旨在为 WEB 应用提供可扩展的高性能数据存储解决方案的非关系型数据库。

MongoDB 是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。

MongoDB这种非关系型数据库与我们应用的最广泛的传统型数据库，比如说MySQL相比较，其基本的异同在我之前所写的文章中有所论述，详情请参考[Mysql与MongoDB的语法比较（CRUD）][Mysql_MongoDB_CRUD]

最后再说一下MongoDB的主要特点，其主要特点如下：

>  *  MongoDB 是一个面向文档存储的数据库，操作起来比较简单和容易。
>  *  你可以在MongoDB记录中设置任何属性的索引 (如：FirstName=“Sameer”,Address=“8 Gandhi Road”)来实现更快的排序。
>  *  你可以通过本地或者网络创建数据镜像，这使得MongoDB有更强的扩展性。
>  *  如果负载的增加（需要更多的存储空间和更强的处理能力） ，它可以分布在计算机网络中的其他节点上这就是所谓的分片。
>  *  Mongo支持丰富的查询表达式。查询指令使用JSON形式的标记，可轻易查询文档中内嵌的对象及数组。
>  *  MongoDb 使用update()命令可以实现替换完成的文档（数据）或者一些指定的数据字段 。
>  *  Mongodb中的Map/reduce主要是用来对数据进行批量处理和聚合操作。
>  *  Map和Reduce。Map函数调用emit(key,value)遍历集合中所有的记录，将key与value传给Reduce函数进行处理。
>  *  Map函数和Reduce函数是使用Javascript编写的，并可以通过db.runCommand或mapreduce命令来执行MapReduce操作。
>  *  GridFS是MongoDB中的一个内置功能，可以用于存放大量小文件。
>  *  MongoDB允许在服务端执行脚本，可以用Javascript编写某个函数，直接在服务端执行，也可以把函数的定义存储在服务端，下次直接调用即可。
>  *  MongoDB支持各种编程语言:RUBY，PYTHON，JAVA，C++，PHP，C\#等多种语言。
>  *  MongoDB安装简单。

# 源码 #

这里的父模块源码和之前的一样，详情请参考之前的文章[SpringCloud集成Spring Data Redis][SpringCloud_Spring Data Redis]，因而这里就不再复述。

## spring-mongodb ##

这里由于直接采用了SpringCloud的默认设置，因而无需在配置相应的配置文件，默认的，MongoDB端口号为27017。

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">
        <parent>
            <artifactId>springcloud-parent2</artifactId>
            <groupId>com.lyc</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>spring-mongodb</artifactId>
    
        <name>spring-mongodb</name>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-mongodb</artifactId>
            </dependency>
        </dependencies>
    
    </project>

PersonMongoDBApplication启动类

package com.lyc.springMongodb;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    /** * @author: zhangzhenyi * @date: 2019/3/11 10:57 * @description: PersonMongodb启动类 **/
    @SpringBootApplication
    public class PersonMongoDBApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(PersonMongoDBApplication.class,args);
        }
    
    }

PersonMongoDBController类

package com.lyc.springMongodb.controller;
    
    import com.lyc.springMongodb.entity.Location;
    import com.lyc.springMongodb.entity.Person;
    import com.lyc.springMongodb.service.PersonMongoDBRepository;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.util.Collection;
    import java.util.LinkedHashSet;
    import java.util.List;
    import java.util.UUID;
    
    /** * @author: zhangzhenyi * @date: 2019/3/11 10:43 * @description: PersonMongoDB Controller **/
    @RestController
    public class PersonMongoDBController { 
    
        @Autowired
        PersonMongoDBRepository personMongoDBRepository;
    
        /** * 保存数据 * @return */
        @GetMapping("/save")
        public Person save(){ 
            Person person = Person.builder()
                    .id(UUID.randomUUID().toString())
                    .name("zhangsan")
                    .age(32)
                    .build();
            Collection<Location> locationCollection = new LinkedHashSet<>();
            Location location = Location.builder()
                    .place("hangzhou")
                    .year("2002")
                    .build();
            locationCollection.add(location);
            person.setLocations(locationCollection);
            return personMongoDBRepository.save(person);
        }
    
        /** * 根据名称查询数据 * @param name 用户名 * @return */
        @GetMapping("/queryByName")
        public Person queryByName(String name){ 
            return personMongoDBRepository.findByName(name);
        }
    
        /** * 根据年龄查询数据 * @param age 用户年龄 * @return */
        @GetMapping("/queryByAge")
        public List<Person> queryByAge(Integer age){ 
            return personMongoDBRepository.withQueryFindByAge(age);
        }
    }

PersonMongoDBRepository类

package com.lyc.springMongodb.service;
    
    import com.lyc.springMongodb.entity.Person;
    import org.springframework.data.mongodb.repository.MongoRepository;
    import org.springframework.data.mongodb.repository.Query;
    
    import java.util.List;
    
    /** * @author: zhangzhenyi * @date: 2019/3/11 10:39 * @description: PersonMongoDB Repository **/
    public interface PersonMongoDBRepository extends MongoRepository<Person,String> { 
    
        Person findByName(String name);
    
        @Query("{'age':?0}")
        List<Person> withQueryFindByAge(Integer age);
    
    }

Person实体类

package com.lyc.springMongodb.entity;
    
    import lombok.*;
    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.Collection;
    import java.util.LinkedHashSet;
    
    /** * @author: zhangzhenyi * @date: 2019/3/10 11:02 * @description: Person实体类 **/
    @Getter
    @Setter
    @Builder
    @NoArgsConstructor
    @AllArgsConstructor
    @Document
    public class Person { 
    
        @Id
        private String id;       //主键id
        private String name;    //姓名
        private Integer age;    //年龄q
        @Field("locs")
        private Collection<Location> locations = new LinkedHashSet<>();
    
    }

Location实体类

package com.lyc.springMongodb.entity;
    
    import lombok.*;
    
    /** * @author: zhangzhenyi * @date: 2019/3/11 10:37 * @description: Location实体类 **/
    @Getter
    @Setter
    @Builder
    @NoArgsConstructor
    @AllArgsConstructor
    public class Location { 
    
        private String place;
        private String year;
    
    }

# 运行 #

当我们在Restlet中输入下面的地址时，即可看到数据被成功保存到MongoDB中

http://localhost:8080/save

结果如下图所示：

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

其在MongoDB中存储的信息如下：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1paWTEwNzg2ODkyNzY_size_16_color_FFFFFF_t_70 1]

[Mysql_MongoDB_CRUD]: https://blog.csdn.net/ZZY1078689276/article/details/54178005
[SpringCloud_Spring Data Redis]: https://blog.csdn.net/ZZY1078689276/article/details/88384650
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1paWTEwNzg2ODkyNzY_size_16_color_FFFFFF_t_70]: /images/20220310/c9ccbbc6b531458f87454f308b2a92ec.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1paWTEwNzg2ODkyNzY_size_16_color_FFFFFF_t_70 1]: /images/20220310/3d32eca683dd4671a45569d26e615f89.png