92

我一直在寻找一个很好的解决方案来解决典型存储库模式所带来的问题(不断增长的专用查询方法列表等。请参阅:http ://ayende.com/blog/3955/repository-是新的单例)。

我真的很喜欢使用命令查询的想法,特别是通过使用规范模式。但是,我对规范的问题是它只涉及简单选择的标准(基本上是 where 子句),而不涉及查询的其他问题,例如连接、分组、子集选择或投影等。基本上,许多查询必须经过所有额外的循环才能获得正确的数据集。

(注意:我在命令模式中使用术语“命令”,也称为查询对象。我不是在谈论命令/查询分离中的命令,其中查询和命令(更新、删除、插入))

所以我正在寻找封装整个查询的替代方案,但仍然足够灵活,以至于您不只是将意大利面条存储库换成命令类的爆炸式增长。

例如,我使用过 Linqspecs,虽然我发现能够为选择标准分配有意义的名称有一些价值,但这还不够。也许我正在寻找一种结合多种方法的混合解决方案。

我正在寻找其他人可能已经开发的解决方案来解决这个问题,或者解决一个不同的问题,但仍然满足这些要求。在链接的文章中,Ayende 建议直接使用 nHibernate 上下文,但我觉得这在很大程度上使您的业务层复杂化,因为它现在还必须包含查询信息。

等待期结束后,我将为此提供赏金。因此,请让您的解决方案有价值,并提供良好的解释,我将选择最佳解决方案,并为亚军投票。

注意:我正在寻找基于 ORM 的东西。不必明确地是 EF 或 nHibernate,但这些是最常见的并且最适合。如果它可以很容易地适应其他 ORM,那将是一个奖励。Linq 兼容也不错。

更新:我真的很惊讶这里没有很多好的建议。似乎人们要么完全是 CQRS,要么完全属于 Repository 阵营。我的大多数应用程序都不够复杂,不足以保证 CQRS(大多数 CQRS 倡导者很容易说你不应该使用它)。

更新:这里似乎有点混乱。我不是在寻找新的数据访问技术,而是在业务和数据之间设计合理的接口。

理想情况下,我正在寻找的是查询对象、规范模式和存储库之间的某种交叉。正如我上面所说,规范模式只处理 where 子句方面,而不是查询的其他方面,例如连接、子选择等。存储库处理整个查询,但一段时间后就会失控. 查询对象也处理整个查询,但我不想简单地用大量查询对象替换存储库。

4

4 回答 4

100

免责声明:由于还没有任何好的答案,我决定从我不久前阅读的一篇很棒的博客文章中发布一部分,几乎逐字复制。您可以在此处找到完整的博客文章。所以这里是:


我们可以定义以下两个接口:

public interface IQuery<TResult>
{
}

public interface IQueryHandler<TQuery, TResult> where TQuery : IQuery<TResult>
{
    TResult Handle(TQuery query);
}

指定一条消息,该消息使用泛型类型IQuery<TResult>返回的数据定义特定查询。TResult使用之前定义的接口,我们可以定义如下查询消息:

public class FindUsersBySearchTextQuery : IQuery<User[]>
{
    public string SearchText { get; set; }
    public bool IncludeInactiveUsers { get; set; }
}

这个类定义了一个带有两个参数的查询操作,这将产生一个User对象数组。处理这个消息的类可以定义如下:

public class FindUsersBySearchTextQueryHandler
    : IQueryHandler<FindUsersBySearchTextQuery, User[]>
{
    private readonly NorthwindUnitOfWork db;

    public FindUsersBySearchTextQueryHandler(NorthwindUnitOfWork db)
    {
        this.db = db;
    }

    public User[] Handle(FindUsersBySearchTextQuery query)
    {
        return db.Users.Where(x => x.Name.Contains(query.SearchText)).ToArray();
    }
}

我们现在可以让消费者依赖通用IQueryHandler接口:

public class UserController : Controller
{
    IQueryHandler<FindUsersBySearchTextQuery, User[]> findUsersBySearchTextHandler;

    public UserController(
        IQueryHandler<FindUsersBySearchTextQuery, User[]> findUsersBySearchTextHandler)
    {
        this.findUsersBySearchTextHandler = findUsersBySearchTextHandler;
    }

    public View SearchUsers(string searchString)
    {
        var query = new FindUsersBySearchTextQuery
        {
            SearchText = searchString,
            IncludeInactiveUsers = false
        };

        User[] users = this.findUsersBySearchTextHandler.Handle(query);    
        return View(users);
    }
}

这个模型立即为我们提供了很大的灵活性,因为我们现在可以决定将什么注入UserController. 我们可以注入一个完全不同的实现,或者一个包装真实实现的实现,而无需更改UserController(以及该接口的所有其他消费者)。

在指定或注入我们的代码时,该IQuery<TResult>接口为我们提供了编译时支持。IQueryHandlers当我们将FindUsersBySearchTextQuery改为 return时UserInfo[](通过实现IQuery<UserInfo[]>),UserController将无法编译,因为泛型类型约束 onIQueryHandler<TQuery, TResult>将无法映射FindUsersBySearchTextQueryUser[].

然而,将IQueryHandler接口注入消费者,还有一些不太明显的问题需要解决。我们的消费者的依赖数量可能会变得太大,并且可能导致构造函数过度注入 - 当构造函数接受太多参数时。类执行的查询数量可能会经常变化,这需要不断更改构造函数参数的数量。

IQueryHandlers我们可以通过额外的抽象层来解决必须注入太多的问题。我们创建了一个位于消费者和查询处理程序之间的中介:

public interface IQueryProcessor
{
    TResult Process<TResult>(IQuery<TResult> query);
}

IQueryProcessor是一个具有一个通用方法的非通用接口。正如您在接口定义中看到的那样,IQueryProcessor取决于IQuery<TResult>接口。这使我们能够在依赖于IQueryProcessor. 让我们重写UserController以使用新的IQueryProcessor

public class UserController : Controller
{
    private IQueryProcessor queryProcessor;

    public UserController(IQueryProcessor queryProcessor)
    {
        this.queryProcessor = queryProcessor;
    }

    public View SearchUsers(string searchString)
    {
        var query = new FindUsersBySearchTextQuery
        {
            SearchText = searchString,
            IncludeInactiveUsers = false
        };

        // Note how we omit the generic type argument,
        // but still have type safety.
        User[] users = this.queryProcessor.Process(query);

        return this.View(users);
    }
}

现在UserController取决于IQueryProcessor可以处理我们所有查询的。的方法调用传入初始化查询对象UserController的方法。由于实现了接口,我们可以将它传递给泛型方法。由于 C# 类型推断,编译器能够确定泛型类型,这使我们不必显式声明类型。该方法的返回类型也是已知的。SearchUsersIQueryProcessor.ProcessFindUsersBySearchTextQueryIQuery<User[]>Execute<TResult>(IQuery<TResult> query)Process

现在是IQueryProcessor找对了落实的责任IQueryHandler。这需要一些动态类型,并且可以选择使用依赖注入框架,并且只需几行代码即可完成:

sealed class QueryProcessor : IQueryProcessor
{
    private readonly Container container;

    public QueryProcessor(Container container)
    {
        this.container = container;
    }

    [DebuggerStepThrough]
    public TResult Process<TResult>(IQuery<TResult> query)
    {
        var handlerType = typeof(IQueryHandler<,>)
            .MakeGenericType(query.GetType(), typeof(TResult));

        dynamic handler = container.GetInstance(handlerType);

        return handler.Handle((dynamic)query);
    }
}

该类根据提供的查询实例的类型QueryProcessor构造特定类型。IQueryHandler<TQuery, TResult>此类型用于要求提供的容器类获取该类型的实例。不幸的是,我们需要Handle使用反射调用该方法(在本例中使用 C# 4.0 动态关键字),因为此时无法强制转换处理程序实例,因为通用TQuery参数在编译时不可用。但是,除非Handle方法被重命名或获取其他参数,否则此调用将永远不会失败,如果您愿意,为此类编写单元测试非常容易。使用反射会略有下降,但没什么好担心的。


回答您的一个问题:

所以我正在寻找封装整个查询的替代方案,但仍然足够灵活,以至于您不只是将意大利面条存储库换成命令类的爆炸式增长。

使用这种设计的一个结果是系统中会有很多小类,但是有很多小/集中的类(具有清晰的名称)是一件好事。这种方法显然比在存储库中为同一方法使用不同参数的许多重载要好得多,因为您可以将它们分组到一个查询类中。因此,您获得的查询类仍然比存储库中的方法少得多。

于 2013-01-25T09:07:27.227 回答
4

我的处理方式实际上是简单化且与 ORM 无关。我对存储库的看法是:存储库的工作是为应用程序提供上下文所需的模型,因此应用程序只是向存储库询问它想要什么,但不告诉它如何获取它。

我为存储库方法提供了一个 Criteria(是的,DDD 样式),repo 将使用它来创建查询(或任何需要的 - 它可能是一个 web 服务请求)。恕我直言,联接和组是如何的细节,而不是什么和标准应该只是构建where子句的基础。

模型 = 应用程序需要的最终对象或数据结构。

public class MyCriteria
{
   public Guid Id {get;set;}
   public string Name {get;set;}
    //etc
 }

 public interface Repository
  {
       MyModel GetModel(Expression<Func<MyCriteria,bool>> criteria);
   }

如果需要,您可能可以直接使用 ORM 标准(Nhibernate)。存储库实现应该知道如何将 Criteria 与底层存储或 DAO 一起使用。

我不知道您的域和模型要求,但如果最好的方法是应用程序自己构建查询,那就太奇怪了。模型变化如此之大,以至于您无法定义稳定的东西?

这个解决方案显然需要一些额外的代码,但它不会将其余的代码耦合到 ORM 或您用来访问存储的任何东西。存储库的作用是充当门面,IMO 很干净,“标准翻译”代码是可重用的

于 2013-01-20T08:40:42.990 回答
2

我已经完成了这个,支持这个并撤消了这个。

主要问题是:无论你怎么做,增加的抽象都不会让你获得独立性。它会根据定义泄漏。从本质上讲,你发明了一个完整的层只是为了让你的代码看起来很可爱……但它不会减少维护、提高可读性或让你获得任何类型的模型不可知论。

有趣的是,您回答了自己的问题以回应 Olivier 的回答:“这实际上是在复制 Linq 的功能,而没有从 Linq 获得的所有好处”。

问问自己:怎么可能?

于 2013-01-28T19:43:19.807 回答
1

您可以使用流畅的界面。基本思想是一个类的方法在执行了一些操作之后返回这个类的当前实例。这允许您链接方法调用。

通过创建适当的类层次结构,您可以创建可访问方法的逻辑流。

public class FinalQuery
{
    protected string _table;
    protected string[] _selectFields;
    protected string _where;
    protected string[] _groupBy;
    protected string _having;
    protected string[] _orderByDescending;
    protected string[] _orderBy;

    protected FinalQuery()
    {
    }

    public override string ToString()
    {
        var sb = new StringBuilder("SELECT ");
        AppendFields(sb, _selectFields);
        sb.AppendLine();

        sb.Append("FROM ");
        sb.Append("[").Append(_table).AppendLine("]");

        if (_where != null) {
            sb.Append("WHERE").AppendLine(_where);
        }

        if (_groupBy != null) {
            sb.Append("GROUP BY ");
            AppendFields(sb, _groupBy);
            sb.AppendLine();
        }

        if (_having != null) {
            sb.Append("HAVING").AppendLine(_having);
        }

        if (_orderBy != null) {
            sb.Append("ORDER BY ");
            AppendFields(sb, _orderBy);
            sb.AppendLine();
        } else if (_orderByDescending != null) {
            sb.Append("ORDER BY ");
            AppendFields(sb, _orderByDescending);
            sb.Append(" DESC").AppendLine();
        }

        return sb.ToString();
    }

    private static void AppendFields(StringBuilder sb, string[] fields)
    {
        foreach (string field in fields) {
            sb.Append(field).Append(", ");
        }
        sb.Length -= 2;
    }
}

public class GroupedQuery : FinalQuery
{
    protected GroupedQuery()
    {
    }

    public GroupedQuery Having(string condition)
    {
        if (_groupBy == null) {
            throw new InvalidOperationException("HAVING clause without GROUP BY clause");
        }
        if (_having == null) {
            _having = " (" + condition + ")";
        } else {
            _having += " AND (" + condition + ")";
        }
        return this;
    }

    public FinalQuery OrderBy(params string[] fields)
    {
        _orderBy = fields;
        return this;
    }

    public FinalQuery OrderByDescending(params string[] fields)
    {
        _orderByDescending = fields;
        return this;
    }
}

public class Query : GroupedQuery
{
    public Query(string table, params string[] selectFields)
    {
        _table = table;
        _selectFields = selectFields;
    }

    public Query Where(string condition)
    {
        if (_where == null) {
            _where = " (" + condition + ")";
        } else {
            _where += " AND (" + condition + ")";
        }
        return this;
    }

    public GroupedQuery GroupBy(params string[] fields)
    {
        _groupBy = fields;
        return this;
    }
}

你会这样称呼它

string query = new Query("myTable", "name", "SUM(amount) AS total")
    .Where("name LIKE 'A%'")
    .GroupBy("name")
    .Having("COUNT(*) > 2")
    .OrderBy("name")
    .ToString();

您只能创建 的新实例Query。其他类有一个受保护的构造函数。层次结构的重点是“禁用”方法。例如,该GroupBy方法返回 a GroupedQuery,它是基类Query并且没有Where方法( where 方法在 中声明Query)。因此无法调用Whereafter GroupBy

然而它并不完美。使用此类层次结构,您可以连续隐藏成员,但不显示新成员。因此Having在之前调用它时会引发异常GroupBy

请注意,可以Where多次调用。这会AND在现有条件中添加新条件。这使得从单个条件以编程方式构造过滤器变得更加容易。也是可能的Having

接受字段列表的方法有一个参数params string[] fields。它允许您传递单个字段名称或字符串数​​组。


Fluent 接口非常灵活,不需要您创建大量具有不同参数组合的方法重载。我的示例适用于字符串,但是该方法可以扩展到其他类型。您还可以为特殊情况或接受自定义类型的方法声明预定义的方法。您还可以添加类似ExecuteReaderor的方法ExceuteScalar<T>。这将允许您定义这样的查询

var reader = new Query<Employee>(new MonthlyReportFields{ IncludeSalary = true })
    .Where(new CurrentMonthCondition())
    .Where(new DivisionCondition{ DivisionType = DivisionType.Production})
    .OrderBy(new StandardMonthlyReportSorting())
    .ExecuteReader();

即使是这样构造的 SQL 命令也可以有命令参数,从而避免 SQL 注入问题,同时允许命令被数据库服务器缓存。这不是 O/R 映射器的替代品,但可以在您使用简单字符串连接创建命令的情况下提供帮助。

于 2013-01-20T02:12:52.313 回答