未加星标

MongoDB中游标的深入学习

字体大小 | |
[数据库(综合) 所属分类 数据库(综合) | 发布者 店小二05 | 时间 | 作者 红领巾 ] 0人收藏点击收藏

前言

MongoDB中的游标与关系型数据库中的游标在功能上大同小异。游标相当于C语言的指针,可以定位到某条记录,在MongoDB中,则是文档。因此在mongoDB中游标也有定义,声明, 打开,读取,关闭这么个过程。客户端通过游标,能够实现对最终结果进行有效的控制,诸如限制结果数量,跳过部分结果或根据任意键按任意顺序的组合对结果进行各种排序等。

通俗的说,游标不是查询结果,可以理解为数据在遍历过程中的内部指针,其返回的是一个资源,或者说数据读取接口.
客户端通过对游标进行一些设置就能对查询结果进行有效地控制,如可以限制查询得到的结果数量、跳过部分结果、或对结果集按任意键进行排序等!

直接对一个集合调用find()方法时,我们会发现,如果查询结果超过二十条,只会返回二十条的结果,这是因为Mongodb会自动递归find() 返回的游标。

下文是针对MongoDB游标的具体介绍。

一、mongoDB游标介绍

db.collection.find()方法返回一个游标,对于文档的访问,我们需要进行游标迭代
mongoDB的游标与关系型数据库SQL中的游标类似,可以通过对游标进行(如限制查询结果数,跳过的结果数等)设置来控制查询结果
游标会消耗内存和相关系统资源,游标使用完后应尽快释放资源
在mongo shell中,如果返回的游标结果集未指定给某个var定义的变量,则,游标自动迭代20次,即输出前20个文档,超出20的情形则需要输入it来翻页

本文内容描述手动方式来实现游标迭代来访问文档或者是用索引迭代

    声明游标

           var cursor =  db.collectioName.find(query,projection);

    打开游标

            Cursor.hasNext() 判断游标是否已经取到尽头

    读取数据

            Cursor.Next()    取出游标的下一个文档

    关闭游标

            cursor.close()   此步骤可省略,通常为自动关闭,也可以显示关闭

用while循环来遍历游标示例

var mycursor = db.bar.find({_id:{$lte:5}})
while(mycursor.hasNext()) {
printjson(mycursor.next());
}
    游标生命周期
            a、游标完成匹配结果的迭代后,它会清除自身;
            b、客户端的游标已经不在作用域内,驱动程序回向服务器发送一条特别的消息,让其销毁;
            c、缺省情况下,游标在十分钟内没有使用,游标自动关闭或者客户端已经迭代完整个游标;
            d、可以通过cursor.noCursorTimeout()来定义游标超时时间

                    如:var myCursor = db.users.find().noCursorTimeout() 

           e、对于自定义超时时长的游标可以使用cursor.close() 来关闭游标
                    如:db.collection.find(<query>).close()

二、当前环境及数据准备

repSetTest:PRIMARY> db.version()
3.0.12
//创建包含29个文档的集合user
repSetTest:PRIMARY> for (var i=1;i<30;i++){
... db.user.insert({"id":i,"ename":"usr"+i});
... }
WriteResult({ "nInserted" : 1 })
repSetTest:PRIMARY> db.user.count()
29
//查询集合user上所有文档
repSetTest:PRIMARY> db.user.find()
{ "_id" : ObjectId("5804d07fd974b32430ea9748"), "id" : 1, "ename" : "usr1" }
{ "_id" : ObjectId("5804d07fd974b32430ea9749"), "id" : 2, "ename" : "usr2" }
.............................
{ "_id" : ObjectId("5804d07fd974b32430ea975b"), "id" : 20, "ename" : "usr20" }
Type "it" for more //上面的结果只输出了20行,这个提示表明查看更多应输入it
repSetTest:PRIMARY> it
{ "_id" : ObjectId("5804d07fd974b32430ea975c"), "id" : 21, "ename" : "usr21" }
..............
{ "_id" : ObjectId("5804d07fd974b32430ea9764"), "id" : 29, "ename" : "usr29" }

二、使用print输出游标结果集

repSetTest:PRIMARY> var myCursor = db.user.find()
while (myCursor.hasNext()) {
print(tojson(myCursor.next()))
}
{ "_id" : ObjectId("5804d07fd974b32430ea9748"), "id" : 1, "ename" : "usr1" }
..........
{
"_id" : ObjectId("5804d07fd974b32430ea9751"),
"id" : 10,
"ename" : "usr10"
}
................
{
"_id" : ObjectId("5804d07fd974b32430ea9764"),
"id" : 29,
"ename" : "usr29"
}
//上述查询中通过var myCursor进行变量的定义,相当于SQL中的declare cursor cur_name is select ..
//变量 myCursor定义仅仅是定义,并不会访问数据库,而是在myCursor.hasNext()真正访问数据库
//myCursor.next()则是输出下一条记录,hasNext()访问数据库时会根据缺省游标设定将结果读取到本地

三、使用printjsont输出游标结果集

repSetTest:PRIMARY> var myCursor = db.user.find({id:{$gt:20}})
while (myCursor.hasNext()) {
printjson(myCursor.next());}
{
"_id" : ObjectId("5804d07fd974b32430ea975c"),
"id" : 21,
"ename" : "usr21"
}
.......
{
"_id" : ObjectId("5804d07fd974b32430ea9764"),
"id" : 29,
"ename" : "usr29"
}

四、使用 forEach()进行迭代

repSetTest:PRIMARY> var myCursor = db.user.find({id:{$gt:20}})
repSetTest:PRIMARY> myCursor.forEach(printjson);
{
"_id" : ObjectId("5804d07fd974b32430ea975c"),
"id" : 21,
"ename" : "usr21"
}
................
{
"_id" : ObjectId("5804d07fd974b32430ea9764"),
"id" : 29,
"ename" : "usr29"
}

五、基于数组索引迭代

    可以使用toArray()将游标迭代文档返回到一个数组,然后通过数组下标方式进行访问。
    该方法将所有由游标返回的文档装载进内存。
//如下示例,将游标返回的内容传递到数组,然后使用 printjson (documentArray[3])输出其中的元素
repSetTest:PRIMARY> var myCursor = db.user.find({id:{$gt:20}})
repSetTest:PRIMARY> var documentArray = myCursor.toArray();
repSetTest:PRIMARY> printjson (documentArray[3])
{
"_id" : ObjectId("580d775edeb57e4d05eec0f2"),
"id" : 24, //Author : Leshami
"ename" : "usr24" //Blog : http://blog.csdn.net/leshami
}
//也可以将数组元素输出到某个变量,然后在用printjson(myDocument)输出这个变量,如下
repSetTest:PRIMARY> var myDocument = documentArray[3];
repSetTest:PRIMARY> printjson(myDocument)
{
"_id" : ObjectId("580d775edeb57e4d05eec0f2"),
"id" : 24,
"ename" : "usr24"
}

六、调整游标迭代次数

//设置迭代显示的次数,如下设置为5
repSetTest:PRIMARY> DBQuery.shellBatchSize = 5
5
repSetTest:PRIMARY> db.user.find()
{ "_id" : ObjectId("5804d07fd974b32430ea9748"), "id" : 1, "ename" : "usr1" }
{ "_id" : ObjectId("5804d07fd974b32430ea9749"), "id" : 2, "ename" : "usr2" }
{ "_id" : ObjectId("5804d07fd974b32430ea974a"), "id" : 3, "ename" : "usr3" }
{ "_id" : ObjectId("5804d07fd974b32430ea974b"), "id" : 4, "ename" : "usr4" }
{ "_id" : ObjectId("5804d07fd974b32430ea974c"), "id" : 5, "ename" : "usr5" }
Type "it" for more //从上面的查询结果可知,当输出5个文档就提示需要输入it来查看更多
repSetTest:PRIMARY> it
{ "_id" : ObjectId("5804d07fd974b32430ea974d"), "id" : 6, "ename" : "usr6" }
{ "_id" : ObjectId("5804d07fd974b32430ea974e"), "id" : 7, "ename" : "usr7" }
{ "_id" : ObjectId("5804d07fd974b32430ea974f"), "id" : 8, "ename" : "usr8" }
{ "_id" : ObjectId("5804d07fd974b32430ea9750"), "id" : 9, "ename" : "usr9" }
{ "_id" : ObjectId("5804d07fd974b32430ea9751"), "id" : 10, "ename" : "usr10" }
Type "it" for more

七、查看游标度量信息

可以通过db.serverStatus()查看游标状态相关的信息,这些信息通常包括
从服务器上次启动之后游标超时的数量
自定义游标超时的数量
游标打开后已经pinned的数量
打开游标的总数目

//如下查询本机游标的信息
repSetTest:PRIMARY> db.serverStatus().metrics.cursor
{
"timedOut" : NumberLong(2),
"open" : {
"noTimeout" : NumberLong(0),
"pinned" : NumberLong(0),
"total" : NumberLong(2)
}
}

总结

以上就是关于MongoDB游标的全部内容了,希望本文的内容对大家学习或者使用MongoDB的时候能带来一定的帮助,如果有疑问大家可以留言交流。

本文数据库(综合)相关术语:系统安全软件

主题: MongoDBRIMRYSQL服务器数据C语言数据库变量上大
分页:12
转载请注明
本文标题:MongoDB中游标的深入学习
本站链接:http://www.codesec.net/view/523576.html
分享请点击:


1.凡CodeSecTeam转载的文章,均出自其它媒体或其他官网介绍,目的在于传递更多的信息,并不代表本站赞同其观点和其真实性负责;
2.转载的文章仅代表原创作者观点,与本站无关。其原创性以及文中陈述文字和内容未经本站证实,本站对该文以及其中全部或者部分内容、文字的真实性、完整性、及时性,不作出任何保证或承若;
3.如本站转载稿涉及版权等问题,请作者及时联系本站,我们会及时处理。
登录后可拥有收藏文章、关注作者等权限...
技术大类 技术大类 | 数据库(综合) | 评论(0) | 阅读(49)