您的位置: 首页  >  文章  >  SpringCloud集成Spring Data MongoDB

SpringCloud集成Spring Data MongoDB

分类: 文章 • 2022-10-11 16:03:54

文章目录

MongoDB

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

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

  MongoDB这种非关系型数据库与我们应用的最广泛的传统型数据库，比如说MySQL相比较，其基本的异同在我之前所写的文章中有所论述，详情请参考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，因而这里就不再复述。

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

  结果如下图所示：

SpringCloud集成Spring Data MongoDB

  其在MongoDB中存储的信息如下：
SpringCloud集成Spring Data MongoDB

相关推荐