- MongoDB官方文档中文版
- MongoDB中文手册说明
- MongoDB简介
- 安装 MongoDB
- The mongo Shell
- MongoDB CRUD 操作
- 聚合
- 数据模型
- 事务
- 索引
- 安全
- 安全检查列表
- 启用访问控制
- 身份验证
- 基于角色的访问控制
- TLS / SSL(传输加密)
- 静态加密
- 客户端字段级加密
- 审计
- 网络和配置强化
- 实现字段级别修订
- 安全参考
- 附录
- 变更流
- 复制
- 分片
- 分片键
- 哈希分片
- 范围分片
- 区
- 管理分片区
- 按位置细分数据
- 用于更改SLA或SLO的分层硬件
- 按应用或客户细分数据
- 仅插入工作负载的分布式本地写入
- 管理分片区
- 使用块进行数据分区
- 在分片集群中拆分数据块
- 管理
- 存储
- 存储引擎
- 日志记录
- 管理日志记录
- GridFS
- FAQ:MongoDB 存储
- 存储引擎
- 参考
- 运算符
- 查询与映射运算符
- 更新运算符
- 聚合管道阶段
- 聚合管道操作符
- $abs (aggregation)
- $acos (aggregation)
- $acosh (aggregation)
- $add (aggregation)
- $addToSet (aggregation)
- $allElementsTrue (aggregation)
- $and (aggregation)
- $anyElementTrue (aggregation)
- $arrayElemAt (aggregation)
- $arrayToObject (aggregation)
- $asin (aggregation)
- $asinh (aggregation)
- $atan (aggregation)
- $atan2 (aggregation)
- $atanh (aggregation)
- $avg (aggregation)
- $ceil (aggregation)
- $cmp (aggregation)
- $concat (aggregation)
- $concatArrays (aggregation)
- $cond (aggregation)
- $convert (aggregation)
- $cos (aggregation)
- $dateFromParts (aggregation)
- $dateToParts (aggregation)
- $dateFromString (aggregation)
- $literal (aggregation)
- 查询修饰符
- 数据库命令
- 聚合命令
- 地理空间命令
- 查询和写操作命令
- 查询计划缓存命令
- 认证命令
- 用户管理命令
- 角色管理命令
- 复制命令
- 分片命令
- 会话命令
- 管理命令
- 诊断命令
- 免费监控命令
- 系统事件审计命令
- mongo Shell 方法
- 集合方法
- db.collection.aggregate()
- db.collection.bulkWrite()
- db.collection.copyTo()
- db.collection.count()
- db.collection.countDocuments()
- db.collection.estimatedDocumentCount()
- db.collection.createIndex()
- db.collection.createIndexes()
- db.collection.dataSize()
- db.collection.deleteOne()
- db.collection.deleteMany()
- db.collection.distinct()
- db.collection.drop()
- db.collection.dropIndex()
- db.collection.dropIndexes()
- db.collection.ensureIndex()
- db.collection.explain()
- db.collection.find()
- db.collection.findAndModify()
- db.collection.findOne()
- db.collection.findOneAndDelete()
- db.collection.findOneAndReplace()
- db.collection.findOneAndUpdate()
- db.collection.getIndexes()
- db.collection.getShardDistribution()
- db.collection.getShardVersion()
- db.collection.insert()
- db.collection.insertOne()
- db.collection.insertMany()
- db.collection.isCapped()
- db.collection.latencyStats()
- db.collection.mapReduce()
- db.collection.reIndex()
- db.collection.remove()
- db.collection.renameCollection()
- db.collection.replaceOne()
- db.collection.save()
- db.collection.stats()
- db.collection.storageSize()
- db.collection.totalIndexSize()
- db.collection.totalSize()
- db.collection.update()
- db.collection.updateOne()
- db.collection.updateMany()
- db.collection.watch()
- db.collection.validate()
- 词汇表
- 默认的MongoDB端口
- 默认的MongoDB读/写关注
- 服务器会话
- MongoDB驱动
- FAQ
- 联系我们
- 更多资料
- [快学Mongo]
- [Mongo问题讨论区]
- [Mongo 驱动使用手册]
- 本书使用 GitBook 发布
通过findAndModify进行线性化读取
通过findAndModify可线性读取
概述
从复制集读取数据时,可能会读取过时(即可能并不能反映所有写道,发生前读操作)或不持久(即数据可能反映了写的状态还没有得到多数或复制集成员因此可以回滚)的数据,这取决于所使用的读取关注点。
从3.4版本开始,MongoDB引入了可线性化的读关注点,它返回的是持久的数据,不会过时。可线性化的读关注保证仅适用于读操作指定了唯一标识单个文档的查询筛选器。
本教程概述了一个替代过程,对于使用MongoDB 3.2的部署,该过程使用db.collection.findAndModify()
来读取不过时且不能回滚的数据。对于MongoDB 3.4,尽管可以应用概述的过程,但请参阅“线性化”)阅读问题。
可线性通过findAndModify读取
此过程用于db.collection.findAndModify()
读取不过期且无法回滚的数据。为此,该过程使用findAndModify()
具有写关注的方法来修改文档中的伪字段。具体来说,该过程要求:
db.collection.findAndModify()
使用完全匹配查询,并且必须存在唯一索引 才能满足该查询。findAndModify()
必须实际修改文档;即导致文档更改。findAndModify()
必须使用写关注 。{ w: "majority" }
[warning] 重要
“仲裁读取”过程比单纯使用读取问题要花费大量成本,
"majority"
因为它会导致写入延迟而不是读取延迟。仅在绝对不过期的情况下才应使用此技术。
前提条件
本教程从名为products的集合中读取内容。使用以下操作初始化集合。
db.products.insert( [
{
_id: 1,
sku: "xyz123",
description: "hats",
available: [ { quantity: 25, size: "S" }, { quantity: 50, size: "M" } ],
_dummy_field: 0
},
{
_id: 2,
sku: "abc123",
description: "socks",
available: [ { quantity: 10, size: "L" } ],
_dummy_field: 0
},
{
_id: 3,
sku: "ijk123",
description: "t-shirts",
available: [ { quantity: 30, size: "M" }, { quantity: 5, size: "L" } ],
_dummy_field: 0
}
] )
该集合中的文档包含一个虚拟字段_dummy_field
,该字段 db.collection.findAndModify()
在本教程中将通过递增 。如果该字段不存在,则该db.collection.findAndModify()
操作会将字段添加到文档中。该字段的目的是确保db.collection.findAndModify()
对文档进行修改。
程序
1.创建一个唯一索引。
在将用于指定db.collection.findAndModify()
操作中完全匹配的字段上创建唯一索引。
本教程将在sku
现场使用完全匹配。这样,在sku
字段上创建唯一索引。
db.products.createIndex( { sku: 1 }, { unique: true } )
2.使用findAndModify
读取提交的数据。
使用该db.collection.findAndModify()
方法对要阅读的文档进行简单更新,然后返回修改后的文档。需要写关注。要指定要阅读的文档,必须使用唯一索引支持的完全匹配查询。{ w: "majority" }
下面的findAndModify()
操作在唯一索引的字段sku
上指定精确匹配,并增加匹配文档中名为_dummy_field
的字段。虽然不是必需的,但该命令的写操作还包括一个5000毫秒的wtimeout
值,以防止在写操作不能传播到大多数投票成员时永远阻塞操作。
var updatedDocument = db.products.findAndModify(
{
query: { sku: "abc123" },
update: { $inc: { _dummy_field: 1 } },
new: true,
writeConcern: { w: "majority", wtimeout: 5000 }
}
);
即使在副本集中的两个节点认为它们是主节点的情况下,也只有一个节点能够用w: "majority"
.完成写操作。因此,只有当客户机连接到真正的主服务器来执行操作时,具有“多数”写关注点的findAndModify()
方法才会成功。
由于仲裁读取过程只会增加文档中的虚拟字段,因此您可以安全地重复调用 findAndModify()
,根据需要调整 wtimeout。
译者:杨帅
校对:杨帅
Copyright © 上海锦木信息技术有限公司 all right reserved,由 MongoDB汉化小组 提供技术支持文件修订时间: 2020-10-11 20:53:05