c#開發Mongo筆記第九篇
用skip略過少量的文檔還是不錯的。但是要是數量非常多的話,skip就會變得很慢,因為要先找到需要被略過的數據,然後再拋棄這些數據。大多數數據庫都會在索引中保存更多的元數據,用於處理skip,
但是mongoDB目前還不支持,所以要盡量避免略過太多的數據 。通常可以利用上次的結果來計算下一次的查詢條件。
最簡單的分頁方法就是用limit返回結果的第一頁,然後將每個後續頁面作為相對開始的偏移量返回。
比如var page1=db.Log.find(query).skip(100).limit(100)
然而,一般來講可以找到一種不使用skip的情況下實現分頁,這取決於查詢的本身。例如。要按照時間降序顯示文檔列表。可以用如下方式獲取結果的第一頁
var page1=db.Log.find().sort({"createtime":-1}).limit(100)
然後可以利用最後一個文檔中的createTime的值最為查詢條件,來獲取下一頁
var lasttime=null;
while(page1.hasnext()){
lasttime=page1.next();
}
var page2=db.Log.find({"createtime":{"$gt":createtime.createtime});
page2.sort({"createtime":-1}).limit(100);
那麼在c#中我覺得大概應該就是這麼實現,當然了這只是個演示,肯定是不能在這個函數中查詢上次的結果的,不然又再次查詢了,直接把上次查詢結果傳過來就好‘
復制代碼
public static List<Log> GetList(IMongoQuery query, int pagesize, int pagenum)
{
MongoDatabase db = MongoHelperFactory.GetDataBase();
MongoCollection collection = db.GetCollection<Log>("Log");
if (pagenum==0)
{
return collection.FindAs<Log>(query).OrderByDescending(l => l.CreateTime).Take(pagesize).ToList();
}
else
{
DateTime lastTime = collection.FindAs<Log>(query).OrderByDescending(l => l.CreateTime).Take(pagesize * pagenum).Min(l => l.CreateTime);
return collection.FindAs<Log>(query).Where(l => l.CreateTime < lastTime).OrderByDescending(l => l.CreateTime).Take(pagesize).ToList();
}
}
復制代碼
調用方法是這樣的
復制代碼
int SkipNum = Convert.ToInt32(Request.Form["page"]) - 1;
int TakeNum = Convert.ToInt32(Request.Form["rows"]);
string searchstr = "";// Request.QueryString["condition"];
IMongoQuery query = null;
if (Request.QueryString["condition"] != null)
{
searchstr = Request.QueryString["condition"];
query = Query<Log>.Matches(c => c.Description, new BsonRegularExpression(new Regex(searchstr)));
}
// List<Log> list = DAL.DALLog.GetList(query).OrderByDescending(l => l.CreateTime).ToList() ;
// return Content("{\"total\":\""+list.Count()+"\",\"rows\":"+ users.Take(TakeNum).Skip(TakeNum*SkipNum).ToJson().ToString()+"}");
StringBuilder sb = new StringBuilder();
sb.Append("{\"total\":\"" + DAL.DALLog.GetCount(query) + "\",\"rows\":[");
List<Log> list = DAL.DALLog.GetList(query, TakeNum, SkipNum);