MongoDB【MongoRepository& MongoTemplate】实现增删改查

た入场券 2023-10-09 18:13 79阅读 0赞

**目录**

1：文章评论

1.1：需求分析

1.2：表结构分析

1.3：技术选型

1.3.1：mongodb-driver

1.3.2：SpringDataMongoDB

1.4：文章微服务模块搭建

1.5：文章评论实体类的编写

1.6：文章评论的基本增删改查

1.7：根据上级ID查询文章评论的分页列表

1.8：MongoTemplate实现评论点赞

--------------------

## 1：文章评论 ##

### 1.1：需求分析 ###

某头条的文章评论业务如下： ![b2256f8f11164a4d93adbef3753bae50.png][]

文章示例参考：早晨空腹喝水，是对还是错？ https://www.toutiao.com/a6721476546088927748/

需要实现以下功能：

1 ）基本增删改查 API

2 ）根据文章 id 查询评论

3 ）评论点赞

### 1.2：表结构分析 ###

数据库： articledb

![56ff928eb180427ea5583fcfe662db95.png][]

### 1.3：技术选型 ###

#### 1.3.1：mongodb-driver（了解） ####

mongodb-driver 是 mongo 官方推出的 java 连接 mongoDB 的驱动包，相当于 JDBC 驱动。我们通过一个入门的案例来了解 mongodb-driver 的基本使用。

官方驱动说明和下载： http://mongodb.github.io/mongo-java-driver/

官方驱动示例文档： http://mongodb.github.io/mongo-java-driver/3.8/driver/getting-started/quick-start/

#### 1.3.2：SpringDataMongoDB ####

SpringData 家族成员之一，用于操作 MongoDB 的持久层框架，封装了底层的 mongodb-driver 。

官网主页：  https://projects.spring.io/spring-data-mongodb/

我们十次方项目的吐槽微服务就采用 SpringDataMongoDB 框架。

### 1.4：文章微服务模块搭建 ###

（ 1 ）搭建项目工程 article ， pom.xml 引入依赖：

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.1.6.RELEASE</version>
    <relativePath/> 
    </parent>
    <groupId>cn.itcast</groupId>
    <artifactId>article</artifactId>
    <version>1.0-SNAPSHOT</version>
    <dependencies>
    （2）创建application.yml
    （3）创建启动类
    cn.itcast.article.ArticleApplication
    （4）启动项目，看是否能正常启动，控制台没有错误。
    5.5 文章评论实体类的编写
    创建实体类 创建包cn.itcast.article，包下建包po用于存放实体类，创建实体类
    cn.itcast.article.po.Comment
    <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
    </dependency>
    <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-mongodb</artifactId>
    </dependency>
    </dependencies>
    </project>

（ 2 ）创建 application.yml

spring:
    #数据源配置
    data:
    mongodb:
    # 主机地址
    host: 192.168.40.141
    # 数据库
    database: articledb
    # 默认端口是27017
    port: 27017
    #也可以使用uri连接
    #uri: mongodb://192.168.40.134:27017/articledb

（ 3 ）创建启动类

cn.itcast.article.ArticleApplication

@SpringBootApplication
    public class ArticleApplication {
    public static void main(String[] args) {
    SpringApplication.run(ArticleApplication.class, args);
    }
    }

（ 4 ）启动项目，看是否能正常启动，控制台没有错误。

### 1.5：文章评论实体类的编写 ###

创建实体类 创建包 cn.itcast.article ，包下建包 po 用于存放实体类，创建实体类

/**
    * 文章评论实体类
    */
    //把一个java类声明为mongodb的文档，可以通过collection参数指定这个类对应的文档。
    //@Document(collection="mongodb 对应 collection 名")
    // 若未加 @Document ，该 bean save 到 mongo 的 comment collection
    // 若添加 @Document ，则 save 到 comment collection
    @Document(collection="comment")//可以省略，如果省略，则默认使用类名小写映射集合
    //复合索引
    // @CompoundIndex( def = "{'userid': 1, 'nickname': -1}")
    public class Comment implements Serializable {
    //主键标识，该属性的值会自动对应mongodb的主键字段"_id"，如果该属性名就叫“id”,则该注解可以省略，否则必须写
    @Id
    private String id;//主键
    //该属性对应mongodb的字段的名字，如果一致，则无需该注解
    @Field("content")
    private String content;//吐槽内容
    private Date publishtime;//发布日期
    //添加了一个单字段的索引
    @Indexed
    private String userid;//发布人ID
    private String nickname;//昵称
    private LocalDateTime createdatetime;//评论的日期时间
    private Integer likenum;//点赞数
    private Integer replynum;//回复数
    private String state;//状态
    private String parentid;//上级ID
    private String articleid;

说明：

索引可以大大提升查询效率，一般在查询字段上添加索引，索引的添加可以通过 Mongo 的命令来添加，也可以在 Java 的实体类中通过注解添

加。

1 ）单字段索引注解 @Indexed

org.springframework.data.mongodb.core.index.Indexed.class

声明该字段需要索引，建索引可以大大的提高查询效率。

Mongo 命令参考：

db.comment.createIndex({"userid":1})

2 ）复合索引注解 @CompoundIndex

org.springframework.data.mongodb.core.index.CompoundIndex.class

复合索引的声明，建复合索引可以有效地提高多字段的查询效率。

Mongo 命令参考：

db.comment.createIndex({"userid":1,"nickname":-1})

### 1.6：文章评论的基本增删改查（MongoRepository） ###

（ 1 ）创建数据访问接口  cn.itcast.article 包下创建 dao 包，包下创建接口 cn.itcast.article.dao.CommentRepository

//评论的持久层接口
    public interface CommentRepository extends MongoRepository<Comment,String> {
    }

（ 2 ）创建业务逻辑类  cn.itcast.article 包下创建 service 包，包下创建类

//评论的业务层
    @Service
    public class CommentService {
    //注入dao
    @Autowired
    private CommentRepository commentRepository;
    /**
    * 保存一个评论
    * @param comment
    */
    public void saveComment(Comment comment){
    //如果需要自定义主键，可以在这里指定主键；如果不指定主键，MongoDB会自动生成主键
    //设置一些默认初始值。。。
    //调用dao
    commentRepository.save(comment);
    }
    /**
    * 更新评论
    * @param comment
    */
    public void updateComment(Comment comment){
    //调用dao
    commentRepository.save(comment);
    }
    /**
    * 根据id删除评论
    * @param id
    */
    public void deleteCommentById(String id){
    //调用dao
    commentRepository.deleteById(id);
    }
    /**
    * 查询所有评论
    * @return
    */
    public List<Comment> findCommentList(){
    //调用dao
    return commentRepository.findAll();
    }
    /**
    * 根据id查询评论
    * @param id
    * @return
    */
    public Comment findCommentById(String id){
    //调用dao
    return commentRepository.findById(id).get();
    }
    }

（ 3 ）新建 Junit 测试类，测试保存和查询所有：

//测试评论的业务层
    添加结果：
    5.7 根据上级ID查询文章评论的分页列表
    （1）CommentRepository新增方法定义
    （2）CommentService新增方法
    //SpringBoot的Junit集成测试
    @RunWith(SpringRunner.class)
    //SpringBoot的测试环境初始化，参数：启动类
    @SpringBootTest(classes = ArticleApplication.class)
    public class CommentServiceTest {
    //注入Service
    @Autowired
    private CommentService commentService;
    /**
    * 保存一个评论
    */
    @Test
    public void testSaveComment(){
    Comment comment=new Comment();
    comment.setArticleid("100000");
    comment.setContent("测试添加的数据");
    comment.setCreatedatetime(LocalDateTime.now());
    comment.setUserid("1003");
    comment.setNickname("凯撒大帝");
    comment.setState("1");
    comment.setLikenum(0);
    comment.setReplynum(0);
    commentService.saveComment(comment);
    }
    /**
    * 查询所有数据
    */
    @Test
    public void testFindAll(){
    List<Comment> list = commentService.findCommentList();
    System.out.println(list);
    }
    /**
    * 测试根据id查询
    */
    @Test
    public void testFindCommentById(){
    Comment comment = commentService.findCommentById("5d6a27b81b8d374798cf0b41");
    System.out.println(comment);
    }
    }

![2f857f52aa574d6ba90143432149a804.png][]

### 1.7：根据上级ID查询文章评论的分页列表 ###

（ 1 ） CommentRepository 新增方法定义

> // 根据父 id ，查询子评论的分页列表 
> 
> Page < Comment >  findByParentid ( String  parentid ,  Pageable pageable );

（2）CommentService新增方法

/**
    * 根据父id查询分页列表
    * @param parentid
    * @param page
    * @param size
    * @return
    */
    public Page<Comment> findCommentListPageByParentid(String parentid,int page ,int size){
    return commentRepository.findByParentid(parentid, PageRequest.of(page-1,size));
    }

（ 3 ） junit 测试用例：

cn.itcast.article.service.CommentServiceTest

/**
    * 测试根据父id查询子评论的分页列表
    */
    @Test
    public void testFindCommentListPageByParentid(){
    Page<Comment> pageResponse = commentService.findCommentListPageByParentid("3", 1, 2);
    System.out.println("----总记录数："+pageResponse.getTotalElements());
    System.out.println("----当前页数据："+pageResponse.getContent());
    }

### 1.8：MongoTemplate实现评论点赞 ###

我们可以使用 MongoTemplate 类来实现对某列的操作。

（ 1 ）修改 CommentService

//注入MongoTemplate
    @Autowired
    private MongoTemplate mongoTemplate;
    /**
    * 点赞数+1
    * @param id
    */
    public void updateCommentLikenum(String id){
    //查询对象
    Query query=Query.query(Criteria.where("_id").is(id));
    //更新对象
    Update update=new Update();
    //局部更新，相当于$set
    // update.set(key,value)
    //递增$inc
    // update.inc("likenum",1);
    update.inc("likenum");
    //参数1：查询对象
    //参数2：更新对象
    //参数3：集合的名字或实体类的类型Comment.class
    mongoTemplate.updateFirst(query,update,"comment");
    }

[b2256f8f11164a4d93adbef3753bae50.png]: https://img-blog.csdnimg.cn/b2256f8f11164a4d93adbef3753bae50.png
[56ff928eb180427ea5583fcfe662db95.png]: https://img-blog.csdnimg.cn/56ff928eb180427ea5583fcfe662db95.png
[2f857f52aa574d6ba90143432149a804.png]: https://img-blog.csdnimg.cn/2f857f52aa574d6ba90143432149a804.png