MongoDB

使用 db.COLLECTION_NAME.insert() 可以往当前数据库中集合 COLLECTION_NAME 下插入一个或多个文档。如插入一个文档：

> db.products.insert( { item: "card", qty: 15 } )
WriteResult({ "nInserted" : 1 })

如果插入的文档数据中没有 _id 字段，则会自动生成一个 _id 字段；如果插入的文档中带有 _id 字段，则用户自己需要确保 _id 字段不重复。

下面是一次插入多个文档的例子：

> db.products.insert([ { item: "pencil", qty: 15 }, { item: "book", qty: 10} ] )
BulkWriteResult({
	"writeErrors" : [ ],
	"writeConcernErrors" : [ ],
	"nInserted" : 2,
	"nUpserted" : 0,
	"nMatched" : 0,
	"nModified" : 0,
	"nRemoved" : 0,
	"upserted" : [ ]
})

使用 db.COLLECTION_NAME.insertOne() 和 db.COLLECTION_NAME.insertMany() 可以往集合中分别插入一个和多个文档，执行成功后它们的返回数据类型和 db.COLLECTION_NAME.insert() 不一样。下面是使用 insertMany() 插入多个文档的实例：

>  db.products.insertMany([ { item: "pencil", qty: 30 }, { item: "book", qty: 40} ] )
{
	"acknowledged" : true,
	"insertedIds" : [
		ObjectId("5b6e7d9490789f89f897931d"),
		ObjectId("5b6e7d9490789f89f897931e")
	]
}

可见， insertMany() 的返回数据确实和 insert() 不一样。

注：在 nodejs 的 MongoDB 驱动中 insert() 已经被标记为过时的，推荐使用 insertOne() 和 insertMany() 。

使用 db.COLLECTION_NAME.find() 可以得到集合中的所有文档。如：

> db.products.find()
{ "_id" : ObjectId("5b6e7d6790789f89f897931a"), "item" : "card", "qty" : 15 }
{ "_id" : ObjectId("5b6e7d8c90789f89f897931b"), "item" : "pencil", "qty" : 15 }
{ "_id" : ObjectId("5b6e7d8c90789f89f897931c"), "item" : "book", "qty" : 10 }
{ "_id" : ObjectId("5b6e7d9490789f89f897931d"), "item" : "pencil", "qty" : 30 }
{ "_id" : ObjectId("5b6e7d9490789f89f897931e"), "item" : "book", "qty" : 40 }

通过指定 pretty() 方法可以更好地显示结果。如：

> db.products.find().pretty()
{
	"_id" : ObjectId("5b6e7d6790789f89f897931a"),
	"item" : "card",
	"qty" : 15
}
{
	"_id" : ObjectId("5b6e7d8c90789f89f897931b"),
	"item" : "pencil",
	"qty" : 15
}
{
	"_id" : ObjectId("5b6e7d8c90789f89f897931c"),
	"item" : "book",
	"qty" : 10
}
{
	"_id" : ObjectId("5b6e7d9490789f89f897931d"),
	"item" : "pencil",
	"qty" : 30
}
{
	"_id" : ObjectId("5b6e7d9490789f89f897931e"),
	"item" : "book",
	"qty" : 40
}

> db.products.find({item: "book"})
{ "_id" : ObjectId("5b6e7d8c90789f89f897931c"), "item" : "book", "qty" : 10 }
{ "_id" : ObjectId("5b6e7d9490789f89f897931e"), "item" : "book", "qty" : 40 }

> db.products.find({qty: {$gte: 30}})
{ "_id" : ObjectId("5b6e7d9490789f89f897931d"), "item" : "pencil", "qty" : 30 }
{ "_id" : ObjectId("5b6e7d9490789f89f897931e"), "item" : "book", "qty" : 40 }

> db.products.find({item: "book", qty: {$gte: 30}})                  // AND实例
{ "_id" : ObjectId("5b6e7d9490789f89f897931e"), "item" : "book", "qty" : 40 }

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

> db.products.find({$or: [{item: "book"}, {qty: {$gte: 30}} ] })     // OR实例
{ "_id" : ObjectId("5b6e7d8c90789f89f897931c"), "item" : "book", "qty" : 10 }
{ "_id" : ObjectId("5b6e7d9490789f89f897931d"), "item" : "pencil", "qty" : 30 }
{ "_id" : ObjectId("5b6e7d9490789f89f897931e"), "item" : "book", "qty" : 40 }

> db.products.find()
{ "_id" : ObjectId("5b6e7d6790789f89f897931a"), "item" : "card", "qty" : 15 }
{ "_id" : ObjectId("5b6e7d8c90789f89f897931b"), "item" : "pencil", "qty" : 15 }
{ "_id" : ObjectId("5b6e7d8c90789f89f897931c"), "item" : "book", "qty" : 10 }
{ "_id" : ObjectId("5b6e7d9490789f89f897931d"), "item" : "pencil", "qty" : 30 }
{ "_id" : ObjectId("5b6e7d9490789f89f897931e"), "item" : "book", "qty" : 40 }
> db.products.find({}, {_id: 1, item: 1} )    // inclusion模式
{ "_id" : ObjectId("5b6e7d6790789f89f897931a"), "item" : "card" }
{ "_id" : ObjectId("5b6e7d8c90789f89f897931b"), "item" : "pencil" }
{ "_id" : ObjectId("5b6e7d8c90789f89f897931c"), "item" : "book" }
{ "_id" : ObjectId("5b6e7d9490789f89f897931d"), "item" : "pencil" }
{ "_id" : ObjectId("5b6e7d9490789f89f897931e"), "item" : "book" }

> db.products.find({}, {qty: 0})               // exclusion模式
{ "_id" : ObjectId("5b6e7d6790789f89f897931a"), "item" : "card" }
{ "_id" : ObjectId("5b6e7d8c90789f89f897931b"), "item" : "pencil" }
{ "_id" : ObjectId("5b6e7d8c90789f89f897931c"), "item" : "book" }
{ "_id" : ObjectId("5b6e7d9490789f89f897931d"), "item" : "pencil" }
{ "_id" : ObjectId("5b6e7d9490789f89f897931e"), "item" : "book" }

使用 db.collection.update() 和 db.collection.save() 可以使用更新文档。

update() 的用法如下：

db.collection.update(
   <query>,
   <update>,
   {
     upsert: <boolean>,
     multi: <boolean>,   // 默认只更新找到的第一个文档，如果这个参数为true，则更新所有文档
     writeConcern: <document>,  // 设置抛出异常的级别
     collation: <document>,
     arrayFilters: [ <filterdocument1>, ... ]
   }
)

其中：query 用来指定查询条件，而 update 指定更新的对象和一些更新操作符（如 $set , $inc 等，可参考 https://docs.mongodb.com/manual/reference/operator/update/ ）。

例如，更新 item 为 book 的文档，把其 qty 字段设置为 100：

> db.products.update({item: "book"}, {$set : {qty: 100}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.products.find()
{ "_id" : ObjectId("5b6e7d6790789f89f897931a"), "item" : "card", "qty" : 15 }
{ "_id" : ObjectId("5b6e7d8c90789f89f897931b"), "item" : "pencil", "qty" : 15 }
{ "_id" : ObjectId("5b6e7d8c90789f89f897931c"), "item" : "book", "qty" : 100 }
{ "_id" : ObjectId("5b6e7d9490789f89f897931d"), "item" : "pencil", "qty" : 30 }
{ "_id" : ObjectId("5b6e7d9490789f89f897931e"), "item" : "book", "qty" : 40 }

上面例子中，只会更新第一个找到的文档，要更新所有找到的文档，则需要指定 multi 为 true ，如：

> db.products.update({item: "book"}, {$set : {qty: 100}}, {multi:true})  // 所有book的qty设置为100
WriteResult({ "nMatched" : 2, "nUpserted" : 0, "nModified" : 1 })
> db.products.update({item: "book"}, {$inc : {qty: 1}}, {multi:true})    // 所有book的qty增加1
WriteResult({ "nMatched" : 2, "nUpserted" : 0, "nModified" : 2 })

save() 方法通过传入的文档来替换已有文档。不指定 _id 字段 save() 方法类似于 insert() 方法；如果指定 _id 字段，则会更新该 _id 的数据。例如，替换 _id 为 5b6e7d9490789f89f897931e 的文档：

> db.products.save({ "_id" : ObjectId("5b6e7d9490789f89f897931e"), "item" : "book1", "qty" : 100 })
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })

使用 db.collection.remove() 可以删除指定文档，用法如下：

db.collection.remove(
   <query>,
   {
     justOne: <boolean>,      // 是否只删除第一个匹配文档，默认为false
     writeConcern: <document>,
     collation: <document>
   }
)

下面是删除 item 为 pencil 的文档的实例：

> db.products.find()
{ "_id" : ObjectId("5b6e7d6790789f89f897931a"), "item" : "card", "qty" : 15 }
{ "_id" : ObjectId("5b6e7d8c90789f89f897931b"), "item" : "pencil", "qty" : 15 }
{ "_id" : ObjectId("5b6e7d8c90789f89f897931c"), "item" : "book", "qty" : 101 }
{ "_id" : ObjectId("5b6e7d9490789f89f897931d"), "item" : "pencil", "qty" : 30 }
{ "_id" : ObjectId("5b6e7d9490789f89f897931e"), "item" : "book1", "qty" : 100 }
> db.products.remove({item: "pencil"})      // 删除item为pencil的文档
WriteResult({ "nRemoved" : 2 })
> db.products.find()
{ "_id" : ObjectId("5b6e7d6790789f89f897931a"), "item" : "card", "qty" : 15 }
{ "_id" : ObjectId("5b6e7d8c90789f89f897931c"), "item" : "book", "qty" : 101 }
{ "_id" : ObjectId("5b6e7d9490789f89f897931e"), "item" : "book1", "qty" : 100 }

在执行 remove() 命令前先执行 find() 命令来判断执行的条件是否正确，以避免误删数据。

后文将介绍如果部署 3 个节点的 MongoDB 副本集集群，假设 3 个节点的域名分别为表 3 所示。

Table 3: 3 个节点的域名

Replica Set Member	Hostname
Member 0	mongodb0.example.net
Member 1	mongodb1.example.net
Member 2	mongodb2.example.net

在每个机器上启动 MongoDB 很简单，分别登录这 3 个机器，带 --replSet <name> 参数启动 mongod 即可：

$ mongod --replSet "rs0" --fork --config <path-to-config>

说明：这和启动普通的 mongod 节点没有什么区别，唯一的不同在于需要设置副本集的名字（这个例子中为 rs0）。注： 同一副本集群的 replSet 名称必需相同。 除了在命令行直接指定外，也可以在其配置文件中指定副本集的名字，如：

replication:
   replSetName: "rs0"

登录 3 台机器中的任意一台（比如 mongodb0.example.net），进入到 mongo shell 中，执行 rs.initiate 命令，在这个命令的参数中指定副本集名字和其它节点的信息，比如：

rs.initiate( {
   _id : "rs0",
   members: [
      { _id: 0, host: "mongodb0.example.net:27017" },
      { _id: 1, host: "mongodb1.example.net:27017" },
      { _id: 2, host: "mongodb2.example.net:27017" }
   ]
})

通过前面的步骤，集群的基本配置已经完成了。在 mongo shell 中执行 rs.status() 可以查看各个节点状态。如：

......
	"members" : [
		{
			"_id" : 0,
			"name" : "mongodb0.example.net:27017",
			"health" : 1,
			"state" : 1,
			"stateStr" : "PRIMARY",
			"uptime" : 1125,
......
        {
			"_id" : 1,
			"name" : "mongodb1.example.net:27018",
			"health" : 1,
			"state" : 2,
			"stateStr" : "SECONDARY",
			"uptime" : 735,
......
		{
			"_id" : 2,
			"name" : "mongodb2.example.net:27019",
			"health" : 1,
			"state" : 2,
			"stateStr" : "SECONDARY",
			"uptime" : 735,

从输出中可知，mongodb0.example.net 是主节点，其它两个是从节点。

MongoDB 还支持其它一些操作，如 rs.stepDown()：将主节点降级为从节点；rs.add()增加节点；rs.remove()删除节点，等等。可以执行 rs.help() 查看帮助，如：

> rs.help()
	rs.status()                                { replSetGetStatus : 1 } checks repl set status
	rs.initiate()                              { replSetInitiate : null } initiates set with default settings
	rs.initiate(cfg)                           { replSetInitiate : cfg } initiates set with configuration cfg
	rs.conf()                                  get the current configuration object from local.system.replset
	rs.reconfig(cfg)                           updates the configuration of a running replica set with cfg (disconnects)
	rs.add(hostportstr)                        add a new member to the set with default attributes (disconnects)
	rs.add(membercfgobj)                       add a new member to the set with extra attributes (disconnects)
	rs.addArb(hostportstr)                     add a new member which is arbiterOnly:true (disconnects)
	rs.stepDown([stepdownSecs, catchUpSecs])   step down as primary (disconnects)
	rs.syncFrom(hostportstr)                   make a secondary sync from the given member
	rs.freeze(secs)                            make a node ineligible to become primary for the time specified
	rs.remove(hostportstr)                     remove a host from the replica set (disconnects)
	rs.slaveOk()                               allow queries on secondary nodes

	rs.printReplicationInfo()                  check oplog size and time range
	rs.printSlaveReplicationInfo()             check replica set members and replication lag
	db.isMaster()                              check who is primary