mall整合Mongodb实现文档操作

2023-01-29 18:48:04

文主要讲解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. 


    3. 

  3. import org.springframework.data.annotation.Id;
    4. 

  4. import org.springframework.data.mongodb.core.index.Indexed;
    5. 

  5. import org.springframework.data.mongodb.core.mapping.Document;
    6. 


    7. 

  7. import java.util.Date;
    8. 


    9. 

  9. /**
    10. 

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

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

  12.  */
    13. 

  13. @Document
    14. 

  14. public class MemberReadHistory {
    15. 

  15.     @Id
    16. 

  16.     private String id;
    17. 

  17.     @Indexed
    18. 

  18.     private Long memberId;
    19. 

  19.     private String memberNickname;
    20. 

  20.     private String memberIcon;
    21. 

  21.     @Indexed
    22. 

  22.     private Long productId;
    23. 

  23.     private String productName;
    24. 

  24.     private String productPic;
    25. 

  25.     private String productSubTitle;
    26. 

  26.     private String productPrice;
    27. 

  27.     private Date createTime;
    28. 


    29. 

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


    31. 

  31. }
    32. 



添加MemberReadHistoryRepository接口用于操作Mongodb


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




    

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


    3. 


    4. 

  4. import com.macro.mall.tiny.nosql.mongodb.document.MemberReadHistory;
    5. 

  5. import org.springframework.data.mongodb.repository.MongoRepository;
    6. 


    7. 

  7. import java.util.List;
    8. 


    9. 

  9. /**
    10. 

  10.  * 会员商品浏览历史Repository
    11. 

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

  12.  */
    13. 

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

  14.     /**
    15. 

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

  16.      * @param memberId 会员id
    17. 

  17.      */
    18. 

  18.     List<MemberReadHistory> findByMemberIdOrderByCreateTimeDesc(Long memberId);
    19. 

  19. }
    20. 



添加MemberReadHistoryService接口




    

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


    3. 


    4. 

  4. import com.macro.mall.tiny.nosql.mongodb.document.MemberReadHistory;
    5. 


    6. 

  6. import java.util.List;
    7. 


    8. 

  8. /**
    9. 

  9.  * 会员浏览记录管理Service
    10. 

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

  11.  */
    12. 

  12. public interface MemberReadHistoryService {
    13. 

  13.     /**
    14. 

  14.      * 生成浏览记录
    15. 

  15.      */
    16. 

  16.     int create(MemberReadHistory memberReadHistory);
    17. 


    18. 

  18.     /**
    19. 

  19.      * 批量删除浏览记录
    20. 

  20.      */
    21. 

  21.     int delete(List<String> ids);
    22. 


    23. 

  23.     /**
    24. 

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

  25.      */
    26. 

  26.     List<MemberReadHistory> list(Long memberId);
    27. 

  27. }
    28. 



添加MemberReadHistoryService接口实现类MemberReadHistoryServiceImpl




    

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


    3. 

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

  4. import com.macro.mall.tiny.nosql.mongodb.repository.MemberReadHistoryRepository;
    5. 

  5. import com.macro.mall.tiny.service.MemberReadHistoryService;
    6. 

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

  7. import org.springframework.stereotype.Service;
    8. 


    9. 

  9. import java.util.ArrayList;
    10. 

  10. import java.util.Date;
    11. 

  11. import java.util.List;
    12. 


    13. 

  13. /**
    14. 

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

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

  16.  */
    17. 

  17. @Service
    18. 

  18. public class MemberReadHistoryServiceImpl implements MemberReadHistoryService {
    19. 

  19.     @Autowired
    20. 

  20.     private MemberReadHistoryRepository memberReadHistoryRepository;
    21. 

  21.     @Override
    22. 

  22.     public int create(MemberReadHistory memberReadHistory) {
    23. 

  23.         memberReadHistory.setId(null);
    24. 

  24.         memberReadHistory.setCreateTime(new Date());
    25. 

  25.         memberReadHistoryRepository.save(memberReadHistory);
    26. 

  26.         return 1;
    27. 

  27.     }
    28. 


    29. 

  29.     @Override
    30. 

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

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

  32.         for(String id:ids){
    33. 

  33.             MemberReadHistory memberReadHistory = new MemberReadHistory();
    34. 

  34.             memberReadHistory.setId(id);
    35. 

  35.             deleteList.add(memberReadHistory);
    36. 

  36.         }
    37. 

  37.         memberReadHistoryRepository.deleteAll(deleteList);
    38. 

  38.         return ids.size();
    39. 

  39.     }
    40. 


    41. 

  41.     @Override
    42. 

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

  43.         return memberReadHistoryRepository.findByMemberIdOrderByCreateTimeDesc(memberId);
    44. 

  44.     }
    45. 

  45. }
    46. 



添加MemberReadHistoryController定义接口




    

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


    3. 

  3. import com.macro.mall.tiny.common.api.CommonResult;
    4. 

  4. import com.macro.mall.tiny.nosql.mongodb.document.MemberReadHistory;
    5. 

  5. import com.macro.mall.tiny.service.MemberReadHistoryService;
    6. 

  6. import io.swagger.annotations.Api;
    7. 

  7. import io.swagger.annotations.ApiOperation;
    8. 

  8. import org.springframework.beans.factory.annotation.Autowired;
    9. 

  9. import org.springframework.stereotype.Controller;
    10. 

  10. import org.springframework.web.bind.annotation.*;
    11. 


    12. 

  12. import java.util.List;
    13. 


    14. 

  14. /**
    15. 

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

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

  17.  */
    18. 

  18. @Controller
    19. 

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

  20. @RequestMapping("/member/readHistory")
    21. 

  21. public class MemberReadHistoryController {
    22. 

  22.     @Autowired
    23. 

  23.     private MemberReadHistoryService memberReadHistoryService;
    24. 


    25. 

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

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

  27.     @ResponseBody
    28. 

  28.     public CommonResult create(@RequestBody MemberReadHistory memberReadHistory) {
    29. 

  29.         int count = memberReadHistoryService.create(memberReadHistory);
    30. 

  30.         if (count > 0) {
    31. 

  31.             return CommonResult.success(count);
    32. 

  32.         } else {
    33. 

  33.             return CommonResult.failed();
    34. 

  34.         }
    35. 

  35.     }
    36. 


    37. 

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

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

  39.     @ResponseBody
    40. 

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

  41.         int count = memberReadHistoryService.delete(ids);
    42. 

  42.         if (count > 0) {
    43. 

  43.             return CommonResult.success(count);
    44. 

  44.         } else {
    45. 

  45.             return CommonResult.failed();
    46. 

  46.         }
    47. 

  47.     }
    48. 


    49. 

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

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

  51.     @ResponseBody
    52. 

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

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

  54.         return CommonResult.success(memberReadHistoryList);
    55. 

  55.     }
    56. 

  56. }
    57. 



进行接口测试


添加商品浏览记录到Mongodb




查询Mongodb中的商品浏览记录


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





 

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

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