- 浏览: 32290 次
- 性别:
- 来自: 福州
文章分类
最新评论
1.插入和保存document
如前所述,向collection插入document使用insert方法
如果document里边没有"_id"键,"_id"会被自动创建
批量插入
批量插入是一种更高效的方法,传递给database一个document的数组,可以一次插入多个document。单个插入的时候,向 database传送一个document,前边会附加一个头部,告诉database在某个collection执行一次插入操作。批量插入只产生一个 TCP请求,意味着不用处理很多请求,同时也省掉了处理头部的时间。批量插入只能插入到一个collection里边去。
批量插入只能用于应用程序接口,shell不支持(至少到目前还不支持)。
另外,如果想导入数据(比如说从mysql),不要使用批量插入,使用命令行工具如mongoimport。
2.删除document
这个命令会删除users里边的所有document。
remove函数可以有一个查询用document做参数,以删除符合条件的document。
这个命令删除所有"opt-out"为true的document。
删除文档通常是一个非常快的操作,如果想清除整个collection,还有一种更快的方法,使用drop函数然后重建索引。
3.更新document
udpate方法可以携带两个参数:
- 查询用document, 用于定位哪些document将会被更新
- 修饰符document,用于描述如何修改找到的document
更新是原子性操作,先到达服务器的将会被先执行,后到达的会被后执行,所以,后边的会覆盖前边的修改。
document替换
使用一个新的document来替换匹配的,上一篇文章里用的其实就是document替换,如
document替换时一个常见的错误是当有多个匹配的document时候可能会导致duplicate key错误。举个例子,
假设我们有好几个名字都叫joe的document,
{"_id" : ObjectId("4b2b9f67a1f631733d917a7b"), "name" : "joe", "age" : 65},
{"_id" : ObjectId("4b2b9f67a1f631733d917a7c"), "name" : "joe", "age" : 20},
{"_id" : ObjectId("4b2b9f67a1f631733d917a7d"), "name" : "joe", "age" : 49},
现在,2号joe(20岁那个)生日到了,我们要给他的年龄加1,
{
"_id" : ObjectId("4b2b9f67a1f631733d917a7c"),
"name" : "joe",
"age" : 20
}
> joe.age++;
> db.people.update({"name" : "joe"}, joe);
E11001 duplicate key on update
Oh,出错了,怎么回事?数据库查找name为joe的document,找到的第一个是65岁那个,然后试图替换这个document,然而
数据库里边已经有一个"_id"为"4b2b9f67a1f631733d917a7c" 的记录了,”_id"是不可重复的,所以就有个这个错误。
所以执行document替换的时候要小心,确认你要替换的是唯一一个符合条件的。
使用修饰符
通常情况下我们只想更新document的一部分,我们可以使用更新修饰符来做到这一点。
假设我们有一个记录网站访问信息的一个collection,里边的document像这个样子
"_id" : ObjectId("4b253b067525f35f94b60a31"),
"url" : "www.example.com",
"pageviews" : 52
}
pageviews是站点的访问次数,那么我想给它增加1的时候就可以这样子做
... {"$inc" : {"pageviews" : 1}})
"$inc"就是个更新修饰符,使用更新修饰符的时候,不能更新"_id"键的值。
下边我们看看常用的更新修饰符
- $set
$set修饰符设定指定的key的值,如果key不存在就创建一个
假设我们有下边一个用户档案> db.users.findOne()
{
"_id" : ObjectId("4b253b067525f35f94b60a31"),
"name" : "joe",
"age" : 30,
"sex" : "male",
"location" : "Wisconsin"
}> db.users.update({"_id" : ObjectId("4b253b067525f35f94b60a31")},
... {"$set" : {"favorite book" : "war and peace"}})> db.users.findOne()
{
"_id" : ObjectId("4b253b067525f35f94b60a31"),
"name" : "joe",
"age" : 30,
"sex" : "male",
"location" : "Wisconsin",
"favorite book" : "war and peace"
}> db.users.update({"name" : "joe"},
... {"$set" : {"favorite book" : "green eggs and ham"}})> db.users.update({"name" : "joe"},
... {"$set" : {"favorite book" :
... ["cat's cradle", "foundation trilogy", "ender's game"]}})> db.users.update({"name" : "joe"},
... {"$unset" : {"favorite book" : 1}})
- $inc
$inc修饰符只能用于数字,增加一个指定的数量 -
数组修饰符$push
$push向数组尾部追加一个元素,如果数组不存在则创建一个数组
例如,我想给一篇博客文章添加评论,而评论这个key还不存在
> db.blog.posts.findOne()
{
"_id" : ObjectId("4b2d75476cc613d5ee930164"),
"title" : "A blog post",
"content" : "..."
}
> db.blog.posts.update({"title" : "A blog post"}, {$push : {"comments" :
... {"name" : "joe", "email" : "joe@example.com", "content" : "nice post."}}})
> db.blog.posts.findOne()
{
"_id" : ObjectId("4b2d75476cc613d5ee930164"),
"title" : "A blog post",
"content" : "...",
"comments" : [
{
"name" : "joe",
"email" : "joe@example.com",
"content" : "nice post."
}
]
}
> db.blog.posts.update({"title" : "A blog post"}, {$push : {"comments" :
... {"name" : "bob", "email" : "bob@example.com", "content" : "good post."}}})
> db.blog.posts.findOne()
{
"_id" : ObjectId("4b2d75476cc613d5ee930164"),
"title" : "A blog post",
"content" : "...",
"comments" : [
{
"name" : "joe",
"email" : "joe@example.com",
"content" : "nice post."
},
{
"name" : "bob",
"email" : "bob@example.com",
"content" : "good post."
}
]
}
> db.papers.update({"authors cited" : {"$ne" : "Richie"}},
... {$push : {"authors cited" : "Richie"}})
> db.users.findOne({"_id" : ObjectId("4b2d75476cc613d5ee930164")})
{
"_id" : ObjectId("4b2d75476cc613d5ee930164"),
"username" : "joe",
"emails" : [
"joe@example.com",
"joe@gmail.com",
"joe@yahoo.com"
]
}
> db.users.update({"_id" : ObjectId("4b2d75476cc613d5ee930164")},
... {"$addToSet" : {"emails" : "joe@gmail.com"}})
> db.users.findOne({"_id" : ObjectId("4b2d75476cc613d5ee930164")})
{
"_id" : ObjectId("4b2d75476cc613d5ee930164"),
"username" : "joe",
"emails" : [
"joe@example.com",
"joe@gmail.com",
"joe@yahoo.com",
]
}
> db.users.update({"_id" : ObjectId("4b2d75476cc613d5ee930164")},
... {"$addToSet" : {"emails" : "joe@hotmail.com"}})
> db.users.findOne({"_id" : ObjectId("4b2d75476cc613d5ee930164")})
{
"_id" : ObjectId("4b2d75476cc613d5ee930164"),
"username" : "joe",
"emails" : [
"joe@example.com",
"joe@gmail.com",
"joe@yahoo.com",
"joe@hotmail.com"
]
}
> db.users.update({"_id" : ObjectId("4b2d75476cc613d5ee930164")}, {"$addToSet" :
... {"emails" : {"$each" : ["joe@php.net", "joe@example.com", "joe@python.org"]}}})
> db.users.findOne({"_id" : ObjectId("4b2d75476cc613d5ee930164")})
{
"_id" : ObjectId("4b2d75476cc613d5ee930164"),
"username" : "joe",
"emails" : [
"joe@example.com",
"joe@gmail.com",
"joe@yahoo.com",
"joe@hotmail.com"
"joe@php.net"
"joe@python.org"
]
}
-
数组修饰符$pop
$pop修饰符从数组的两端移除一个元素,{$pop : {key : 1}}从数组末端删除一个元素,{$pop :{key : -1}}从数组起始端删除一个元素
- 数组修饰符$pull
$pull从数组里移除符合条件的元素
比如,我们有一个待做事项列表> db.lists.insert({"todo" : ["dishes", "laundry", "dry cleaning"]})> db.lists.update({}, {"$pull" : {"todo" : "laundry"}})> db.lists.find()
{
"_id" : ObjectId("4b2d75476cc613d5ee930164"),
"todo" : [
"dishes",
"dry cleaning"
]
}
- 按照位置操作数组的值
有两种方式:一是按照位置,二是使用位置操作符($符号)
我们先看第一种用法,位置是从0开始索引的,我们可以使用这个索引就好像它是数组的一个属性一样
假设我们有一篇博客,带有一些评论> db.blog.posts.findOne()
{
"_id" : ObjectId("4b329a216cc613d5ee930192"),
"content" : "...",
"comments" : [
{
"comment" : "good post",
"author" : "John",
"votes" : 0
},
{
"comment" : "i thought it was too short",
"author" : "Claire",
"votes" : 3
},
{
"comment" : "free watches",
"author" : "Alice",
"votes" : -1
}
]
}> db.blog.update({"post" : post_id},
... {"$inc" : {"comments.0.votes" : 1}})
$就代表了匹配的元素的索引,如果我们想把评论里叫John的那个改成Jim,就可以这样子做db.blog.update({"comments.author" : "John"},
... {"$set" : {"comments.$.author" : "Jim"}})
4.Upsert
这估计是作者自己造的单词,指如果存在匹配的document就更新,如果不存在匹配就插入。
将update函数的第三个参数设为true即可,如:
shell的save函数也可以达到同样的目的,如果存在就更新,如果不存在就插入。
save函数使用一个document做参数,如果document有"_id"键就更新,如果没有就插入。
> x.num = 42
42
> db.foo.save(x)
5.更新多个document
缺省情况下,update函数只更新匹配的第一条记录,余下的不做改变,要想更新所有的匹配记录,将update函数的第4个参数设为true
... {$set : {gift : "Happy Birthday!"}}, false, true)
6.返回被更新的document
findAndModify命令的调用比普通的update要慢一些,因为它要等待服务器的响应。
findAndModify命令适合处理队列,或者其他的原子性的get-and-set式的操作。
假设我们有一个处理流程的collection,需要按一定的顺序执行,一个document代表了一个处理流程,如下
"_id" : ObjectId(),
"status" : state,
"priority" : N
}
status是个字符串,可能的值是"Ready","Running","Done".我们需要找到Ready状态优先级最高的处理流程,处理完成后把状态设为Done。
我们查询Ready状态的所有流程,按优先级排序,把最高的那个标记为Running,然后执行处理流程,结束后把状态设为Done。
db.processes.update({"_id" : ps._id}, {"$set" : {"status" : "RUNNING"}})
do_something(ps);
db.processes.update({"_id" : ps._id}, {"$set" : {"status" : "DONE"}})
这个算法并不好,会产生资源竞争。假设我们有两个线程来处理,一个线程(线程A)获取了document,另一个线程(线程B)可能在A将状态设置为 Running之前获取同一个document,然后两个线程会执行同一个处理流程。我们可以将检查status作为update的一部分来避免这个问题,不过会变得复杂:
while ((ps = cursor.next()) != null) {
ps.update({"_id" : ps._id, "status" : "READY"},
{"$set" : {"status" : "RUNNING"}});
var lastOp = db.runCommand({getlasterror : 1});
if (lastOp.n == 1) {
do_something(ps);
db.processes.update({"_id" : ps._id}, {"$set" : {"status" : "DONE"}})
break;
}
cursor = db.processes.find({"status" : "READY"}).sort({"priority" : -1}).limit(1);
}
这样有另外一个问题,依赖于运行时,一个线程可能处理完所有的工作然后结束,而另一个线程无用的跟在后边。线程A总是能获取处理流程,线程B试图获取同一个处理流程,然后失败,然后看着A完成所有的工作。这种情况就非常适合使用findAndModify命令,findAndModify命令在同一个操作里返回项目并更新它。
... "query" : {"status" : "READY"},
... "sort" : {"priority" : -1},
... "update" : {"$set" : {"status" : "RUNNING"}})
{
"ok" : 1,
"value" : {
"_id" : ObjectId("4b3e7a18005cab32be6291f7"),
"priority" : 1,
"status" : "READY"
}
}
Note:返回的document中的状态仍然是Ready,在修饰符生效之前,document已经返回了。
执行find查看就可以看到status被设置为了Running
{
"_id" : ObjectId("4b3e7a18005cab32be6291f7"),
"priority" : 1,
"status" : "RUNNING"
}
所以我们的程序应该是这个样子:
... "query" : {"status" : "READY"},
... "sort" : {"priority" : -1},
... "update" : {"$set" : {"status" : "RUNNING"}}).value
> do_something(ps)
> db.process.update({"_id" : ps._id}, {"$set" : {"status" : "DONE"}})
findAndModify命令里含有一个"update"键或"remove"键,remove表示匹配的document会被从collection里删除。
findAndModify命令里各个key的值意义如下
- findAndModify: 字符串,collection的名字
- query:查询document,检索document的条件
- sort:按照什么排序
- update:修饰符document,如何更新匹配的document
- remove:布尔值,指示是否删除document
- new:布尔值,指示返回的document是更新前的还是更新后的,缺省为更新前的。
7.密西西比河此岸的最快书写(The Fastest Write This Side of Mississippi)
本章节所关注的三个操作(insert,update,remove)看起来都是瞬发的,因为它们不会等待服务器的响应。
这并不是异步,应当被看作是"fire-and-forget"型的函数:客户端向服务器发送了document然后就继续自己的事情,客户端从不会收到一个响应诸如“ok,我收到你的消息啦”或者“不ok,你得给我重新发送一次”之类的东西。
安全操作
这些操作的安全版本就是在执行操作之后立刻调用getLastError命令。驱动会等待服务器响应并做相应的处理,通常是抛出一个异常,开发人员可以捕获然后处理。
操作成功之后,getLastError也会返回一些信息,比如update或remove,信息里包含了受影响的document数。
请求和连接
数据库为每个到mongoDB的连接建立一个请求队列,客户端发出一个请求,就会被放到队列的尾部。
注意是一个连接一个队列,如果我们打开两个shell,那么我们有了两个连接,如果我们在一个shell里执行插入,然后在另一个shell里执行查询,有可能得不到刚才插入的document。在同一个shell里执行插入和查询不会有问题,插入的document会被返回。这种情况在使用 Ruby,Python 和Java驱动时尤其值得注意,因为它们都是用连接池,出于性能上的考虑,这些驱动打开多个连接,然后将请求分配给它们。不过它们本身都有自己的机制,保证一系列的请求会使用一个连接来处理。
来源:http://www.open-open.com/lib/view/open1328161999125.html
发表评论
-
MongoDB优化
2012-03-20 11:00 1330部署优化(Linux系统): 1.关闭MongoDB数 ... -
MongoDB权威指南(7)- 管理
2012-03-20 11:01 8461.启动和停止mongoDB 从命令行启动mongoD ... -
MongoDB权威指南(6)- 高级主题
2012-03-20 11:01 9631.数据库命令 mongoDB提供了范围广泛的数据库命 ... -
MongoDB权威指南(5)- 聚合
2012-03-16 01:00 904除了基本的查询功能外,mongoDB还提供了聚合工具,从 ... -
MongoDB权威指南(4)- 索引
2012-03-16 00:58 1035Note:mongoDB的索引的工作方式和关系数据库中的 ... -
MongoDB权威指南(3)- 查询
2012-03-16 00:57 9251.find方法介绍 在不传入参数的情况下,find方 ... -
MongoDB权威指南(1)- 入门
2012-03-16 00:51 1190安装 解压缩出来就OK了,mongoDB缺省使用磁 ...
相关推荐
但根据文件标题《MongoDB权威指南中文版.pdf》和描述内容,我可以推测读者想要了解的是关于MongoDB数据库系统的一些基础知识和概念。 MongoDB是一款流行的开源文档导向数据库系统(NoSQL),它以其高性能、高可用性...
mongodb-win32-x86_64-2012plus-4.2.20-signed
赠送jar包:mongodb-driver-sync-4.2.3.jar; 赠送原API文档:mongodb-driver-sync-4.2.3-javadoc.jar; 赠送源代码:mongodb-driver-sync-4.2.3-sources.jar; 赠送Maven依赖信息文件:mongodb-driver-sync-4.2.3....
MongoDB Community Server(mongodb-org-server-5.0.8-1.el7.x86_64.rpm)适用于RedHat / CentOS 7.0 MongoDB是一个基于分布式文件存储的数据库。由C++语言编写。旨在为WEB应用提供可扩展的高性能数据存储解决方案。...
mongodb-win32-x86_64-2012plus-4.2.11-signed下载、安装教程
赠送jar包:mongodb-driver-core-4.2.3.jar; 赠送原API文档:mongodb-driver-core-4.2.3-javadoc.jar; 赠送源代码:mongodb-driver-core-4.2.3-sources.jar; 赠送Maven依赖信息文件:mongodb-driver-core-4.2.3....
赠送jar包:mongodb-driver-sync-4.2.3.jar; 赠送原API文档:mongodb-driver-sync-4.2.3-javadoc.jar; 赠送源代码:mongodb-driver-sync-4.2.3-sources.jar; 赠送Maven依赖信息文件:mongodb-driver-sync-4.2.3....
MongoDB安装包mongodb-win32-x86_64-2008plus-ssl-3.2.21-signed.msi
2. **聚合框架增强**:新增了`$merge`操作符,允许在聚合管道中将结果直接合并回源集合,简化了数据处理流程。 3. **交易支持**:MongoDB 4.2引入了跨文档的ACID事务,支持多文档的原子性操作,提高了数据一致性,...
mongodb-win32-x86_64-2008plus-ssl-4.0.12-signed.msi
mongodb-win32-x86_64-enterprise-windows-64-4.2.1-signed.msi mongodb windows 版本,官网下载的
mongodb-win32-x86_64-2008plus-ssl-4.0.10,windows版,官网下载太慢,保存一份
mongodb-win32-x86_64-2008plus-ssl-v4.0-latest-signed.msi 资源收集不易
8. **平台兼容性**:MongoDB支持多种操作系统,包括Windows,这里我们讨论的是适用于64位Windows 2008及更高版本的“mongodb-win32-x86_64-2008plus-ssl-3.2.4-signed.msi”安装包。 安装MongoDB的步骤通常包括: ...
mongodb-win32-x86_64-2008plus-2.6.7
mongodb-win32-x86_64-2008plus-ssl-4.0.23-signed.msi安装包 官网好难下载,找到后跟大家一起分享下,有需要可以来下
windows 64 mongo,mongodb-win32-x86_64-2012plus-4.2.1-signed
在本场景中,我们关注的是"mongodb-win32-x86_64-2012plus-4.2.3.zip"这个压缩包,它包含了适用于Windows 64位操作系统(2012及更高版本)的MongoDB 4.2.3版本。这个版本是MongoDB的一个重要里程碑,因为它引入了...
"signed"表示该安装文件已经过MongoDB官方签名验证,这意味着它未经修改,可以安全下载和安装,避免了潜在的恶意软件风险。 安装程序".msi"是一种Windows Installer包,是微软提供的安装和部署软件的标准格式。用户...