一、项目配置
SpringBoot项目
1、项目依赖
代码语言：javascript复制<?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>2、项目yml配置
代码语言：javascript复制spring:
# 数据源配置
data:
mongodb:
# 主机地址
host: localhost
# 数据库：
database: articledb
# 端口号 默认：27017
port: 27017
# 也可以是会用url来连接
# uri: mongodb://localhost:27017/articledb3、实体类
代码语言：javascript复制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()注解说明
索引可以大大加快查询效率，一般在查询字段上添加索引，索引的添加可以通过MongoDB的命令来添加，也可以在Java的实体类上通过注解添加。
单字段索引@Indexed
声明该字段需要索引，以提高查询效率
Mongo命令参考：
代码语言：javascript复制db.comment.createIndex({"userid":1})复合索引注解@CompoundIndex
复合索引的声明，建复合索引可以有效地提高多字段的查询效率。
Mongo命令参考：
代码语言：javascript复制db.comment.createIndexes({"userid":1,"age":-1})二、实现CRUD、分页、点赞数增加
1、创建dao层
CommentRepository.java
代码语言：javascript复制//评论的持久层接口
public interface CommentRepository extends MongoRepository<Comment,String> {
Page<Comment> findByParentid(String parentid, Pageable pageable);
}注：此处集成MongoRepository，第一位参数为实体类，第二位为
2、创建service层
代码语言：javascript复制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);
}
}3、测试
调方法即可
