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配置文件

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. import org.springframework.data.annotation.Id;

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

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

6. 
   

7. import java.util.Date;

8. 
   

9. /**

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

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

12. */

13. @Document

14. public class MemberReadHistory {

15.    @Id

16.    private String id;

17.    @Indexed

18.    private Long memberId;

19.    private String memberNickname;

20.    private String memberIcon;

21.    @Indexed

22.    private Long productId;

23.    private String productName;

24.    private String productPic;

25.    private String productSubTitle;

26.    private String productPrice;

27.    private Date createTime;

28. 
    

29.    //省略了全部getter和setter方法

30. 
    

31. }

添加MemberReadHistoryRepository接口用于操做Mongodb

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

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

2. 
   

3. 
   

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

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

6. 
   

7. import java.util.List;

8. 
   

9. /**

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

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

12. */

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

14.    /**

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

16.     * @param memberId 会员id

17.     */

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

19. }

添加MemberReadHistoryService接口

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

2. 
   

3. 
   

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

5. 
   

6. import java.util.List;

7. 
   

8. /**

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

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

11. */

12. public interface MemberReadHistoryService {

13.    /**

14.     * 生成浏览记录

15.     */

16.    int create(MemberReadHistory memberReadHistory);

17. 
    

18.    /**

19.     * 批量删除浏览记录

20.     */

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

22. 
    

23.    /**

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

25.     */

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

27. }

添加MemberReadHistoryService接口实现类MemberReadHistoryServiceImpl

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

2. 
   

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

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

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

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

7. import org.springframework.stereotype.Service;

8. 
   

9. import java.util.ArrayList;

10. import java.util.Date;

11. import java.util.List;

12. 
    

13. /**

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

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

16. */

17. @Service

18. public class MemberReadHistoryServiceImpl implements MemberReadHistoryService {

19.    @Autowired

20.    private MemberReadHistoryRepository memberReadHistoryRepository;

21.    @Override

22.    public int create(MemberReadHistory memberReadHistory) {

23.        memberReadHistory.setId(null);

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

25.        memberReadHistoryRepository.save(memberReadHistory);

26.        return 1;

27.    }

28. 
    

29.    @Override

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

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

32.        for(String id:ids){

33.            MemberReadHistory memberReadHistory = new MemberReadHistory();

34.            memberReadHistory.setId(id);

35.            deleteList.add(memberReadHistory);

36.        }

37.        memberReadHistoryRepository.deleteAll(deleteList);

38.        return ids.size();

39.    }

40. 
    

41.    @Override

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

43.        return memberReadHistoryRepository.findByMemberIdOrderByCreateTimeDesc(memberId);

44.    }

45. }

添加MemberReadHistoryController定义接口

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

2. 
   

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

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

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

6. import io.swagger.annotations.Api;

7. import io.swagger.annotations.ApiOperation;

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

9. import org.springframework.stereotype.Controller;

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

11. 
    

12. import java.util.List;

13. 
    

14. /**

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

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

17. */

18. @Controller

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

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

21. public class MemberReadHistoryController {

22.    @Autowired

23.    private MemberReadHistoryService memberReadHistoryService;

24. 
    

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

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

27.    @ResponseBody

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

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

30.        if (count > 0) {

31.            return CommonResult.success(count);

32.        } else {

33.            return CommonResult.failed();

34.        }

35.    }

36. 
    

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

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

39.    @ResponseBody

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

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

42.        if (count > 0) {

43.            return CommonResult.success(count);

44.        } else {

45.            return CommonResult.failed();

46.        }

47.    }

48. 
    

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

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

51.    @ResponseBody

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

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

54.        return CommonResult.success(memberReadHistoryList);

55.    }

56. }

进行接口测试

添加商品浏览记录到Mongodb

查询Mongodb中的商品浏览记录