游標相當于C語言的指針，可以定位到某條記錄，在MongoDB中，則是文檔。因此在mongoDB中游標也有定義，聲明， 打開，讀取，關(guān)閉這么個過程。客戶端通過游標，能夠?qū)崿F(xiàn)對最終結(jié)果進行有效的控制，諸如限制結(jié)果數(shù)量，跳過部分結(jié)果或根據(jù)任意鍵按任意順序的組合對結(jié)果進行各種排序等。

       一、mongoDB游標介紹

  db.collection.find()方法返回一個游標，對于文檔的訪問，我們需要進行游標迭代

  mongoDB的游標與關(guān)系型數(shù)據(jù)庫SQL中的游標類似，可以通過對游標進行(如限制查詢結(jié)果數(shù)，跳過的結(jié)果數(shù)等)設置來控制查詢結(jié)果

  游標會消耗內(nèi)存和相關(guān)系統(tǒng)資源，游標使用完后應盡快釋放資源

  在mongo shell中，如果返回的游標結(jié)果集未指定給某個var定義的變量，則，游標自動迭代20次，即輸出前20個文檔，超出20的情形則需要輸入it來翻頁

  本文內(nèi)容描述手動方式來實現(xiàn)游標迭代來訪問文檔或者是用索引迭代

  聲明游標

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

  打開游標

      Cursor.hasNext() 判斷游標是否已經(jīng)取到盡頭

  讀取數(shù)據(jù)

      Cursor.Next()  取出游標的下一個文檔

  關(guān)閉游標

      cursor.close()  此步驟可省略，通常為自動關(guān)閉，也可以顯示關(guān)閉

  用while循環(huán)來遍歷游標示例

      var mycursor = db.bar.find({_id:{$lte:5}})

      while(mycursor.hasNext()) {

          printjson(mycursor.next());

          }

  游標生命周期

      a、游標完成匹配結(jié)果的迭代后，它會清除自身；

      b、客戶端的游標已經(jīng)不在作用域內(nèi)，驅(qū)動程序回向服務器發(fā)送一條特別的消息，讓其銷毀；

      c、缺省情況下，游標在十分鐘內(nèi)沒有使用，游標自動關(guān)閉或者客戶端已經(jīng)迭代完整個游標；

      d、可以通過cursor.noCursorTimeout()來定義游標超時時間

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

      e、對于自定義超時時長的游標可以使用cursor.close() 來關(guān)閉游標

          如：db.collection.find(<query>).close()

       二、當前環(huán)境及數(shù)據(jù)準備

 repSetTest:PRIMARY> db.version()

  3.0.12

  //創(chuàng)建包含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  //上面的結(jié)果只輸出了20行，這個提示表明查看更多應輸入it

  repSetTest:PRIMARY> it

  { "_id" : ObjectId("5804d07fd974b32430ea975c"), "id" : 21, "ename" : "usr21" }

   ..............

  { "_id" : ObjectId("5804d07fd974b32430ea9764"), "id" : 29, "ename" : "usr29" }

       三、使用print輸出游標結(jié)果集

 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定義僅僅是定義，并不會訪問數(shù)據(jù)庫，而是在myCursor.hasNext()真正訪問數(shù)據(jù)庫

  //myCursor.next()則是輸出下一條記錄，hasNext()訪問數(shù)據(jù)庫時會根據(jù)缺省游標設定將結(jié)果讀取到本地

       四、使用printjsont輸出游標結(jié)果集

  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"

  }

       六、基于數(shù)組索引迭代

       可以使用toArray()將游標迭代文檔返回到一個數(shù)組，然后通過數(shù)組下標方式進行訪問。

       該方法將所有由游標返回的文檔裝載進內(nèi)存。

 //如下示例，將游標返回的內(nèi)容傳遞到數(shù)組，然后使用 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

  }

  //也可以將數(shù)組元素輸出到某個變量，然后在用printjson(myDocument)輸出這個變量，如下

  repSetTest:PRIMARY> var myDocument = documentArray[3];

  repSetTest:PRIMARY> printjson(myDocument)

  {

      "_id" : ObjectId("580d775edeb57e4d05eec0f2"),

      "id" : 24,

      "ename" : "usr24"

  }

       七、調(diào)整游標迭代次數(shù)

 //設置迭代顯示的次數(shù)，如下設置為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 //從上面的查詢結(jié)果可知，當輸出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()查看游標狀態(tài)相關(guān)的信息，這些信息通常包括

      從服務器上次啟動之后游標超時的數(shù)量

      自定義游標超時的數(shù)量

      游標打開后已經(jīng)pinned的數(shù)量

      打開游標的總數(shù)目

  //如下查詢本機游標的信息    

  repSetTest:PRIMARY> db.serverStatus().metrics.cursor

  {

      "timedOut" : NumberLong(2),

      "open" : {

          "noTimeout" : NumberLong(0),

          "pinned" : NumberLong(0),

          "total" : NumberLong(2)

      }

  }