- 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 发布
在mongo Shell中迭代游标
在mongo Shell中迭代游标
在本页面
方法返回一个游标。 要访问文档,您需要迭代游标。 但是,在mongo shell中,如果未使用var关键字将返回的游标分配给变量,则该游标将自动迭代多达20次,以打印结果中的前20个文档。
以下示例描述了手动迭代游标以访问文档或使用迭代器索引的方法。
手动迭代游标
在mongo
shell中,当使用var关键字将find()
方法返回的游标分配给变量时,游标不会自动进行迭代。
您可以在shell程序中调用cursor变量以进行多达20次迭代并打印匹配的文档,如以下示例所示:
var myCursor = db.users.find( { type: 2 } );
myCursor
您还可以使用游标方法next()
来访问文档,如以下示例所示:
var myCursor = db.users.find( { type: 2 } );
while (myCursor.hasNext())
printjson(myCursor.next());
}
作为一种替代的打印操作,请考虑使用printjson()
辅助方法替换print(tojson())
:
var myCursor = db.users.find( { type: 2 } );
while (myCursor.hasNext()) {
printjson(myCursor.next());
}
您可以使用游标方法forEach()
来迭代游标并访问文档,如下例所示:
var myCursor = db.users.find( { type: 2 } );
myCursor.forEach(printjson);
有关游标方法的更多信息,请参阅JavaScript游标方法和 driver程序文档。
迭代器索引
在 mongo
shell中,可以使用 toArray()
方法来迭代游标并以数组形式返回文档,如下所示:
var myCursor = db.inventory.find( { type: 2 } );
var documentArray = myCursor.toArray();
var myDocument = documentArray[3];
toArray()
方法将游标返回的所有文档加载到RAM中; toArray()
方法耗尽游标。
另外,某些驱动程序通过使用游标上的索引(即cursor [index])来提供对文档的访问。 这是先调用toArray()
方法,然后在结果数组上使用索引的快捷方式。
考虑以下示例:
var myCursor = db.users.find( { type: 2 } );
var myDocument = myCursor[1];
myCursor [1]等效于以下示例:
myCursor.toArray() [1];
游标行为
关闭非活动游标
默认情况下,服务器将在闲置10分钟后或客户端用尽光标后自动关闭游标。 要在mongo shell中覆盖此行为,可以使用cursor.noCursorTimeout()
方法:
var myCursor = db.users.find().noCursorTimeout();
设置noCursorTimeout选项后,您必须使用cursor.close()
手动关闭游标,或者用尽游标的结果。
有关设置noCursorTimeout选项的信息,请参见驱动程序文档。
游标隔离
当游标返回文档时,其他操作可能会与查询交错。
光标批次
MongoDB服务器批量返回查询结果。批处理中的数据量不会超过最大BSON文档大小。若要覆盖批处理的默认大小,请参见batchSize()
和 limit()
.
3.4版中的新增功能:find()
, aggregate()
, listIndexes
, 和 listCollections
类型的操作每批返回最多16 MB。 batchSize()
可以强制使用较小的限制,但不能强制使用较大的限制。
默认情况下,find()
和aggregate()
操作的初始批处理大小为101个文档。随后针对结果游标发出的getMore
操作没有默认的批处理大小,因此它们仅受16 MB消息大小的限制。
对于包含不带索引的排序操作的查询,服务器必须在返回任何结果之前将所有文档加载到内存中以执行排序。
当您遍历游标并到达返回批处理的末尾时,如果还有更多结果,cursor.next()
将执行getMore操作以检索下一个批处理。要查看在迭代游标时批处理中剩余多少文档,可以使用objsLeftInBatch()
方法,如以下示例所示:
var myCursor = db.inventory.find();
var myFirstDocument = myCursor.hasNext() ? myCursor.next() : null;
myCursor.objsLeftInBatch();
游标信息
db.serverStatus()
方法返回包含度量标准字段的文档。 指标字段包含一个带有以下信息的metrics.cursor
字段:
自上次服务器重新启动以来超时的游标数
设置了选项
DBQuery.Option.noTimeout
的打开游标的数量,以防止一段时间不活动后发生超时“固定”打开游标的数量
打开的游标总数
考虑以下示例,该示例调用db.serverStatus()
方法并从结果中访问索引字段,然后从指标字段访问游标字段:
db.serverStatus().metrics.cursor
结果是以下文档:
{
"timedOut" : <number>
"open" : {
"noTimeout" : <number>,
"pinned" : <number>,
"total" : <number>
}
}
另可参考:
译者:杨帅
校对:杨帅
Copyright © 上海锦木信息技术有限公司 all right reserved,由 MongoDB汉化小组 提供技术支持文件修订时间: 2020-10-11 20:53:05