1. 场景案例
存放文章评论的数据存放到 MongoDB 中,数据结构如下:
字段名称 | 字段含义 | 字段类型 | 备注 |
_id | ID | ObjectId 或 String | Mongo 的主键的字段 |
articleid | 文章ID | String | |
content | 评论内容 | String | |
userid | 评论人ID | String | |
nickname | 评论人昵称 | String |
nickname | 评论人昵称 | String | |
createdatetime | 评论的日期时间 | Date | |
likenum | 点赞数 | Int32 | |
replynum | 回复数 | Int32 | |
state | 状态 | String | 0:不可见,1:可见 |
parentid | 上级ID | String | 如果为0表示文章的顶级评论 |
2. 数据库操作
选择和创建数据库的语法格式:
use 数据库名称
如果数据库不存在则自动创建,例如,以下语句创建 articledb
数据库
use articledb
查询有权限查看的所有数据库的命令
show dbs 或者 show databases
需要注意的是,在 MongoDB 中数据库只有插入内容才会真正创建,持久化到磁盘上,如果没有插入内容的话,show dbs
是不会显示刚刚创建的数据库的!
查看当前正在使用的数据库,命令如下
db
需要注意的是,数据库名可以是满足以下条件的任意 UTF-8 字符串
- 不能是空字符串
- 不得含有
空格
、.
、$
、/
、\
和\0
- 全部小写
- 最多 64 字节
有一些数据库名是保留的,可以直接访问这些有特殊作用的数据库:
admin: 从权限的角度来看,这是"root"数据库。要是将一个用户添加到这个数据库,这个用户自动继承所有数据库的权限。一些特定的服务器端命令也只能从这个数据库运行,例如列出所有的数据库或者关闭服务器
local: 这个数据永远不会被复制,可以用来存储限于本地单台服务器的任意集合
config: 当 MongoDB 用于分片设置时,config 数据库在内部使用,用于保存分片的相关信息
MongoDB 删除数据库的语法格式如下
db.dropDatabase()
主要用来删除已经持久化的数据库。
3. 集合操作
MonogoDB 中集合类似关系型数据库中的表,可以显式、隐式的创建。
3.1 显式创建集合
基本语法格式:
db.createCollection(name) #name表示要创建的集合名称
例如,创建一个名为 mycollection
的普通集合。
db.createCollection("mycollection")
查看当前库中的集合命令:
show collections 或 show tables
集合的命令规范:
- 集合名不能是空字符串
""
- 集合名不能含有
\0
字符(空字符),这个字符表示集合名的结尾 - 集合名不能以
”system“
开头,这是为系统集合保留的前缀 - 用户创建的集合名字不能含有保留字符
3.2 集合的隐式创建
当向一个集合中插入一个文档的时候,如果集合不存在,则会自动创建集合,详见 文档的插入
章节,通常都是使用隐式创建文档方式。
3.3 集合的删除
集合删除语法格式如下:
db.collection.drop()
如果成功删除选定集合,则 drop()
方法返回 true,否则返回 false
例如,要删除 mycollection
集合
db.mycollection.drop()
4. 文档操作
文档的数据结构和 JSON 基本一样,所有存储在集合中的数据都是 BSON 格式。
4.1 文档的插入
4.1.1 单个文档插入
使用 insert()
或 save()
方法向集合中插入文档,语法如下:
db.collection.insert( <document or array documents> { writeConcern: <document>, ordered: <boolean> } )
参数:
Parameter | Type | Description |
document | document or array | 要插入到集合中的文档或文档数组(json 格式) |
writeConcern | document |
ordered | boolean | 可选,如果为真,则按顺序插入数组中的文档,如果其中一个文档出现错误,MongoDB 将返回而不处理数组中的其余文档,如果为假,则执行无序插入,如果其中一个文档出现错误,则继续处理数组中的主文档,在版本2.6+中默认为true |
示例:
要向 comment 的集合中插入一条测试数据:
db.comment.insert({"articleid":"100000","content":"今天天气真好,阳光明媚", "userid":"1001","nickname":"Rose","createdatetime":new Date(), "likenum":NumberInt(10),"state":null})
提示:
comment 集合如果不存在,则会隐式创建
mongo 中的数字,默认情况下 double 类型,如果要存放整型,必须使用函数 NumberInt(整型数字),否则取出来就有问题
插入当前日期使用 new_Date()
插入的数据没有指定 _id,会自动生成主键值
如果某字段没值,可以赋值为 null,或不写该字段
注意:
文档中的键/值对是有序的
文档的值不仅可以是在双引号里面的字符串,还可以是其他几种数据类型(甚至可以是整个嵌入的文档)
MongoDB 区分类型和大小写
MongoDB 的文档不能有重复的键
文档的键是字符串,除了少数例外情况,键可以使用任意 UTF-8 字符
文档键命规范:
键不能含有\0(空字符),这个字符用来表示键的结尾
. 和 $ 有特别的意义,只有在特定环境下才能使用
以下划线 _ 开头的键是保留的
4.1.2 批量插入
语法格式:
db.collection.insertMany( [<document 1>,<document 2>,...], { writeConcern: <document>, ordered: <boolean> } )
参数:
Parameter | Type | Description |
document | document | 要插入到集合文档或文档数组(json 格式) |
writeConcern | document |
ordered | boolean | 可选,一个布尔值,指定 Mongo 实例应执行有序插入还是无序插入,默认为 true |
示例,批量插入多条文章评论
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); }
4.2 文档的基本查询
查询数据的语法格式如下:
db.collection.find(<query>,[projection])
参数:
Parameter | Type | Description |
query | document | 可选,使用查询运算符指定选择筛选器,若要返回集合中的所有文档,省略此参数或传递空文档({}) |
projection | document | 可选,指定要在与查询筛选器匹配的文档中返回的字段(投影),若要返回匹配文档中的所有字段,省略此参数 |
示例:
(1) 查询所有
如果要查询所有集合的所有文档,输入以下命令
db.comment.find() 或 db.comment.find({})
查询出来的每条文档都有一个 _id 字段,这个字段相当于关系数据库中的表的主键,当在插入文档记录时没有指定该字段,MongoDB 会自动创建,其类型是 ObjectID 类型。
如果在插入文档记录时指定该字段也可以,其类型可以是 ObjectID 类型,也可以是 MongoDB 支持的任意类型。
如果想按一定条件查询,例如要查询 userid=1003 的记录,只要在 find() 中添加函数即可,参数也是 json 格式,命令如下所示
db.comment.find({"})
查询出来的记录有两条,如果只想要返回满足条件的第一条记录,可以使用 findOne()
命令,语法格式如下:
db.comment.findOne({userid:"1003"})
(2) 投影查询
如果要查询结果返回部分字段,需要使用投影查询。例如,结果只显示 _id、userid、nickname
,语法格式如下:
虽然没有手动显式指定 _id
,但是 MongoDB 默认情况下会显示 _id
.
如果不想显示 _id
字段,也可以手动设置,语法格式如下:
db.comment.find({userid:"1003"},{userid:1,nickname:1,_id:0})
4.3 文档的更新
更新文档的语法:
db.collection.update(query,update,options) 或 db.collection.update( <query>, <update>, { upsert: <boolean>, multi: <boolean>, writeConcern: <document>, collation: <document>, arrayFilters: [<filterdocument>,...], hint: <document|string> } )
参数:
(1) 覆盖修改
如果想要修改_id
为1的记录,点赞量为 1001,输入以下语句:
db.comment.update({_id:"1"},{likenum: NumberInt(1001)})
执行后发现,这条文档除了 likenum 字段其他字段都不可见了,因此覆盖修改慎用!
(2) 局部修改
为了解决覆盖修改带来的问题,可以使用局部修改的方式。例如,想要修改_id 为2的记录,浏览量为 999, 命令如下:
db.comment.update({_id:"2"},{$set:{likenum:NumberInt(999)}})
(3) 批量修改
更新所有用户ID为 1003 的用户昵称为 华仔仔
#默认只修改第一条数据 db.comment.update({userid:"1003"},{$set:{nickname:"华仔仔coding"}}) #修改所有符合条件的数据 db.comment.update({userid:"1003"},{$set:{nickname:"华仔仔"}},{multi:true})
(3) 列值增长修改
如果想要实现对某列值在原有值的基础上增加或者减少,可以使用 $inc
运算符来实现。例如,对 _id
为3的数据的点赞数每次递增1:
db.comment.update({_id:"3"},{$inc:{likenum:NumberInt(1)}})
4.4 删除文档
删除文档的语法格式:
db.collection.remove(条件)
如果要删除集合中的所有文档,使用如下命令:
db.collection.remove({})
如果要删除id=1
的记录,输入以下语句:
db.comment.remove({_id:"1"})
5. 文档的分页查询
5.1 统计查询
统计查询使用 count()
方法,语法如下:
db.collection.count(query,options)
参数:
Parameter | Type | Description |
query | document | 查询选择条件 |
options | document | 可选,用于修改计数的额外选项 |
(1) 统计所有记录数
统计 comment
集合的所有记录数:
db.comment.count()
(2) 按条件统计记录数
统计 userid=1003
的记录数:
db.comment.count({userid:"1003"})
5.2 分页列表查询
可以使用 limit()
方法读取指定数量的数据,使用 skip()
方法跳过指定数量数据。
基本语法格式如下:
db.collection.find().limit(number).skip(number)
而 skip()
方法的默认值为 0.
5.3 排序查询
对数据排序可以使用 sort()
方法,该方法可以通过指定排序的字段,并使用 1
和 -1
来指定排序的方法,其中,1
为升序排序,而 -1
是用于降序排序。语法格式如下:
db.collection.find().sort({key:1}) 或 db.collection.find().sort({key:-1})
例如,对 userid
降序排序,并对likenum
进行升序排序
db.comment.find().sort({userid:-1,likenum:1})
注意:skip()
、limit()
、sort()
方法放在一起执行的时候,执行的顺序是先sort()
,再skip()
,最后是 limit()
,和命令编写顺序无关。
6. 其他查询
6.1 正则表达式查询
MongoDB 的模糊查询是通过正则表达式的方式实现的,格式为:
db.collection.find({field:/正则表达式/})
例如,要查询评论内容包含“开水”的所有文档,代码如下:
db.comment.find({content:/开水/})
6.2 比较查询
比较查询的语法格式如下:
db.collection.find({field:{$gt:value}}) #大于:field > value db.collection.find({field:{$lt:value}}) #小于:field < value db.collection.find({field:{$gte:value}}) #大于等于:field >= value db.collection.find({field:{$lte:value}}) #小于等于:field <= value db.collection.find({field:{$ne:value}}) #不等于:field != value
示例:查询评论点赞数量大于700的记录:
db.comment.find({likenum:{$gt:NumberInt(700)}})
6.3 包含查询
包含使用 $in
操作符,例如,查询评论的集合中 userid
字段包含 1003 或 1004 的文档:
db.comment.find({userid:{$in:["1003","1004"]}})
不包含使用 $nin
操作符,例如,查询评论集合中 userid
字段不包含 1003 和 1004 的文档:
db.comment.find({userid:{$nin:["1003","1004"]}})
6.4 条件连接查询
如果要查询同时满足两个以上条件,可以使用 $and
操作符将条件进行关联,语法格式为:
$and:[{},{},{}]
例如,要查询集合中 likenum
大于等于 700 并且小于等于 2000 的文档:
db.comment.find({$and:[{likenum:{$gte:NumberInt(700)}},{likenum:{$lt:NumberInt(2000)}}]})
如果两个以上条件之间是或者的关系,可以使用 or
操作符进行关联,语法格式如下:
$or:[{},{},{}]
例如,查询评论集合中 userid
为 1003 或者 likenum
小于 100 的文档记录:
db.comment.find({$or:[{userid:"1003"},{likenum:{$lt:1000}}]})