【mongoDB中級篇①】游標(biāo)cursor

AZmake 發(fā)布于2019-06-26 16:58 / 3395人閱讀

摘要：在這里我們就可以使用，，三個(gè)函數(shù)來處理游標(biāo)。同時(shí)這三個(gè)函數(shù)可以組成方法鏈?zhǔn)秸{(diào)用的形式。

簡述

通俗的說,游標(biāo)不是查詢結(jié)果,可以理解為數(shù)據(jù)在遍歷過程中的內(nèi)部指針,其返回的是一個(gè)資源,或者說數(shù)據(jù)讀取接口.
客戶端通過對游標(biāo)進(jìn)行一些設(shè)置就能對查詢結(jié)果進(jìn)行有效地控制，如可以限制查詢得到的結(jié)果數(shù)量、跳過部分結(jié)果、或?qū)Y(jié)果集按任意鍵進(jìn)行排序等！
直接對一個(gè)集合調(diào)用find()方法時(shí)，我們會發(fā)現(xiàn)，如果查詢結(jié)果超過二十條，只會返回二十條的結(jié)果，這是因?yàn)镸ongodb會自動(dòng)遞歸find() 返回的游標(biāo)。

基本操作

當(dāng)我們使用一個(gè)變量來保存 find()的返回值時(shí)，其將不會自動(dòng)進(jìn)行遍歷顯示查詢結(jié)果的操作,并沒有真正的去查詢數(shù)據(jù)庫，只要當(dāng)用到的時(shí)候（也就是遍歷游標(biāo)的時(shí)候）才會到數(shù)據(jù)庫中將數(shù)據(jù)取出來,和PHP鏈接mysql資源一樣:

php代碼

$result = mysql_query("select * from message"); //返回的是一個(gè)資源

$row=mysql_fetch_assoc($result);//返回sql查詢的數(shù)組(僅為滿足條件的第一條),其內(nèi)部就有一個(gè)指針游標(biāo),可以通過循環(huán)反復(fù)的取出數(shù)據(jù)

while($f=mysql_fetch_assoc($result)){//每循環(huán)一次游標(biāo)就前進(jìn)一次,游標(biāo)走到尾的時(shí)候,就不返回值了
  $row[]=$f; 
}
var_dump($row);

mongoDB代碼(js)

// while循環(huán)
var cursor = db.goods.find({goods_id:{$lte:20}},{_id:0,goods_id:1}); //使用變量來保存游標(biāo)
while(cursor.hasNext()){ //cursor.hasNext()判斷游標(biāo)是否取到盡頭
  printjson(cursor.next()); //cursor.next()取出游標(biāo)的下1個(gè)單元(從0開始游),注意print打印的是二進(jìn)制對象,printjson打印出來的才是可閱讀的json格式數(shù)據(jù)
}

// for循環(huán)
var cursor = db.goods.find({goods_id:{$lte:100}},{_id:0,goods_id:1}); //使用變量來保存游標(biāo)
for (;cursor.hasNext();) { //由于cursor.hasNext()自動(dòng)判斷的特性這里的for循環(huán)可以很簡單
  printjson(cursor.next());
}

//forEach循環(huán)
var cursor = db.goods.find({goods_id:{$lte:100}},{_id:0,goods_id:1,goods_name:1}); 
var callback = function(obj){ //obj就是查出的文檔對象
  printjson(obj.goods_id) //直接取出goods_id的值;
}
cursor.forEach(callback);

游標(biāo)在分頁中的應(yīng)用 limit，skip，sort

比如查到10000行,跳過100頁,取10行.一般地,我們假設(shè)每頁N行, 當(dāng)前是page頁,就需要跳過前 (page-1)*N 行, 再取N行, 在mysql中, limit offset,N來實(shí)現(xiàn)

在mongo中,用skip(), limit()函數(shù)來實(shí)現(xiàn)的,當(dāng)獲得游標(biāo)后，我們可以先對游標(biāo)進(jìn)行處理后，再讓訪問數(shù)據(jù)庫的動(dòng)作按照我們的意愿發(fā)生。在這里我們就可以使用limit，skip，sort三個(gè)函數(shù)來處理游標(biāo)。同時(shí)這三個(gè)函數(shù)可以組成方法鏈?zhǔn)秸{(diào)用的形式。

limit：限制游標(biāo)返回的數(shù)量，指定了上限
skip：忽略前面的部分文檔，如果文檔總數(shù)量小于忽略的數(shù)量，則返回空集合
sort：得到的子集合進(jìn)行排序，可以按照多個(gè)鍵進(jìn)行正反排序！

# 查詢5條
> var cursor = db.goods.find({},{_id:0,goods_id:1}).limit(5); //注意,再次使用游標(biāo)的時(shí)候,游標(biāo)得重置,因?yàn)槭褂眠^一次就游到最后了;
> cursor.forEach(function(obj){print(obj.goods_id);})

# 查詢5條,并按照shop_price的降序排列
> var cursor = db.goods.find({},{_id:0,goods_id:1,shop_price:1}).limit(5).sort({shop_price:-1})
> cursor.forEach(function(obj){
    print(obj.goods_id+" "+obj.shop_price)
  })
22 5999
23 3700
32 3010
18 2878
14 2625

# 每頁10條取第二頁,并且升序排列
var cursor = db.goods.find({},{_id:0,goods_id:1,shop_price:1}).limit(10).sort({goods_id:1}).skip(10)
cursor.forEach(function(obj){
  print(obj.goods_id+" "+obj.shop_price)
})

# 一次性打印所有的行,以易讀的模式
var cursor = db.goods.find({},{_id:0,goods_id:1,shop_price:1});
printjson(cursor.toArray());

/*
注意: 不要隨意使用toArray()
原因: 會把所有的行立即以對象形式組織在內(nèi)存里.可以在取出少數(shù)幾行時(shí),用此功能.
*/