mall整合Mongodb实现文档操作

文主要讲解mall整合Mongodb的过程,以实现商品浏览记录在Mongodb中的添加、删除、查询为例。

项目使用框架介绍

Mongodb

Mongodb是为快速开发互联网Web应用而构建的数据库系统,其数据模型和持久化策略就是为了构建高读/写吞吐量和高自动灾备伸缩性的系统。

Mongodb的安装和使用

1.下载Mongodb安装包,下载地址:https://fastdl.mongodb.org/win32/mongodb-win32-x86_64-2008plus-ssl-3.2.21-signed.msi

2.选择安装路径进行安装

mall整合Mongodb实现文档操作

3.在安装路径下创建data\db和data\log两个文件夹

4.在安装路径下创建mongod.cfg配置文件

systemLog:    destination: file    path: D:\developer\env\MongoDB\data\log\mongod.logstorage:    dbPath: D:\developer\env\MongoDB\data\db

4.安装为服务(运行命令需要用管理员权限)

D:\developer\env\MongoDB\bin\mongod.exe --config "D:\developer\env\MongoDB\mongod.cfg" --install

5.服务相关命令

启动服务:net start MongoDB关闭服务:net stop MongoDB移除服务:D:\developer\env\MongoDB\bin\mongod.exe --remove

6.下载客户端程序:https://download.robomongo.org/1.2.1/windows/robo3t-1.2.1-windows-x86_64-3e50a65.zip

7.解压到指定目录,打开robo3t.exe并连接到localhost:27017

Spring Data Mongodb

和Spring Data Elasticsearch类似,Spring Data Mongodb是Spring提供的一种以Spring Data风格来操作数据存储的方式,它可以避免编写大量的样板代码。

常用注解

  • @Document:标示映射到Mongodb文档上的领域对象

  • @Id:标示某个域为ID域

  • @Indexed:标示某个字段为Mongodb的索引字段

Sping Data方式的数据操作

继承MongoRepository接口可以获得常用的数据操作方法

可以使用衍生查询

在接口中直接指定查询方法名称便可查询,无需进行实现,以下为根据会员id按时间倒序获取浏览记录的例子。

/** * 会员商品浏览历史Repository * Created by macro on 2018/8/3. */public interface MemberReadHistoryRepository extends MongoRepository<MemberReadHistory,String> {    /**     * 根据会员id按时间倒序获取浏览记录     * @param memberId 会员id     */    List<MemberReadHistory> findByMemberIdOrderByCreateTimeDesc(Long memberId);}

在idea中直接会提示对应字段

使用@Query注解可以用Mongodb的JSON查询语句进行查询
@Query("{ 'memberId' : ?0 }")List<MemberReadHistory> findByMemberId(Long memberId);

整合Mongodb实现文档操作

在pom.xml中添加相关依赖

<!---mongodb相关依赖--><dependency>  <groupId>org.springframework.boot</groupId>  <artifactId>spring-boot-starter-data-mongodb</artifactId></dependency>

修改SpringBoot配置文件

修改application.yml文件,在spring:data节点下添加Mongodb相关配置。

mongodb:  host: localhost # mongodb的连接地址  port: 27017 # mongodb的连接端口号  database: mall-port # mongodb的连接的数据库

添加会员浏览记录文档对象MemberReadHistory

文档对象的ID域添加@Id注解,需要检索的字段添加@Indexed注解。


  1. package com.macro.mall.tiny.nosql.mongodb.document;


  2. import org.springframework.data.annotation.Id;

  3. import org.springframework.data.mongodb.core.index.Indexed;

  4. import org.springframework.data.mongodb.core.mapping.Document;


  5. import java.util.Date;


  6. /**

  7. * 用户商品浏览历史记录

  8. * Created by macro on 2018/8/3.

  9. */

  10. @Document

  11. public class MemberReadHistory {

  12.    @Id

  13.    private String id;

  14.    @Indexed

  15.    private Long memberId;

  16.    private String memberNickname;

  17.    private String memberIcon;

  18.    @Indexed

  19.    private Long productId;

  20.    private String productName;

  21.    private String productPic;

  22.    private String productSubTitle;

  23.    private String productPrice;

  24.    private Date createTime;


  25.    //省略了所有getter和setter方法


  26. }

添加MemberReadHistoryRepository接口用于操作Mongodb

继承MongoRepository接口,这样就拥有了一些基本的Mongodb数据操作方法,同时定义了一个衍生查询方法。


  1. package com.macro.mall.tiny.nosql.mongodb.repository;



  2. import com.macro.mall.tiny.nosql.mongodb.document.MemberReadHistory;

  3. import org.springframework.data.mongodb.repository.MongoRepository;


  4. import java.util.List;


  5. /**

  6. * 会员商品浏览历史Repository

  7. * Created by macro on 2018/8/3.

  8. */

  9. public interface MemberReadHistoryRepository extends MongoRepository<MemberReadHistory,String> {

  10.    /**

  11.     * 根据会员id按时间倒序获取浏览记录

  12.     * @param memberId 会员id

  13.     */

  14.    List<MemberReadHistory> findByMemberIdOrderByCreateTimeDesc(Long memberId);

  15. }

添加MemberReadHistoryService接口


  1. package com.macro.mall.tiny.service;



  2. import com.macro.mall.tiny.nosql.mongodb.document.MemberReadHistory;


  3. import java.util.List;


  4. /**

  5. * 会员浏览记录管理Service

  6. * Created by macro on 2018/8/3.

  7. */

  8. public interface MemberReadHistoryService {

  9.    /**

  10.     * 生成浏览记录

  11.     */

  12.    int create(MemberReadHistory memberReadHistory);


  13.    /**

  14.     * 批量删除浏览记录

  15.     */

  16.    int delete(List<String> ids);


  17.    /**

  18.     * 获取用户浏览历史记录

  19.     */

  20.    List<MemberReadHistory> list(Long memberId);

  21. }

添加MemberReadHistoryService接口实现类MemberReadHistoryServiceImpl


  1. package com.macro.mall.tiny.service.impl;


  2. import com.macro.mall.tiny.nosql.mongodb.document.MemberReadHistory;

  3. import com.macro.mall.tiny.nosql.mongodb.repository.MemberReadHistoryRepository;

  4. import com.macro.mall.tiny.service.MemberReadHistoryService;

  5. import org.springframework.beans.factory.annotation.Autowired;

  6. import org.springframework.stereotype.Service;


  7. import java.util.ArrayList;

  8. import java.util.Date;

  9. import java.util.List;


  10. /**

  11. * 会员浏览记录管理Service实现类

  12. * Created by macro on 2018/8/3.

  13. */

  14. @Service

  15. public class MemberReadHistoryServiceImpl implements MemberReadHistoryService {

  16.    @Autowired

  17.    private MemberReadHistoryRepository memberReadHistoryRepository;

  18.    @Override

  19.    public int create(MemberReadHistory memberReadHistory) {

  20.        memberReadHistory.setId(null);

  21.        memberReadHistory.setCreateTime(new Date());

  22.        memberReadHistoryRepository.save(memberReadHistory);

  23.        return 1;

  24.    }


  25.    @Override

  26.    public int delete(List<String> ids) {

  27.        List<MemberReadHistory> deleteList = new ArrayList<>();

  28.        for(String id:ids){

  29.            MemberReadHistory memberReadHistory = new MemberReadHistory();

  30.            memberReadHistory.setId(id);

  31.            deleteList.add(memberReadHistory);

  32.        }

  33.        memberReadHistoryRepository.deleteAll(deleteList);

  34.        return ids.size();

  35.    }


  36.    @Override

  37.    public List<MemberReadHistory> list(Long memberId) {

  38.        return memberReadHistoryRepository.findByMemberIdOrderByCreateTimeDesc(memberId);

  39.    }

  40. }

添加MemberReadHistoryController定义接口


  1. package com.macro.mall.tiny.controller;


  2. import com.macro.mall.tiny.common.api.CommonResult;

  3. import com.macro.mall.tiny.nosql.mongodb.document.MemberReadHistory;

  4. import com.macro.mall.tiny.service.MemberReadHistoryService;

  5. import io.swagger.annotations.Api;

  6. import io.swagger.annotations.ApiOperation;

  7. import org.springframework.beans.factory.annotation.Autowired;

  8. import org.springframework.stereotype.Controller;

  9. import org.springframework.web.bind.annotation.*;


  10. import java.util.List;


  11. /**

  12. * 会员商品浏览记录管理Controller

  13. * Created by macro on 2018/8/3.

  14. */

  15. @Controller

  16. @Api(tags = "MemberReadHistoryController", description = "会员商品浏览记录管理")

  17. @RequestMapping("/member/readHistory")

  18. public class MemberReadHistoryController {

  19.    @Autowired

  20.    private MemberReadHistoryService memberReadHistoryService;


  21.    @ApiOperation("创建浏览记录")

  22.    @RequestMapping(value = "/create", method = RequestMethod.POST)

  23.    @ResponseBody

  24.    public CommonResult create(@RequestBody MemberReadHistory memberReadHistory) {

  25.        int count = memberReadHistoryService.create(memberReadHistory);

  26.        if (count > 0) {

  27.            return CommonResult.success(count);

  28.        } else {

  29.            return CommonResult.failed();

  30.        }

  31.    }


  32.    @ApiOperation("删除浏览记录")

  33.    @RequestMapping(value = "/delete", method = RequestMethod.POST)

  34.    @ResponseBody

  35.    public CommonResult delete(@RequestParam("ids") List<String> ids) {

  36.        int count = memberReadHistoryService.delete(ids);

  37.        if (count > 0) {

  38.            return CommonResult.success(count);

  39.        } else {

  40.            return CommonResult.failed();

  41.        }

  42.    }


  43.    @ApiOperation("展示浏览记录")

  44.    @RequestMapping(value = "/list", method = RequestMethod.GET)

  45.    @ResponseBody

  46.    public CommonResult<List<MemberReadHistory>> list(Long memberId) {

  47.        List<MemberReadHistory> memberReadHistoryList = memberReadHistoryService.list(memberId);

  48.        return CommonResult.success(memberReadHistoryList);

  49.    }

  50. }

进行接口测试

添加商品浏览记录到Mongodb

查询Mongodb中的商品浏览记录

mall整合Mongodb实现文档操作mall整合Mongodb实现文档操作


上一篇:mall整合RabbitMQ实现延迟消息


下一篇:mall整合SpringBoot+MyBatis搭建基本骨架