.NET存储库模式通用查询方法论

本文关键字：查询 方法论 模式 存储 NET | 更新日期: 2023-09-27 17:59:27

我使用的是Repository模式，我有一个基本存储库，我使用实体框架和web api；我的问题是，我想让我的客户能够动态查询任何数据；类似于Dynamics CRM中使用的查询表达式和fetch xml；我尝试了规范模式，但这还不够，因为我想允许客户端代码订购不同列的数据，例如名称asc地址desc，还允许对返回的结果进行分页；所以我的方法要求是

  1. 不依赖ORM技术的通用筛选器未来更改实体框架
  2. 通用排序方法；允许多个排序列，例如。名称asc地址desc
  3. 客户端确定返回的列或所有列，例如。columnSet设置为"Address，Name and Id"或返回整个记录
  4. 允许分页，例如页面索引和页面大小
  5. 支持将返回的记录数设为大的阈值结果可能会影响性能

这是我最初的方法，但我不知道是否更好

IList<TEntity> AllMatching(ISpecification<TEntity> specification = null,
                Func<IQueryable<TEntity>, IOrderedQueryable<TEntity>> orderBy = null,
                IList<Expression<Func<TEntity, object>>> includes = null,
                int? pageIndex = null, int? pageCount = null);

.NET存储库模式通用查询方法论

您可以开始执行以下操作：

 public IQueryable<TEntity> Select(
 Expression<Func<TEntity, bool>> filter = null,
 Func<IQueryable<TEntity>, IOrderedQueryable<TEntity>> orderBy = null,
 IList<Expression<Func<TEntity, object>>> includes = null,
 int? page = null,
 int? pageSize = null)
 {
        IQueryable<TEntity> query = _dbSet;
        if (includes != null)
        {
            query = includes.Aggregate(query, (current, include) => current.Include(include));
        }
        if (orderBy != null)
        {
            query = orderBy(query);
        }
        if (filter != null)
        {
            query = query.AsExpandable().Where(filter);
        }
        if (page != null && pageSize != null)
        {
            query = query.Skip((page.Value - 1)*pageSize.Value).Take(pageSize.Value);
        }
        return query;
 }

正如您所看到的，它几乎可以满足您的所有需求，因此，如果您想在Repository实现中执行同样的操作，则必须使用LinqKit nuget包。

如果你想选择特定的列，你可以创建另一种方法，如下所示：

IEnumerable<TResult> AllMatching<TResult>(
Expression<Func<TEntity, TResult>> columns,
Expression<Func<TEntity, bool>> filter = null,
Func<IQueryable<TEntity>, IOrderedQueryable<TEntity>> orderBy = null,
IList<Expression<Func<TEntity, object>>> includes = null,
int? pageIndex = null,
int? pageCount = null)
{
  var query=Select(filter,orderby,includes,page,pageSize);
  return  query.Select(columns);
}
相关文章：