MongoDB的官方驱动，语法更好，更强
之前写过关于IMongoRepository仓储的文章，在mongodb的驱动选择上使用了NoRM，但是进行$ref引用类型导航时出现了问题，它对引用类型属性支持不是很好，还是使用几年前的泛型技术而没有使用Attribute，在这个方面官方驱动做的更好，所以，我还是使用官方驱动又实现了一次IMongoRepository，把一些实现的细节封装在了底层，我们叫这个官方仓储为MongoOfficialRepository，呵呵，谁叫你来的晚呢，MongoRepository已经为NoRM占上了，呵呵。
新的IMongoRepository接口内容添加了４个方法
/// <summary> /// 官方驱动，返回带分页的结果集 /// </summary> /// <param name="pageIndex"></param> /// <param name="pageSize"></param> /// <returns></returns> PagedResult<TEntity> GetModel(int pageIndex, int pageSize); /// <summary> /// 官方驱动，返回带条件和分页的结果集 /// </summary> /// <param name="expression"></param> /// <param name="pageIndex"></param> /// <param name="pageSize"></param> /// <returns></returns> PagedResult<TEntity> GetModel(Expression<Func<TEntity, bool>> expression, int pageIndex, int pageSize); /// <summary> /// 官方驱动，返回带排序和分页的结果集 /// </summary> /// <param name="fields"></param> /// <param name="pageIndex"></param> /// <param name="pageSize"></param> /// <returns></returns> PagedResult<TEntity> GetModel(Dictionary<Expression<Func<TEntity, object>>, bool> fields, int pageIndex, int pageSize); /// <summary> /// 官方驱动，返回带条件和排序及分页的结果集 /// </summary> /// <param name="expression"></param> /// <param name="fields"></param> /// <param name="pageIndex"></param> /// <param name="pageSize"></param> /// <returns></returns> PagedResult<TEntity> GetModel(Expression<Func<TEntity, bool>> expression, Dictionary<Expression<Func<TEntity, object>>, bool> fields, int pageIndex, int pageSize);
对这四大方法的实现，为了不让MongoDB的更多细节公开，所以，更多的内核只能在仓储中实现了，呵呵
public PagedResult<TEntity> GetModel(int pageIndex, int pageSize) { return GetModel(i => true, pageIndex, pageSize); } public PagedResult<TEntity> GetModel(Expression<Func<TEntity, bool>> expression, int pageIndex, int pageSize) { return GetModel(expression, new Dictionary<Expression<Func<TEntity, object>>, bool>(), pageIndex, pageSize); } public PagedResult<TEntity> GetModel( Dictionary<Expression<Func<TEntity, object>>, bool> fields, int pageIndex, int pageSize) { return GetModel(i => true, fields, pageIndex, pageSize); } public PagedResult<TEntity> GetModel( Expression<Func<TEntity, bool>> expression, Dictionary<Expression<Func<TEntity, object>>, bool> fields, int pageIndex, int pageSize) { SortDefinition<TEntity> sorts = new ObjectSortDefinition<TEntity>(new { }); foreach (var item in fields) { if (item.Value) sorts = sorts.Ascending(item.Key); else sorts = sorts.Descending(item.Key); } var skip = (pageIndex - 1) * pageSize; var limit = pageSize; var recordCount = _table.CountAsync<TEntity>(i => true).Result; return new PagedResult<TEntity>( recordCount, (int)(recordCount + pageSize - 1) / pageSize, pageSize, pageIndex, _table.Find(expression) .Sort(sorts) .Skip(skip) .Limit(limit) .ToListAsync().Result); }
ＯＫ，现在你可以在业务层去调用它了，基本上面四个方法可以满足你的一切需求了，呵呵！
看下在ＵＩ层对它的调用，本ＤＥＭＯ没有ＢＬＬ层，呵呵
public ActionResult Index(int? loginNameSort, int? realNameSort, int page = 1) { Dictionary<Expression<Func<WebManageUsers, object>>, bool> sortList =
new System.Collections.Generic.Dictionary<Expression<Func<WebManageUsers, object>>, bool>(); if (loginNameSort.HasValue) sortList.Add(i => i.LoginName, loginNameSort.Value == 0); if (realNameSort.HasValue) sortList.Add(i => i.RealName, realNameSort.Value == 0); var model = _webManageUsersRepository.GetModel(sortList, page, 10); return View(model); }
怎么样，看了上面代码是否心里痒痒了，哈哈，赶快去开发你自己的MongoDB仓储吧！
本文转自博客园张占岭（仓储大叔）的博客，原文链接：MongoDB学习笔记~为IMongoRepository接口添加了排序和表达式树，针对官方驱动，如需转载请自行联系原博主。
