MongoDB实现CRUD、分页、评论点赞数增加

<?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>
​
    <groupId>cn.nr</groupId>
    <artifactId>mongodb-study</artifactId>
    <version>1.0-SNAPSHOT</version>
​
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.6.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
​
    <dependencies>
        <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-test -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <version>2.0.6.RELEASE</version>
            <scope>test</scope>
        </dependency>
​
        <!--MongoDB依赖-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-mongodb</artifactId>
        </dependency>
    </dependencies>
​
</project>

spring:
  # 数据源配置
  data:
    mongodb:
      # 主机地址
      host: localhost
      # 数据库：
      database: articledb
      # 端口号    默认：27017
      port: 27017
      # 也可以是会用url来连接
#      uri: mongodb://localhost:27017/articledb

package cn.nr.pojo;
​
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.index.CompoundIndex;
import org.springframework.data.mongodb.core.index.Indexed;
import org.springframework.data.mongodb.core.mapping.Document;
import org.springframework.data.mongodb.core.mapping.Field;
​
import java.io.Serializable;
import java.time.LocalDateTime;
import java.util.Date;
​
/**
 * 文章评论实体类
 */
//把一个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;
​
    // getter + setter 
    
    // toString()

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

db.comment.createIndexes({"userid":1,"age":-1})

//评论的持久层接口
public interface CommentRepository  extends MongoRepository<Comment,String> {
    Page<Comment> findByParentid(String parentid, Pageable pageable);
}

package cn.nr.service;
​
import cn.nr.dao.CommentRepository;
import cn.nr.pojo.Comment;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
import org.springframework.stereotype.Service;
​
import java.util.List;
​
//评论的业务层
@Service
public class CommentService {
    @Autowired
    private CommentRepository commentRepository;
​
    @Autowired
    private MongoTemplate mongoTemplate;
​
    /**
     * 保存一个评论
     *
     * @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();
    }
​
​
    /**
     * 分页
     *
     * @param id
     */
    public Page<Comment> findCommentListByParentid(String parentid, int page, int size) {
        return commentRepository.findByParentid(parentid, PageRequest.of(page - 1, size));
    }
​
​
    /**
     * 更新评论点赞数
     *
     * @param id
     */
    public void updateCommentLikenum(String id) {
​
        // 查询条件
        // where后传入的是 数据库中的主键id
        // 此处意为：当 _id等于传入的参数id，我们就给下面的点赞数+1
        Query query = Query.query(Criteria.where("_id").is(id));
​
        // 更新条件
        // 给字段 likenum 作自增长，每次+1
        Update update = new Update();
        update.inc("likenum"); // 默认inc是1，故此处不写
//        update.inc("likenum",2); // 给 likenum作自增长，每次加2， inc的参数是  步长
​
        //参数1：查询对象
        // 参数2：更新对象
        // 参数3：集合的名字或实体类的类型Comment.class
        mongoTemplate.updateFirst(query, update, Comment.class);
​
    }
}