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.选择安装路径进行安装

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

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

1. systemLog:

2. destination: file

3. path: D:\developer\env\MongoDB\data\log\mongod.log

4. storage:

5. dbPath: D:\developer\env\MongoDB\data\db

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

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

5.服务相关命令

1. 启动服务：net start MongoDB

2. 关闭服务：net stop MongoDB

3. 移除服务：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按时间倒序获取浏览记录的例子。

1. /**

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

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

4. */

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

6. /**

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

8. * @param memberId 会员id

9. */

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

11. }

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

使用@Query注解可以用Mongodb的JSON查询语句进行查询

1. @Query("{ 'memberId' : ?0 }")

2. List<MemberReadHistory> findByMemberId(Long memberId);

整合Mongodb实现文档操作

在pom.xml中添加相关依赖

1. <!---mongodb相关依赖-->

2. <dependency>

3. <groupId>org.springframework.boot</groupId>

4. <artifactId>spring-boot-starter-data-mongodb</artifactId>

5. </dependency>

修改SpringBoot配置文件

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

1. mongodb:

2. host: localhost # mongodb的连接地址

3. port: 27017 # mongodb的连接端口号

4. 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中的商品浏览记录

项目源码地址

https://github.com/macrozheng/mall-learning/tree/master/mall-tiny-07

推荐阅读

---

欢迎关注，点个在看