首页 > 代码库 > c#开发Mongo笔记第九篇

c#开发Mongo笔记第九篇

2024-08-01 20:33:26   216人阅读

用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);

 

c#开发Mongo笔记第九篇


联系
我们