MongoDB入门教程03

注:本系列教程是自己学习的记录,内容来至 菜鸟教程
MongoDB入门教程01
MongoDB入门教程02
MongoDB入门教程03
MongoDB入门教程04
MongoDB入门教程05

1. MongoDB – 连接

语法

> mongodb://[username:password@]host1[:port1],host2[:port2],
...[,hostN[:portN]][/[database][?options]]
  • mongodb:// 这是固定的格式,必须要指定。
  • username:password@ 可选项,如果设置,在连接数据库服务器之后,驱动都会尝试登陆这个数据库
  • host1 必须的指定至少一个host, host1 是这个URI唯一要填写的。它指定了要连接服务器的地址。<u style=”box-sizing: border-box;”>如果要连接复制集,请指定多个主机地址</u>。
  • portX 可选的指定端口,如果不填,默认为27017
  • /database 如果指定username:password@,连接并验证登陆指定数据库。若不指定,默认打开 test 数据库。
  • ?options 是连接选项。如果不使用/database,则前面需要加上/。所有连接选项都是键值对name=value,键值对之间通过&或;(分号)隔开

标准的连接格式包含了多个选项(options),如下所示:

选项描述描述
replicaSet=name验证replica set的名称。 Impliesconnect=replicaSet.
slaveOk=truefalsetrue:在connect=direct模式下,驱动会连接第一台机器,即使这台服务器不是主。在connect=replicaSet模式下,驱动会发送所有的写请求到主并且把读取操作分布在其他从服务器。false: 在 connect=direct模式下,驱动会自动找寻主服务器. 在connect=replicaSet 模式下,驱动仅仅连接主服务器,并且所有的读写命令都连接到主服务器。
safe=truefalsetrue: 在执行更新操作之后,驱动都会发送getLastError命令来确保更新成功。(还要参考 wtimeoutMS).false: 在每次更新之后,驱动不会发送getLastError来确保更新成功。
w=n驱动添加 { w : n } 到getLastError命令. 应用于safe=true。
wtimeoutMS=ms驱动添加 { wtimeout : ms } 到 getlasterror 命令. 应用于 safe=true.
fsync=truefalsetrue: 驱动添加 { fsync : true } 到 getlasterror 命令.应用于 safe=true.false: 驱动不会添加到getLastError命令中。
journal=truefalse如果设置为 true, 同步到 journal (在提交到数据库前写入到实体中). 应用于 safe=true
connectTimeoutMS=ms可以打开连接的时间。
socketTimeoutMS=ms发送和接受sockets的时间。

更多连接实例

1. 连接本地数据库服务器,端口是默认的。
> mongodb://localhost

2. 使用用户名fred,密码foobar登录localhost的admin数据库。
> mongodb://fred:foobar@localhost

3. 使用用户名fred,密码foobar登录localhost的baz数据库。
> mongodb://fred:foobar@localhost/baz

4. 连接 replica pair, 服务器1为example1.com服务器2为example2。
> mongodb://example1.com:27017,example2.com:27017

5. 连接 replica set 三台服务器 (端口 27017, 27018, 和27019):
> mongodb://localhost,localhost:27018,localhost:27019

6. 连接 replica set 三台服务器, 写入操作应用在主服务器 并且分布查询到从服务器。
> mongodb://host1,host2,host3/?slaveOk=true

7. 直接连接第一个服务器,无论是replica set一部分或者主服务器或者从服务器。
> mongodb://host1,host2,host3/?connect=direct;slaveOk=true

8. 当你的连接服务器有优先级,还需要列出所有服务器,你可以使用上述连接方式。
安全模式连接到localhost:
> mongodb://localhost/?safe=true</pre>

9. 以安全模式连接到replica set,并且等待至少两个复制服务器成功写入,超时时间设置为2秒。
> mongodb://host1,host2,host3/?safe=true;w=2;wtimeoutMS=2000</pre>

2. MongoDB创建数据库

语法

> use DATABASE_NAME
  1. 如果数据库不存在,则创建数据库,否则切换到制定的数据库
  2. 显示所有数据库 show dbs
  3. 当数据库中没有集合时,是不会显示的

3. MongoDB删除数据库

语法

> db.dropDatabase()

先要切换到想要删除的数据库:use DATABASE_NAME

4. MongoDB创建集合

语法

> db.createCollection(name, options)

参数说明

  • name: 要创建的集合名称
  • options: 可选参数, 指定有关内存大小及索引的选项

options 可以是如下参数:

字段类型描述
capped布尔(可选)如果为 true,则创建固定集合。固定集合是指有着固定大小的集合,当达到最大值时,它会自动覆盖最早的文档。当该值为 true 时,必须指定 size 参数。
autoIndexId布尔(可选)如为 true,自动在 _id 字段创建索引。默认为 false。
size数值(可选)为固定集合指定一个最大值(以字节计)。如果 capped 为 true,也需要指定该字段。
max数值(可选)指定固定集合中包含文档的最大数量。

在插入文档时,MongoDB 首先检查固定集合的 size 字段,然后检查 max 字段。

实例

1. 在 test 数据库中创建 jianshu 集合:
> use test
switched to db test
> db.createCollection("jianshu")
{ "ok" : 1 }

2. 如果要查看已有集合,可以使用 show collections 命令:
> show collections
jianshu

3. 下面是带有几个关键参数的 createCollection() 的用法:
创建固定集合 mycol,整个集合空间大小 6142800 KB, 文档最大个数为 10000 个。
> db.createCollection("mycol", { capped : true, autoIndexId : true, size : 
6142800, max : 10000 } )
{ "ok" : 1 }

4. 在 MongoDB 中,你不需要创建集合。当你插入一些文档时,MongoDB 会自
> db.mycol1.insert({"name" : "www.google.com"})
> show collections
jianshu
mycol
mycol1

5. MongoDB 删除集合

语法

> db.collection.drop()

参数说明

返回值
如果成功删除选定集合,则 drop() 方法返回 true,否则返回 false。

实例

1. 在数据库 test 中,我们可以先通过 show collections 命令查看已存在的集合:
> use test
switched to db mydb
> show collections
jianshu
mycol
mycol1

2. 接着删除集合 mycol1 :
> db.mycol1.drop()
true

3. 通过 show collections 再次查看数据库 test 中的集合:
> show collections
jianshu
mycol

6. MongoDB 插入文档

BSON是一种类json的一种二进制形式的存储格式,简称为Binary JSON

插入文档

MongoDB 使用 insert() 或 save() 方法向集合中插入文档,语法如下:

> db.COLLECTION_NAME.insert(document)
  • db.collection.insertOne(): 向指定集合中插入一条文档数据
  • db.collection.insertMany(): 向指定集合中插入多条文档数据

实例

1. 以下文档可以存储在 MongoDB 的 test 数据库 的 jianshu 集合中:
> db.jianshu.insert({title: 'MongoDB 教程',  description: 'MongoDB 是一个 Nosql数据库', by: 'stefanchoo',url: 'http://www.jianshu.com', tags: ['mongodb','database','NoSQL'], likes: 100})

WriteResult({ "nInserted" : 1 })

> var document = db.jianshu.insertOne({title: 'Java虚拟机技术'})
> document
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5bd91dc2fd76390be3425d13")
}

> var res = db.jianshu.insertMany([{"a": 4}, {"b":5}])
> res
{
   "acknowledged" : true,
   "insertedIds" : [
       ObjectId("5bd92184fd76390be3425d16"),
       ObjectId("5bd92184fd76390be3425d17")
   ]
}

7. MongoDB 更新文档

MongoDB 使用 update()save() 方法来更新集合中的文档。接下来让我们详细来看下两个函数的应用及其区别。

update() 方法

update() 方法用于更新已存在的文档。语法格式如下:

>db.collection.update(
  <query>,
  <update>,
  {
    upsert: <boolean>,
    multi: <boolean>,
    writeConcern: <document>
  }
 )
  • db.collection.updateOne() 向指定集合更新单个文档
  • db.collection.updateMany() 向指定集合更新多个文档

参数说明:

  • query : update的查询条件,类似sql update查询内where后面的。
  • update : update的对象和一些更新的操作符(如​inc…)等,也可以理解为sql update查询内set后面的
  • upsert : 可选,这个参数的意思是,如果不存在update的记录,是否插入objNew,true为插入,默认是false,不插入。
  • multi : 可选,mongodb 默认是false,只更新找到的第一条记录,如果这个参数为true,就把按条件查出来多条记录全部更新。
  • writeConcern :可选,抛出异常的级别。

实例

> db.jianshu.find().pretty()
{
   "_id" : ObjectId("5bd91d34fd76390be3425d12"),
   "title" : "MongoDB 教程",
   "description" : "MongoDB 是一个 Nosql数据库",
   "by" : "stefanchoo",
   "url" : "http://www.jianshu.com",
   "tags" : [
       "mongodb",
       "database",
       "NoSQL"
   ],
   "likes" : 100
}
{ "_id" : ObjectId("5bd91dc2fd76390be3425d13"), "title" : "Java虚拟机技术" }
{ "_id" : ObjectId("5bd92184fd76390be3425d16"), "a" : 4 }
{ "_id" : ObjectId("5bd92184fd76390be3425d17"), "b" : 5 }

> db.test.insert([ {"name":"abc","age":"25","status":"zxc"}, {"name":"dec","age":"19","status":"qwe"}, {"name":"asd","age":"30","status":"nmn"}, ] )
BulkWriteResult({
   "writeErrors" : [ ],
   "writeConcernErrors" : [ ],
   "nInserted" : 3,
   "nUpserted" : 0,
   "nMatched" : 0,
   "nModified" : 0,
   "nRemoved" : 0,
   "upserted" : [ ]
})
> db.test.find().pretty()
{
   "_id" : ObjectId("5bd92829fd76390be3425d1e"),
   "name" : "abc",
   "age" : "25",
   "status" : "zxc"
}
{
   "_id" : ObjectId("5bd92829fd76390be3425d1f"),
   "name" : "dec",
   "age" : "19",
   "status" : "qwe"
}
{
   "_id" : ObjectId("5bd92829fd76390be3425d20"),
   "name" : "asd",
   "age" : "30",
   "status" : "nmn"
}

> db.test.updateOne({'age':{$gt:'19'}}, {$set:{'name':'abcd'}})
{ "acknowledged" : true, "matchedCount" : 1, "modifiedCount" : 1 }
> db.test.find().pretty()
{
   "_id" : ObjectId("5bd92829fd76390be3425d1e"),
   "name" : "abcd",
   "age" : "25",
   "status" : "zxc"
}
{
   "_id" : ObjectId("5bd92829fd76390be3425d1f"),
   "name" : "dec",
   "age" : "19",
   "status" : "qwe"
}
{
   "_id" : ObjectId("5bd92829fd76390be3425d20"),
   "name" : "asd",
   "age" : "30",
   "status" : "nmn"
}

> db.test.updateMany({'age':{$gte:'19'}}, {$set:{'name':'abcd'}})
{ "acknowledged" : true, "matchedCount" : 3, "modifiedCount" : 2 }
> db.test.find().pretty()
{
   "_id" : ObjectId("5bd92829fd76390be3425d1e"),
   "name" : "abcd",
   "age" : "25",
   "status" : "zxc"
}
{
   "_id" : ObjectId("5bd92829fd76390be3425d1f"),
   "name" : "abcd",
   "age" : "19",
   "status" : "qwe"
}
{
   "_id" : ObjectId("5bd92829fd76390be3425d20"),
   "name" : "abcd",
   "age" : "30",
   "status" : "nmn"
}

save() 方法

如id存在,则替换,否则相当于insert

> db.test.find().pretty()
{
   "_id" : ObjectId("5bd92829fd76390be3425d1e"),
   "name" : "abcd",
   "age" : "25",
   "status" : "zxc"
}
{
   "_id" : ObjectId("5bd92829fd76390be3425d1f"),
   "name" : "abcd",
   "age" : "19",
   "status" : "qwe"
}
{
   "_id" : ObjectId("5bd92829fd76390be3425d20"),
   "name" : "abcd",
   "age" : "30",
   "status" : "nmn"
}

> db.test.save({ "_id" : ObjectId("5bd92829fd76390be3425d1e"), "name" : "abcd", "age" : "28", "status" : "zxc" } )
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })

> db.test.find().pretty()
{
   "_id" : ObjectId("5bd92829fd76390be3425d1e"),
   "name" : "abcd",
   "age" : "28",
   "status" : "zxc"
}
{
   "_id" : ObjectId("5bd92829fd76390be3425d1f"),
   "name" : "abcd",
   "age" : "19",
   "status" : "qwe"
}
{
   "_id" : ObjectId("5bd92829fd76390be3425d20"),
   "name" : "abcd",
   "age" : "30",
   "status" : "nmn"
}

8. MongoDB 删除文档

语法

> db.collection.remove(<query>, {
                                    justOne: <boolean>,
                                    writeConcern: <document>
                                })
> db.collection.deleteOne(<query>)  删除单个文档
> db.collection.deleteMany(<query>) 删除多个文档

参数说明:

  • query :(可选)删除的文档的条件。
  • justOne : (可选)如果设为 true 或 1,则只删除一个文档。
  • writeConcern :(可选)抛出异常的级别。

实例

> db.test.find().pretty()
{
   "_id" : ObjectId("5bd92829fd76390be3425d1e"),
   "name" : "abcd",
   "age" : "28",
   "status" : "zxc"
}
{
   "_id" : ObjectId("5bd92829fd76390be3425d1f"),
   "name" : "abcd",
   "age" : "19",
   "status" : "qwe"
}
{
   "_id" : ObjectId("5bd92829fd76390be3425d20"),
   "name" : "abcd",
   "age" : "30",
   "status" : "nmn"
}
> db.test.remove({"age": {"$gte":"28"}}, {"justOne": true})
WriteResult({ "nRemoved" : 1 })
> db.test.find().pretty()
{
   "_id" : ObjectId("5bd92829fd76390be3425d1f"),
   "name" : "abcd",
   "age" : "19",
   "status" : "qwe"
}
{
   "_id" : ObjectId("5bd92829fd76390be3425d20"),
   "name" : "abcd",
   "age" : "30",
   "status" : "nmn"
}

> db.test.deleteOne({"status": "qwe"})
{ "acknowledged" : true, "deletedCount" : 1 }
> db.test.find().pretty()
{
   "_id" : ObjectId("5bd92829fd76390be3425d20"),
   "name" : "abcd",
   "age" : "30",
   "status" : "nmn"
}

> db.test.insert({"name":"abcd"})
WriteResult({ "nInserted" : 1 })
> db.test.find().pretty()
{
   "_id" : ObjectId("5bd92829fd76390be3425d20"),
   "name" : "abcd",
   "age" : "30",
   "status" : "nmn"
}
{ "_id" : ObjectId("5bd92dadfd76390be3425d21"), "name" : "abcd" }
> db.test.deleteMany({"name":"abcd"})
{ "acknowledged" : true, "deletedCount" : 2 }
> db.test.find().pretty()

9. MongoDB 查询文档

语法

> db.collection.find(query, projection)</pre>
  • query :可选,使用查询操作符指定查询条件
  • projection :可选,使用投影操作符指定返回的键。查询时返回文档中所有键值, 只需省略该参数即可(默认省略)。

若不指定 projection,则默认返回所有键,指定 projection 格式如下,有两种模式

> db.collection.find(query, {title: 1, by: 1})  // inclusion模式 指定返回的键title, by,不返回其他键
> db.collection.find(query, {title: 0, by: 0})  // exclusion模式 指定不返回的键,返回其他键
默认情况下不可混用,除了在inclusion模式下,指定_id不显示
> db.collection.find(query, {_id:0, title: 1, by: 1}) 
db.col.find().pretty()
pretty() 方法以格式化的方式来显示所有文档。
除了 find() 方法之外,还有一个 findOne() 方法,它只返回一个文档。

MongoDB 与 RDBMS Where 语句比较

如果你熟悉常规的 SQL 数据,通过下表可以更好的理解 MongoDB 的条件语句查询:

操作格式范例RDBMS中的类似语句
等于 {<key>:<value>}db.col.find({"by":"菜鸟教程"}).pretty()where by = '菜鸟教程'
小于{<key>:{$lt:<value>}}db.col.find({"likes":{$lt:50}}).pretty()where likes < 50
小于或等于{<key>:{$lte:<value>}}db.col.find({"likes":{$lte:50}}).pretty()where likes <= 50
大于{<key>:{$gt:<value>}}db.col.find({"likes":{$gt:50}}).pretty()where likes > 50
大于或等于{<key>:{$gte:<value>}}db.col.find({"likes":{$gte:50}}).pretty()where likes >= 50
不等于{<key>:{$ne:<value>}}db.col.find({"likes":{$ne:50}}).pretty()where likes != 50

MongoDB AND 条件

MongoDB 的 find() 方法可以传入多个键(key),每个键(key)以逗号隔开,即常规 SQL 的 AND 条件。

语法

> db.col.find({key1:value1, key2:value2}).pretty()

实例

> db.test.find({"name":"abc","age":"25"}).pretty()
{
"_id" : ObjectId("5aed75de8ed7436bd4545562"),
"name" : "abc",
"age" : "25",
"status" : "zxc"
}

MongoDB OR 条件

MongoDB OR 条件语句使用了关键字 $or,语法格式如下:

> db.col.find(
{
  $or: [
            {key1: value1}, {key2:value2}
        ]
}).pretty()

实例

> db.test.find({$or:[{"name":"abc"},{"age":{$gt:"19"}}]}).pretty()
{
  "_id" : ObjectId("5aed75de8ed7436bd4545562"),
  "name" : "abc",
  "age" : "25",
  "status" : "zxc"
}
{
  "_id" : ObjectId("5aed75de8ed7436bd4545564"),
  "name" : "asd",
  "age" : "30",
  "status" : "nmn"
}

AND 和 OR 联合使用

> db.test.find({"status":"zxc", $or:[{"name":"abc"},{"age":{$gt:"19"}}]}).pretty()
{
"_id" : ObjectId("5aed75de8ed7436bd4545562"),
"name" : "abc",
"age" : "25",
"status" : "zxc"
}

10. MongoDB $type 操作符

描述

在本章节中,我们将继续讨论MongoDB中条件操作符 $type。

$type操作符是基于BSON类型来检索集合中匹配的数据类型,并返回结果。

MongoDB 中可以使用的类型如下表所示:

类型数字备注
Double1
String2
Object3
Array4
Binary data5
Undefined6已废弃。
Object id7
Boolean8
Date9
Null10
Regular Expression11
JavaScript13
Symbol14
JavaScript (with scope)15
32-bit integer16
Timestamp17
64-bit integer18
Min key255Query with -1.
Max key127

MongoDB 操作符 – $type 实例

如果想获取 "col" 集合中 title 为 String 的数据,你可以使用以下命令:
> db.col.find({"title" : {$type : 2}})

11. MongoDB Limit与Skip方法

MongoDB Limit() 方法

如果你需要在MongoDB中读取指定数量的数据记录,可以使用MongoDB的Limit方法,limit()方法接受一个数字参数,该参数指定从MongoDB中读取的记录条数。

语法:

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

实例

> db.test.find({"age":{$gt:"18"}}, {_id:0, status:0}).pretty()
{ "name" : "abc", "age" : "25" }
{ "name" : "dec", "age" : "19" }
{ "name" : "asd", "age" : "30" }
> db.test.find({"age":{$gt:"18"}}, {_id:0, status:0}).limit(2).pretty()
{ "name" : "abc", "age" : "25" }
{ "name" : "dec", "age" : "19" }

MongoDB Skip() 方法

我们除了可以使用limit()方法来读取指定数量的数据外,还可以使用skip()方法来跳过指定数量的数据,skip方法同样接受一个数字参数作为跳过的记录条数。

语法

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

实例

> db.test.find({"age":{$gt:"18"}}, {_id:0, status:0}).limit(2).skip(1).pretty()
{ "name" : "dec", "age" : "19" }
{ "name" : "asd", "age" : "30" }

12. MongoDB 排序

MongoDB sort()方法

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

语法

sort()方法基本语法如下所示:

> db.COLLECTION_NAME.find().sort({KEY:1})

实例

> db.col.find({},{"title":1,"likes":1, _id:0}).sort({"likes":-1})
{ "title" : "PHP 教程", "likes" : 200 }
{ "title" : "Java 教程", "likes" : 150 }
{ "title" : "MongoDB", "likes" : 110 }
> db.col.find({},{"title":1,"likes":1, _id:0}).sort({"likes":1})
{ "title" : "MongoDB", "likes" : 110 }
{ "title" : "Java 教程", "likes" : 150 }
{ "title" : "PHP 教程", "likes" : 200 }
注意

skip(),limit(),sort() 三个放在一起执行的时候,不管其位置如何,执行的顺序总是 sort() > skip() > limit()

如要按照位置顺序来执行,则需要借助管道流aggregate

可参考:Aggregate

MongoDB索引

索引能够极大地提高效率,如果没有索引,MongoDB在读取数据时必须扫描集合中的每个文件并选取那些符合查询条件的记录。

索引是特殊的数据结构,索引存储在一个易于遍历读取的数据集合中,索引是对数据库表中的一列或多列的值进行排序的一种结构。

ensureIndex() 方法

语法

> db.COLLECTION_NAME.ensureIndex({key:1})

语法中的 Key 值为你要创建的索引字段,1为指定按升序创建索引,如果你想按照降序来创建索引指定为-1即可。

实例

> db.col.ensureIndex({"title":1})

ensureIndex() 方法中你也可以设置使用多个字段创建索引(关系型数据库中称作复合索引)。

> db.col.ensureIndex({"title":1,"description":-1})

ensureIndex() 接收可选参数,可选参数列表如下:

ParameterTypeDescription
backgroundBoolean建索引过程会阻塞其它数据库操作,background可指定以后台方式创建索引,即增加 “background” 可选参数。 “background” 默认值为false
uniqueBoolean建立的索引是否唯一。指定为true创建唯一索引。默认值为false.
namestring索引的名称。如果未指定,MongoDB的通过连接索引的字段名和排序顺序生成一个索引名称。
dropDupsBoolean在建立唯一索引时是否删除重复记录,指定 true 创建唯一索引。默认值为 false.
sparseBoolean对文档中不存在的字段数据不启用索引;这个参数需要特别注意,如果设置为true的话,在索引字段中不会查询出不包含对应字段的文档.。默认值为 false.
expireAfterSecondsinteger指定一个以秒为单位的数值,完成 TTL设定,设定集合的生存时间。
vindex version索引的版本号。默认的索引版本取决于mongod创建索引时运行的版本。
weightsdocument索引权重值,数值在 1 到 99,999 之间,表示该索引相对于其他索引字段的得分权重。
default_languagestring对于文本索引,该参数决定了停用词及词干和词器的规则的列表。 默认为英语
language_overridestring对于文本索引,该参数指定了包含在文档中的字段名,语言覆盖默认的language,默认值为 language.

实例

在后台创建索引:

> db.col.ensureIndex({"title":1},{"background":1})
{
"createdCollectionAutomatically" : false,
"numIndexesBefore" : 1,
"numIndexesAfter" : 2,
"ok" : 1
}

> db.col.ensureIndex({"likes":1})
{
"createdCollectionAutomatically" : false,
"numIndexesBefore" : 2,
"numIndexesAfter" : 3,
"ok" : 1
}

> db.col.getIndexes()
[
{
"v" : 2,
"key" : {
"_id" : 1
},
"name" : "_id_",
"ns" : "test.col"
},
{
"v" : 2,
"key" : {
"title" : 1
},
"name" : "title_1",
"ns" : "test.col",
"background" : 1
},
{
"v" : 2,
"key" : {
"likes" : 1
},
"name" : "likes_1",
"ns" : "test.col"
}
]

通过在创建索引时加background:true 的选项,让创建工作在后台执行

查看索引:db.collection.getIndexes(),默认_id作为索引,由数据库本身来维持,且不可删除。

    原文作者:StefanChoo
    原文地址: https://www.jianshu.com/p/7d739317bc1f
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞