使用Spring Data MongoDB联合MongoDB实现商品游览记录基础功能
(一)使用相关框架
1.MongoDB
Mongodb是为快速开发互联网Web应用而构建的数据库系统，其数据模型和持久化策略就是为了构建高读/写吞吐量和高自动灾备伸缩性的系统。
使用docker安装MongoDB
参考链接
https://www.jianshu.com/p/626e4cc11982
2.SpringDataMongoDB
Spring Data Mongodb是Spring提供的一种以Spring Data风格来操作数据存储的方式，它可以避免编写大量的样板代码
常用注解
@Document:标示映射到Mongodb文档上的领域对象
@Id:标示某个域为ID域
@Indexed:标示某个字段为Mongodb的索引字段
SpringDataMongoDB数据操作
继承MongoRepository接口可以获得常用的MongoDB的数据操作方法
也可以自定义衍生方法
在接口中直接指定查询方法名称便可查询，无需进行实现
/**
* 根据会员id按时间倒序获取浏览记录
* @param memberId 会员id
*/
List<MemberReadHistory> findByMemberIdOrderByCreateTimeDesc(Long memberId);
使用@Query注解可以使用MongoDB的json查询语句进行查询
@Query("{ 'memberId' : ?0 }")
List<MemberReadHistory> findByMemberId(Long memberId);
(二)MongoDB实现商品游览记录相关操作
1.在pom.xml中引入MongoDB相关依赖
<!---mongodb相关依赖-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
2.修改springboot配置文件application.yml,spring.data节点下增加MongoDB配置
mongodb:
host: localhost # mongodb的连接地址
port: 27017 # mongodb的连接端口号
database: mall-port # mongodb的连接的数据库
3.增加会员游览记录文档对象MemberReadHistory
文档对象的ID域添加@Id注解，需要检索的字段添加@Indexed注解。
package com.mall.mallmybatis.nosql.mongodb.document;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.index.Indexed;
import org.springframework.data.mongodb.core.mapping.Document;
import java.util.Date;
/**
* 用户商品浏览历史记录
* @author wangxing
* @version 2020/6/25 8:47 Administrator
*/
@Document
public class MemberReadHistory {
@Id
private String id;
@Indexed
private Long memberId;
private String memberNickname;
private String memberIcon;
@Indexed
private Long productId;
private String productName;
private String productPic;
private String productSubTitle;
private String productPrice;
private Date createTime;
/***省略getter/setter*/
}
4.添加MemberReadHistoryRepository接口用于操作MongoDB
继承MongoRepository接口，这样就拥有了一些基本的Mongodb数据操作方法，同时定义了一个衍生查询方法。
package com.mall.mallmybatis.nosql.mongodb.repository;
import com.mall.mallmybatis.nosql.mongodb.document.MemberReadHistory;
import org.springframework.data.mongodb.repository.MongoRepository;
import java.util.List;
/**
* 会员商品浏览历史Repository
* @author wangxing
* @version 2020/6/25 8:49 Administrator
*/
public interface MemberReadHistoryRepository extends MongoRepository<MemberReadHistory,String> {
/**
* 根据会员id按时间倒序获取浏览记录
* @param memberId 会员id
*/
List<MemberReadHistory> findByMemberIdOrderByCreateTimeDesc(Long memberId);
}
5.添加MemberReadHistory接口,定义操作
package com.mall.mallmybatis.service;
import com.mall.mallmybatis.nosql.mongodb.document.MemberReadHistory;
import java.util.List;
/**
* 会员浏览记录管理Service
* @author wangxing
* @version 2020/6/25 8:54 Administrator
*/
public interface MemberReadHistoryService {
/**
* 生成浏览记录
*/
int create(MemberReadHistory memberReadHistory);
/**
* 批量删除浏览记录
*/
int delete(List<String> ids);
/**
* 获取用户浏览历史记录
*/
List<MemberReadHistory> list(Long memberId);
}
6.添加MemeberReadHistoryServiceImpl类,实现MemberReadHistoryService接口的具体方法
package com.mall.mallmybatis.service.impl;
import com.mall.mallmybatis.nosql.mongodb.document.MemberReadHistory;
import com.mall.mallmybatis.nosql.mongodb.repository.MemberReadHistoryRepository;
import com.mall.mallmybatis.service.MemberReadHistoryService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
/**
* @author wangxing
* @version 2020/6/25 8:55 Administrator
*/
@Service
public class MemberReadHistoryServiceImpl implements MemberReadHistoryService {
@Autowired
private MemberReadHistoryRepository memberReadHistoryRepository;
/**
* 生成浏览记录
*
* @param memberReadHistory
*/
@Override
public int create(MemberReadHistory memberReadHistory) {
memberReadHistory.setId(null);
memberReadHistory.setCreateTime(new Date());
memberReadHistoryRepository.save(memberReadHistory);
return 1;
}
/**
* 批量删除浏览记录
*
* @param ids
*/
@Override
public int delete(List<String> ids) {
List<MemberReadHistory> deleteList = new ArrayList<>();
for(String id:ids){
MemberReadHistory memberReadHistory = new MemberReadHistory();
memberReadHistory.setId(id);
deleteList.add(memberReadHistory);
}
memberReadHistoryRepository.deleteAll(deleteList);
return ids.size();
}
/**
* 获取用户浏览历史记录
*
* @param memberId
*/
@Override
public List<MemberReadHistory> list(Long memberId) {
return memberReadHistoryRepository.findByMemberIdOrderByCreateTimeDesc(memberId);
}
}
7.添加MemberReadHistoryController,设置对外接口路径,以及swagger文档
package com.mall.mallmybatis.controller;
import com.mall.mallmybatis.common.api.CommonResult;
import com.mall.mallmybatis.nosql.mongodb.document.MemberReadHistory;
import com.mall.mallmybatis.service.MemberReadHistoryService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
* 会员商品浏览记录管理Controller
* @author wangxing
* @version 2020/6/25 8:58 Administrator
*/
@Api(tags = "MemberReadHistoryController",description = "会员商品浏览记录管理")
@Controller
@RequestMapping("/member/readHistory")
public class MemberReadHistoryController {
@Autowired
private MemberReadHistoryService memberReadHistoryService;
@ApiOperation("创建浏览记录")
@RequestMapping(value = "/create", method = RequestMethod.POST)
@ResponseBody
public CommonResult create(@RequestBody MemberReadHistory memberReadHistory) {
int count = memberReadHistoryService.create(memberReadHistory);
if (count > 0) {
return CommonResult.success(count);
} else {
return CommonResult.failed();
}
}
@ApiOperation("删除浏览记录")
@RequestMapping(value = "/delete", method = RequestMethod.POST)
@ResponseBody
public CommonResult delete(@RequestParam("ids") List<String> ids) {
int count = memberReadHistoryService.delete(ids);
if (count > 0) {
return CommonResult.success(count);
} else {
return CommonResult.failed();
}
}
@ApiOperation("展示浏览记录")
@RequestMapping(value = "/list", method = RequestMethod.GET)
@ResponseBody
public CommonResult<List<MemberReadHistory>> list(Long memberId) {
List<MemberReadHistory> memberReadHistoryList = memberReadHistoryService.list(memberId);
return CommonResult.success(memberReadHistoryList);
}
}
