爆破专栏丨SpringBoot2.x系列教程之整合MongoDB缓存商品信息

• Mongo最大的特点是他支持的查询语言非常强大，其语法有点类似于面向对象的查询语言，几乎可以实现类似关系数据库单表查询的绝大部分功能，而且还支持对数据建立索引。

• 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安装简单。

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
复制

server:
  port: 8080
spring:
  application:
    name: spirng-boot-mongodb
  data:
    mongodb:
      host: localhost   #同127.0.0.1
      port: 27017
      database: db01    #指定操作的数据库
复制

• @Id - 文档的唯一标识，在mongodb中为ObjectId，它是唯一的，通过时间戳+机器标识+进程ID+自增计数器（确保同一秒内产生的Id不会冲突）构成。

• @Document - 声明此类为mongodb的文档实体类，通过collection参数指定这个类对应的文档名称。@Document(collection=”mongodb”) mongodb对应表

• @Indexed - 声明该字段需要索引，建索引可以大大的提高查询效率。

• @CompoundIndex - 复合索引的声明，建复合索引可以有效地提高多字段的查询效率。

• @Transient - 映射忽略的字段，该字段不会保存到mongodb。

• @PersistenceConstructor - 声明构造函数，作用是把从数据库取出的数据实例化为对象。该构造函数传入的值为从DBObject中取出的数据。

server:
  port: 8080
spring:
  application:
    name: spirng-boot-mongodb
  data:
    mongodb:
      host: localhost   #同127.0.0.1
      port: 27017
      database: db01    #指定操作的数据库package com.yyg.boot.entity;

import lombok.Data;
import lombok.ToString;
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;

/**
 * @Author 一一哥Sun
 * @Date Created in 2020/4/9
 * @Description Description
 */
@Data
@ToString
@Document(collection = "product")
public class Product {

    @Id
    private String id;

    /**
     * 价格
     */
    @Field("price")
    private Integer price;

    /**
     * 商品名称
     */
    @Field("name")
    private String name;

    /**
     * 商品简介
     */
    @Field("info")
    private String info;

    /**
     * 商品发布者
     */
    @Field("publisher")
    private String publisher;

    /**
     * 创建时间
     */
    @Field("createTime")
    private Date createTime;

    /**
     * 修改时间
     */
    @Field("updateTime")
    private Date updateTime;

}package com.yyg.boot.entity;

import lombok.Data;
import lombok.ToString;
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;

/**
 * @Author 一一哥Sun
 * @Date Created in 2020/4/9
 * @Description Description
 */
@Data
@ToString
@Document(collection = "product")
public class Product {

    @Id
    private String id;

    /**
     * 价格
     */
    @Field("price")
    private Integer price;

    /**
     * 商品名称
     */
    @Field("name")
    private String name;

    /**
     * 商品简介
     */
    @Field("info")
    private String info;

    /**
     * 商品发布者
     */
    @Field("publisher")
    private String publisher;

    /**
     * 创建时间
     */
    @Field("createTime")
    private Date createTime;

    /**
     * 修改时间
     */
    @Field("updateTime")
    private Date updateTime;

}
复制

package com.yyg.boot.service;

import com.yyg.boot.entity.Product;

import java.awt.print.Book;
import java.util.List;

/**
 * @Author 一一哥Sun
 * @Date Created in 2020/4/9
 * @Description Description
 */
public interface ProductService {

    String saveProduct(Product product);

    /**
     * 查询所有
     */
    List<Product> findAll();


    /***
     * 根据id查询
     */
    Product getProductById(String id);

    /**
     * 根据名称查询
     */
    Product getProductByName(String name);

    /**
     * 更新对象
     */
    String updateProduct(Product product);

    /***
     * 删除对象
     */
    String deleteProduct(Product product);

    /**
     * 根据id删除
     */
    String deleteProductById(String id);

}
复制

6.2 定义ProductServiceImpl实现类

在service层编写一个具体的实现类，实现商品信息操作。

package com.yyg.boot.service.impl;

import com.yyg.boot.entity.Product;
import com.yyg.boot.service.ProductService;
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.stereotype.Service;

import java.util.Date;
import java.util.List;

/**
 * @Author 一一哥Sun
 * @Date Created in 2020/4/9
 * @Description Description
 */
@Service
public class ProductServiceImpl implements ProductService {

    @Autowired
    private MongoTemplate mongoTemplate;

    @Override
    public String saveProduct(Product product) {
        product.setCreateTime(new Date());
        product.setUpdateTime(new Date());
        mongoTemplate.save(product);
        return "添加成功";
    }

    @Override
    public List<Product> findAll() {
        return mongoTemplate.findAll(Product.class);
    }

    @Override
    public Product getProductById(String id) {
        Query query = new Query(Criteria.where("_id").is(id));
        return mongoTemplate.findOne(query, Product.class);
    }

    @Override
    public Product getProductByName(String name) {
        Query query = new Query(Criteria.where("name").is(name));
        return mongoTemplate.findOne(query, Product.class);
    }

    @Override
    public String updateProduct(Product product) {
        Query query = new Query(Criteria.where("_id").is(product.getId()));
        Update update = new Update().set("publisher", product.getPublisher())
                .set("info", product.getInfo())
                .set("updateTime", new Date());
        return "success";
    }

    @Override
    public String deleteProduct(Product product) {
        mongoTemplate.remove(product);
        return "success";
    }

    @Override
    public String deleteProductById(String id) {
        //findOne
        Product product = getProductById(id);
        //delete
        deleteProduct(product);
        return "success";
    }

}
复制

7. 创建Controller接口

package com.yyg.boot.web;

import com.yyg.boot.entity.Product;
import com.yyg.boot.service.ProductService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.List;

/**
 * @Author 一一哥Sun
 * @Date Created in 2020/4/9
 * @Description Description
 */
@RestController
@RequestMapping("/product")
public class ProductController {

    @Autowired
    private ProductService productService;

    @PostMapping("")
    public String saveProduct(@RequestBody Product product) {
        return productService.saveProduct(product);
    }

    @GetMapping("")
    public List<Product> findAll() {
        return productService.findAll();
    }

    @GetMapping("/id/{id}")
    public Product findOne(@PathVariable("id") String id) {
        return productService.getProductById(id);
    }

    @GetMapping("/name/{name}")
    public Product findOneByName(@PathVariable("name") String name) {
        return productService.getProductByName(name);
    }

    @PostMapping("/update")
    public String update(@RequestBody Product product) {
        return productService.updateProduct(product);
    }

    @DeleteMapping("/delOne")
    public String delOne(@RequestBody Product product) {
        return productService.deleteProduct(product);
    }

    @DeleteMapping("/{id}")
    public String delById(@PathVariable("id") String id) {
        return productService.deleteProductById(id);
    }

}
复制

package com.yyg.boot;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * @Author 一一哥Sun
 * @Date Created in 2020/4/9
 * @Description Description
 */
@SpringBootApplication
public class MongoApplication {

    public static void main(String[] args) {
        SpringApplication.run(MongoApplication.class, args);
    }

}

}
复制