MONGO入门(Mongo，maven)

mongo入门

一.MongoDB相关概念
- 1.1 业务应用场景
二.mongo的基本操作
- 2.1数据库的创建
- 2.2 查看当前数据库
- 2.3数据库的增删改查
- - 2.3.1mongo的删除数据库的操作：
  - 2.3.2集合的相关操作
- 2.4文档的CRUD
- - 2.4.1文档的插入操作
  - 2.4.2文档的查询
  - 2.4.3文档的更新
  - 2.4.4 删除文档
- 2.5排序查询
- - 2.5.1统计查询
  - 2.5.2分页列表查询
  - 2.5.3排序查询
- 2.6文档的更多查询
- - 2.6.1正则的负责条件查询
  - 2.6.2比较查询
  - 2.6.3包含查询
  - 2.6.4条件连接查询
  - 2.7常用命令总结
三.索引
- 3.1单字段索引
- 3.2复合索引
- 3.3其他索引
- 3.4索引的管理操作
- - 3.4.1索引的查看
  - 3.4.2索引的创建
  - 3.4.3索引的移除
- 3.5索引的使用
- - 3.5.1 执行计划
  - 3.5.2涵盖的查询
四.使用idea实现CRUD操作
- 4.1 表结构分析
- 4.2 所应用技术
- - 4.2.1 mongodb-driver（了解）
  - 4.2.2 SpringDataMongoDB
- 4.3模块搭建
- - 4.3.1配置文件的编写
  - 4.3.2文章评论实体类编写
  - 4.3.3 文章评论的基本增删改查
  - 4.3.4 根据上级ID查询文章评论的分页列表
  - 4.3.5 MongoTemplate实现评论点赞

以下所用版本为：4,4，不用进行整形转换（numint）
学习目标
1.理解mongo的业务场景、熟悉mongo的简介、特点、体系结构、数据类型等。

2.能够在windows和linux下安装和启动mongo】图形化管理界面compass的安装使用

3.掌握mongo基本常用命令实现数据的CRUD

4.掌握mongo的索引类型、索引管理、执行计划

5.使用Spring DATA MongoDB完成文章评论业务的开发。

一.MongoDB相关概念

1.1 业务应用场景

传统的关系型数据库（如MySQL），在数据操作的“三高”需求以及应对Web2.0的网站需求面前，显得力不从心。解释：“三高”需求：

• High performance - 对数据库高并发读写的需求。

• Huge Storage - 对海量数据的高效率存储和访问的需求。

• High Scalability && High Availability- 对数据库的高可扩展性和高可用性的需求。

而MongoDB可应对“三高”需求。

具体的应用场景如：

1）社交场景，使用 MongoDB 存储存储用户信息，以及用户发表的朋友圈信息，通过地理位置索引实现附近的人、地点等功能。

2）游戏场景，使用 MongoDB 存储游戏用户信息，用户的装备、积分等直接以内嵌文档的形式存储，方便查询、高效率存储和访问。 3）物流场景，使用 MongoDB 存储订单信息，订单状态在运送过程中会不断更新，以 MongoDB 内嵌数组的形式来存储，一次查询就能将订单所有的变更读取出来。

4）物联网场景，使用 MongoDB 存储所有接入的智能设备信息，以及设备汇报的日志信息，并对这些信息进行多维度的分析。

5）视频直播，使用 MongoDB 存储用户信息、点赞互动信息等。

这些应用场景中，数据操作方面的共同特点是：

（1）数据量大

（2）写入操作频繁（读写都很频繁）

（3）价值较低的数据，对事务性要求不高对于这样的数据，我们更适合使用MongoDB来实现数据的存储。

什么时候选择MongoDB 在架构选型上，除了上述的三个特点外，如果你还犹豫是否要选择它？可以考虑以下的一些问题：

应用不需要事务及复杂 join 支持新应用，

需求会变，数据模型无法确定，想快速迭代开发应用需要2000-3000以上的读写QPS（更高也可以）

应用需要TB甚至 PB 级别数据存储应用发展迅速，

需要能快速水平扩展应用要求存储的数据不丢失应用需要99.999%高可用

应用需要大量的地理位置查询、文本查询如果上述有1个符合，可以考虑 MongoDB，2个及以上的符合，选择 MongoDB 绝不会后悔。

二.mongo的基本操作

2.1数据库的创建

use 数据库名称

如果数据库不存在则会自动创建。

查看所有的数据库

show dbs
或者
show databases

数据库创建过后必须要在其中创建集合才能够持久化到磁盘，否则只是存储到内存。

2.2 查看当前数据库

db

有一些数据库名是保留的，可以直接访问这些有特殊作用的数据库。

admin：从权限的角度来看，这是"root"数据库。要是将一个用户添加到这个数据库，这个用户自动继承所有数据库的权限。一些特定的服务器端命令也只能从这个数据库运行，比如列出所有的数据库或者关闭服务器。

local: 这个数据永远不会被复制，可以用来存储限于本地单台服务器的任意集合

config: 当Mongo用于分片设置时，config数据库在内部使用，用于保存分片的相关信息。

2.3数据库的增删改查

2.3.1mongo的删除数据库的操作：

db.dropDatabase()

注：主要用来删除已经持久化的数据

2.3.2集合的相关操作

集合的创建

db.createCollection(name)

上方创建方式为显式创建方法，集合名字要加引号

查看数据库中集合的操作

show collections
或者
show tables

当向一个集合中插入一个文档的时候，如果集合不存在，则会自动创建集合。(集合的隐式创建)

删除指定集合

db.集合名字.drop()

2.4文档的CRUD

2.4.1文档的插入操作

单个文档插入

使用insert()或者save()方法向集合中插入文档，语法如下：

db.comment.insert({"articleid":"100000","content":"今天天气真好，阳光,明媚","userid":"1001","nickname":"Rose","createdatetime":new Date(),"likenum":NumberInt(10),"state":null})

如果集合不存在则会重新创建

出现：WriteResult({ “nInserted” : 1 })则证明插入成功

多个文档的插入

db.comment.insertMany([
{"_id":"1","articleid":"100001","content":"我们不应该把清晨浪费在手机上，健康很重要，一杯温水幸福你我
他。","userid":"1002","nickname":"相忘于江湖","createdatetime":new Date("2019-08-
05T22:08:15.522Z"),"likenum":NumberInt(1000),"state":"1"},
{"_id":"2","articleid":"100001","content":"我夏天空腹喝凉开水，冬天喝温开水","userid":"1005","nickname":"伊人憔
悴","createdatetime":new Date("2019-08-05T23:58:51.485Z"),"likenum":NumberInt(888),"state":"1"},
{"_id":"3","articleid":"100001","content":"我一直喝凉开水，冬天夏天都喝。","userid":"1004","nickname":"杰克船
长","createdatetime":new Date("2019-08-06T01:05:06.321Z"),"likenum":NumberInt(666),"state":"1"},
{"_id":"4","articleid":"100001","content":"专家说不能空腹吃饭，影响健康。","userid":"1003","nickname":"凯
撒","createdatetime":new Date("2019-08-06T08:18:35.288Z"),"likenum":NumberInt(2000),"state":"1"},
{"_id":"5","articleid":"100001","content":"研究表明，刚烧开的水千万不能喝，因为烫
嘴。","userid":"1003","nickname":"凯撒","createdatetime":new Date("2019-08-
06T11:01:02.521Z"),"likenum":NumberInt(3000),"state":"1"}
])

提示：插入时指定了 _id ，则主键就是该值。如果某条数据插入失败，将会终止插入，但已经插入成功的数据不会回滚掉。因为批量插入由于数据较多容易出现失败，因此，可以使用try catch进行异常捕捉处理，测试的时候可以不处理。如（了解）：

try {
db.comment.insertMany([
{"_id":"1","articleid":"100001","content":"我们不应该把清晨浪费在手机上，健康很重要，一杯温水幸福你我
他。","userid":"1002","nickname":"相忘于江湖","createdatetime":new Date("2019-08-
05T22:08:15.522Z"),"likenum":NumberInt(1000),"state":"1"},
{"_id":"2","articleid":"100001","content":"我夏天空腹喝凉开水，冬天喝温开水","userid":"1005","nickname":"伊人憔
悴","createdatetime":new Date("2019-08-05T23:58:51.485Z"),"likenum":NumberInt(888),"state":"1"},
{"_id":"3","articleid":"100001","content":"我一直喝凉开水，冬天夏天都喝。","userid":"1004","nickname":"杰克船
长","createdatetime":new Date("2019-08-06T01:05:06.321Z"),"likenum":NumberInt(666),"state":"1"},
{"_id":"4","articleid":"100001","content":"专家说不能空腹吃饭，影响健康。","userid":"1003","nickname":"凯
撒","createdatetime":new Date("2019-08-06T08:18:35.288Z"),"likenum":NumberInt(2000),"state":"1"},
{"_id":"5","articleid":"100001","content":"研究表明，刚烧开的水千万不能喝，因为烫
嘴。","userid":"1003","nickname":"凯撒","createdatetime":new Date("2019-08-
06T11:01:02.521Z"),"likenum":NumberInt(3000),"state":"1"}
]);
} catch (e) {
print (e);
}

2.4.2文档的查询

按照条件查询所有符合条件的所有文档的所有字段

db.comment.find({userid:'1003'})

按条件查询一条

db.comment.findOne({userid:'1003'})

投影查询（Projection Query）

只显示符合条件文档的字段：1为显示，0为不显示

db.comment.find({userid:"1003"},{userid:1,nickname:1})

2.4.3文档的更新

（1）覆盖的修改如果我们想修改_id为1的记录，点赞量为1001，输入以下语句：

其他字段都会被覆盖

db.comment.update({_id:"1"},{likenum:NumberInt(1001)})

（2）局部修改

为了解决这个问题，我们需要使用修改器$set来实现，命令如下：我们想修改_id为2的记录，浏览量为889，输入以下语句：

db.comment.update({_id:"2"},{$set:{likenum:NumberInt(889)}})

（3）批量的修改

更新所有用户为 1003 的用户的昵称为凯撒大帝。

//默认只修改第一条数据
db.comment.update({userid:"1003"},{$set:{nickname:"凯撒2"}})
//修改所有符合条件的数据
db.comment.update({userid:"1003"},{$set:{nickname:"凯撒大帝"}},{multi:true})

（4）列值增长的修改

如果我们想实现对某列值在原有值的基础上进行增加或减少，可以使用 $inc 运算符来实现。需求：对3号数据的点赞数，每次递增1

db.comment.update({_id:"3"},{$inc:{likenum:NumberInt(1)}})

2.4.4 删除文档

以下语句可以将数据全部删除，请慎用

db.comment.remove({})

如果删除_id=1的记录，输入以下语句

db.comment.remove({_id:"1"})

2.5排序查询

2.5.1统计查询

(1)统计所有记录数：统计comment集合的所有的记录数：

db.comment.count()

(2）按条件统计记录数：例如：统计userid为1003的记录条数

db.comment.count({userid:"1003"})

默认情况下count()返回所有记录数。

2.5.2分页列表查询

可以使用limit()方法来读取指定数量的数据，使用skip()方法来跳过指定数量的数据。基本语法如下所示：

db.COLLECTION_NAME.find().limit(NUMBER).skip(NUMBER)

如果你想返回指定条数的记录，可以在find方法后调用limit来返回结果(TopN)，默认值20，例如：

db.comment.find().limit(3)

skip方法同样接受一个数字参数作为跳过的记录条数。（前N个不要）,默认值是0

db.comment.find().skip(3)

分页查询：需求：每页2个，第二页开始：跳过前两条数据，接着值显示3和4条数据

//第一页
db.comment.find().skip(0).limit(2)
//第二页
db.comment.find().skip(2).limit(2)
//第三页
db.comment.find().skip(4).limit(2)

2.5.3排序查询

sort() 方法对数据进行排序，sort() 方法可以通过参数指定排序的字段，并使用 1 和 -1 来指定排序的方式，其中 1 为升序排列，而 -1 是用于降序排列。

对userid降序排列，并对访问量进行升序排列

db.comment.find().sort({userid:-1,likenum:1})

注意：

skip(), limilt(), sort()三个放在一起执行的时候，执行的顺序是先 sort(), 然后是 skip()，最后是显示的 limit()，和命令编写顺序无关。

2.6文档的更多查询

2.6.1正则的负责条件查询

db.collection.find({field:/正则表达式/})
或
db.集合.find({字段:/正则表达式/})

我要查询评论内容包含“开水”的所有文档，代码如下：

db.comment.find({content:/开水/})

2.6.2比较查询

<, <=, >, >= 这个操作符也是很常用的，格式如下:

db.集合名称.find({ "field" : { $gt: value }}) // 大于: field > value
db.集合名称.find({ "field" : { $lt: value }}) // 小于: field < value
db.集合名称.find({ "field" : { $gte: value }}) // 大于等于: field >= value
db.集合名称.find({ "field" : { $lte: value }}) // 小于等于: field <= value
db.集合名称.find({ "field" : { $ne: value }}) // 不等于: field != value

例：查询评论点赞数量大于700的记录

db.comment.find({likenum:{$gt:700}})

2.6.3包含查询

包含使用$in操作符。示例：查询评论的集合中userid字段包含1003或1004的文档

db.comment.find(userid:{$in:["1003","1004"]})

不包含使用$nin操作符。示例：查询评论集合中userid字段不包含1003和1004的文档

db.comment.find(userid:{$nin:["1003","1004"]})

2.6.4条件连接查询

我们如果需要查询同时满足两个以上条件，需要使用$and操作符将条件进行关联。（相当于SQL的and）格式为：

$and:[ { },{ },{ } ]

查询评论集合中likenum大于等于700 并且小于2000的文档：

db.comment.find({$and:[{likenum:{$gt:700}},{likenum:{$lt:2000}}]})

查询评论集合中userid为1003，或者点赞数小于1000的文档记录

db.comment.find({$or:[{likenum:{$lt:1000}},{userid:"1003"}]})

2.7常用命令总结

选择切换数据库：use articledb
插入数据：db.comment.insert({bson数据})
查询所有数据：db.comment.find();
条件查询数据：db.comment.find({条件})
查询符合条件的第一条记录：db.comment.findOne({条件})
查询符合条件的前几条记录：db.comment.find({条件}).limit(条数)
查询符合条件的跳过的记录：db.comment.find({条件}).skip(条数)
修改数据：db.comment.update({条件},{修改后的数据}) 或db.comment.update({条件},{$set:{要修改部分的字段:数据})
修改数据并自增某字段值：db.comment.update({条件},{$inc:{自增的字段:步进值}})
删除数据：db.comment.remove({条件})
统计查询：db.comment.count({条件})
模糊查询：db.comment.find({字段名:/正则表达式/})
条件比较运算：db.comment.find({字段名:{$gt:值}})
包含查询：db.comment.find({字段名:{$in:[值1，值2]}})或db.comment.find({字段名:{$nin:[值1，值2]}})
条件连接查询：db.comment.find({$and:[{条件1},{条件2}]})或db.comment.find({$or:[{条件1},{条件2}]})

三.索引

索引能够更快的提升查的速度，但是索引实际上也是一个集合，所以当用不到时一定要删除。避免内存的占用。

索引分为：单字段索引、复合索引、其他索引。

3.1单字段索引

MongoDB支持在文档的单个字段上创建用户定义的升序/降序索引，称为单字段索引（Single Field Index）。对于单个字段索引和排序操作，索引键的排序顺序（即升序或降序）并不重要，因为MongoDB可以在任何方向上遍历索引。

3.2复合索引

MongoDB还支持多个字段的用户定义索引，即复合索引（Compound Index）。复合索引中列出的字段顺序具有重要意义。例如，如果复合索引由 { userid: 1, score: -1 } 组成，则索引首先按userid正序排序，然后在每个userid的值内，再在按score倒序排序。

3.3其他索引

地理空间索引（Geospatial Index）、文本索引（Text Indexes）、哈希索引（Hashed Indexes）。

地理空间索引（Geospatial Index）为了支持对地理空间坐标数据的有效查询，MongoDB提供了两种特殊的索引：返回结果时使用平面几何的二维索引和返回结果时使用球面几何的二维球面索引。

文本索引（Text Indexes） MongoDB提供了一种文本索引类型，支持在集合中搜索字符串内容。这些文本索引不存储特定于语言的停止词（例如“the”、“a”、“or”），而将集合中的词作为词干，只存储根词。

哈希索引（Hashed Indexes）为了支持基于散列的分片，MongoDB提供了散列索引类型，它对字段值的散列进行索引。这些索引在其范围内的值分布更加随机，但只支持相等匹配，不支持基于范围的查询。

3.4索引的管理操作

3.4.1索引的查看

说明：返回一个集合中的所有索引的数组。语法：

db.collection.getIndexes()

提示：该语法命令运行要求是MongoDB 3.0+

mongo默认提供_id索引。唯一索引，因此此值不能够重复，在分片集群中，通常使用 _id 作为片键。

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-kSUCe7aI-1666573252989)(D:\typora\Typora\文件\mongo\索引.png)]

3.4.2索引的创建

说明：在集合上创建索引。语法：

db.collection.createIndex(keys, options)

(1)单字段索引示例：对 userid 字段建立索引：

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

(2)复合索引：对 userid 和 nickname 同时建立复合（Compound）索引：

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

3.4.3索引的移除

一、指定索引的移除语法：

db.collection.dropIndex(index)

删除 comment 集合中 userid 字段上的升序索引：

db.comment.dropIndex({userid:1})
或者
db.comment.dropIndex("userid_1")

二、所有索引的移除语法：

 db.comment.dropIndexes()

提示： _id 的字段的索引是无法删除的，只能删除非 _id 字段的索引。

3.5索引的使用

3.5.1 执行计划

分析查询性能（Analyze Query Performance）通常使用执行计划（解释计划、Explain Plan）来查看查询的情况，如查询耗费的时间、是否基于索引查询等。那么，通常，我们想知道，建立的索引是否有效，效果如何，都需要通过执行计划查看。语法：

db.collection.find(query,options).explain(options)

查看根据userid查询数据的情况：

db.comment.find({userid:"1003"}).explain()

关键点看： “stage” : “COLLSCAN”, 表示全集合扫描,fetch：表示索引参与了提升了查询速度

3.5.2涵盖的查询

Covered Queries

当查询条件和查询的投影仅包含索引字段时，MongoDB直接从索引返回结果，而不扫描任何文档或将文档带入内存。这些覆盖的查询可以非常有效。

实例：

 db.comment.find({userid:"1003"},{userid:1,_id:0}).explain()

注意：“stage” : “IXSCAN”

四.使用idea实现CRUD操作

4.1 表结构分析

4.2 所应用技术

4.2.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/

4.2.2 SpringDataMongoDB

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

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

4.3模块搭建

4.3.1配置文件的编写

（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/> <!-- lookup parent from repository -->
</parent>
<groupId>cn.itcast</groupId>
<artifactId>article</artifactId>
<version>1.0-SNAPSHOT</version>
<dependencies>
<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# 默认端口是27017port: 27017#也可以使用uri连接#uri: mongodb://192.168.40.134:27017/articledb

（3）创建启动类

cn.itcast.article.ArticleApplication

package cn.itcast.article;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class ArticleApplication {public static void main(String[] args) {SpringApplication.run(ArticleApplication.class, args);
}
}

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

如果显示为绿色的对钩则证明没有错误，可继续进行操作。

4.3.2文章评论实体类编写

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

package cn.itcast.article.po;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”,则该注解可以省略，否则必须写
//    @Idprivate String id;//主键//该属性对应mongodb的字段的名字，如果一致，则无需该注解@Field("content")private String content;//吐槽内容private Date publishtime;//发布日期//添加了一个单字段的索引@Indexedprivate String userid;//发布人IDprivate String nickname;//昵称private LocalDateTime createdatetime;//评论的日期时间private Integer likenum;//点赞数private Integer replynum;//回复数private String state;//状态private String parentid;//上级IDprivate String articleid;//getter and setter.....public String getId() {return id;}public void setId(String id) {this.id = id;}public String getContent() {return content;}public void setContent(String content) {this.content = content;}public Date getPublishtime() {return publishtime;}public void setPublishtime(Date publishtime) {this.publishtime = publishtime;}public String getUserid() {return userid;}public void setUserid(String userid) {this.userid = userid;}public String getNickname() {return nickname;}public void setNickname(String nickname) {this.nickname = nickname;}public LocalDateTime getCreatedatetime() {return createdatetime;}public void setCreatedatetime(LocalDateTime createdatetime) {this.createdatetime = createdatetime;}public Integer getLikenum() {return likenum;}public void setLikenum(Integer likenum) {this.likenum = likenum;}public Integer getReplynum() {return replynum;}public void setReplynum(Integer replynum) {this.replynum = replynum;}public String getState() {return state;}public void setState(String state) {this.state = state;}public String getParentid() {return parentid;}public void setParentid(String parentid) {this.parentid = parentid;}public String getArticleid() {return articleid;}public void setArticleid(String articleid) {this.articleid = articleid;}@Overridepublic String toString() {return "Comment{" +"id='" + id + '\'' +", content='" + content + '\'' +", publishtime=" + publishtime +", userid='" + userid + '\'' +", nickname='" + nickname + '\'' +", createdatetime=" + createdatetime +", likenum=" + likenum +", replynum=" + replynum +", state='" + state + '\'' +", parentid='" + parentid + '\'' +", articleid='" + 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})

4.3.3 文章评论的基本增删改查

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

package cn.itcast.article.dao;
import cn.itcast.article.po.Comment;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.mongodb.repository.MongoRepository;
//评论的持久层接口
public interface CommentRepository extends MongoRepository<Comment,String> {}

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

package cn.itcast.article.service;import cn.itcast.article.dao.CommentRepository;
import cn.itcast.article.po.Comment;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
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 {@Autowiredprivate CommentRepository commentRepository;@Autowiredprivate MongoTemplate mongoTemplate;/*** 保存一个评论* @param comment*/public void saveComment(Comment comment){//如果需要自定义主键，可以在这里指定主键；如果不指定主键，MongoDB会自动生成主键//设置一些默认初始值。。。//调用daocommentRepository.save(comment);}/*** 更新评论* @param comment*/public void updateComment(Comment comment){//调用daocommentRepository.save(comment);}/*** 根据id删除评论* @param id*/public void deleteCommentById(String id){//调用daocommentRepository.deleteById(id);}/*** 查询所有评论* @return*/public List<Comment> findCommentList(){//调用daoreturn commentRepository.findAll();}/*** 根据id查询评论* @param id* @return*/public Comment findCommentById(String id){//调用daoreturn commentRepository.findById(id).get();}public Page<Comment> findCommentListByParentid(String parentid,int page,int size) {return commentRepository.findByParentid(parentid,PageRequest.of(page-1,size));}public void updateCommentLikenum(String id){//  查询条件Query query = Query.query(Criteria.where("_id").is(id));//  更新条件Update update = new Update();update.inc("likenum");mongoTemplate.updateFirst(query,update,Comment.class);}}

（3）新建Junit测试类，测试保存和查询所有： cn.itcast.article.service.CommentServiceTest

package cn.itcast.article.service;import cn.itcast.article.po.Comment;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.domain.Page;
import org.springframework.test.context.junit4.SpringRunner;import java.time.LocalDateTime;
import java.util.List;@RunWith(SpringRunner.class)
@SpringBootTest
public class CommentServiceTest {@Autowiredprivate CommentService commentService;@Testpublic void testFindCommentList() {List<Comment> commentList = commentService.findCommentList();System.out.println(commentList);}@Testpublic void testFindCommentById() {Comment commentById = commentService.findCommentById("1");System.out.println(commentById);}@Testpublic 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);}@Testpublic void testFindCommentListByParentid() {Page<Comment> page = commentService.findCommentListByParentid("3", 1, 2);System.out.println(page.getTotalElements());System.out.println(page.getContent());}@Testpublic void testUpdateCommentLikenum() {commentService.updateCommentLikenum("1");}}

4.3.4 根据上级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());
}

（4）测试使用compass快速插入一条测试数据，数据的内容是对3号评论内容进行评论。

刚刚插入的数据如下：

4.3.5 MongoTemplate实现评论点赞

我们看一下以下点赞的临时示例代码： CommentService 新增updateThumbup方法

/**
* 点赞-效率低
* @param id
*/
public void updateCommentThumbupToIncrementingOld(String id){Comment comment = CommentRepository.findById(id).get();
comment.setLikenum(comment.getLikenum()+1);
CommentRepository.save(comment);
}

以上方法虽然实现起来比较简单，但是执行效率并不高，因为我只需要将点赞数加1就可以了，没必要查询出所有字段修改后再更新所有字段。(蝴蝶效应)

我们可以使用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");
}

（2）测试用例： cn.itcast.article.service.CommentServiceTest

/**
* 点赞数+1
*/
@Test
public void testUpdateCommentLikenum(){//对3号文档的点赞数+1
commentService.updateCommentLikenum("3");
}

可实现对点赞数逐次递加的效果。