Ardalis.Specification is a powerful library that enables the specification pattern for querying databases, primarily designed for Entity Framework Core, but here I'll demonstrate how you can extend Ardalis.Specification to use NHibernate as an ORM as well.
This blog post assumes you have some experience with Ardalis.Specification, and want to use it in a project using NHibernate. If you are not familiar with Ardalis.Specification yet, head over to the documentation to learn more.
First, in NHibernate there are three different built-in ways to perform queries
I'll go through how you can extend Ardalis.Specification to handle all 3 ways, but since Linq to Query also works with IQueryable like Entity Framework Core, I'll go through that option first.
There is a small nuance between Entity Framework Core and NHIbernate when it comes to create join relationships. In Entity Framework Core we have extensions methods on IQueryable: Include and ThenInclude (these are also the method names used in Ardalis.Specification).
Fetch, FetchMany, ThenFetch and ThenFetchMany are NHibernate specific methods on IQueryable that do joins. The IEvaluator gives us the extensibility we need to invoke the correct extension method when we work with NHibernate.
Add an implementation of IEvaluator as follows:
public class FetchEvaluator : IEvaluator { private static readonly MethodInfo FetchMethodInfo = typeof(EagerFetchingExtensionMethods) .GetTypeInfo().GetDeclaredMethods(nameof(EagerFetchingExtensionMethods.Fetch)) .Single(); private static readonly MethodInfo FetchManyMethodInfo = typeof(EagerFetchingExtensionMethods) .GetTypeInfo().GetDeclaredMethods(nameof(EagerFetchingExtensionMethods.FetchMany)) .Single(); private static readonly MethodInfo ThenFetchMethodInfo = typeof(EagerFetchingExtensionMethods) .GetTypeInfo().GetDeclaredMethods(nameof(EagerFetchingExtensionMethods.ThenFetch)) .Single(); private static readonly MethodInfo ThenFetchManyMethodInfo = typeof(EagerFetchingExtensionMethods) .GetTypeInfo().GetDeclaredMethods(nameof(EagerFetchingExtensionMethods.ThenFetchMany)) .Single(); public static FetchEvaluator Instance { get; } = new FetchEvaluator(); public IQueryableGetQuery (IQueryable query, ISpecification specification) where T : class { foreach (var includeInfo in specification.IncludeExpressions) { query = includeInfo.Type switch { IncludeTypeEnum.Include => BuildInclude (query, includeInfo), IncludeTypeEnum.ThenInclude => BuildThenInclude (query, includeInfo), _ => query }; } return query; } public bool IsCriteriaEvaluator { get; } = false; private IQueryable BuildInclude (IQueryable query, IncludeExpressionInfo includeInfo) { _ = includeInfo ?? throw new ArgumentNullException(nameof(includeInfo)); var methodInfo = (IsGenericEnumerable(includeInfo.PropertyType, out var propertyType) ? FetchManyMethodInfo : FetchMethodInfo); var method = methodInfo.MakeGenericMethod(includeInfo.EntityType, propertyType); var result = method.Invoke(null, new object[] { query, includeInfo.LambdaExpression }); _ = result ?? throw new TargetException(); return (IQueryable )result; } private IQueryable BuildThenInclude (IQueryable query, IncludeExpressionInfo includeInfo) { _ = includeInfo ?? throw new ArgumentNullException(nameof(includeInfo)); _ = includeInfo.PreviousPropertyType ?? throw new ArgumentNullException(nameof(includeInfo.PreviousPropertyType)); var method = (IsGenericEnumerable(includeInfo.PreviousPropertyType, out var previousPropertyType) ? ThenFetchManyMethodInfo : ThenFetchMethodInfo); IsGenericEnumerable(includeInfo.PropertyType, out var propertyType); var result = method.MakeGenericMethod(includeInfo.EntityType, previousPropertyType, propertyType) .Invoke(null, new object[] { query, includeInfo.LambdaExpression }); _ = result ?? throw new TargetException(); return (IQueryable )result; } private static bool IsGenericEnumerable(Type type, out Type propertyType) { if (type.IsGenericType && (type.GetGenericTypeDefinition() == typeof(IEnumerable))) { propertyType = type.GenericTypeArguments[0]; return true; } propertyType = type; return false; } }
Next we need to configure ISpecificationEvaluator to use our FetchEvaluator (and other evaluators). We add an implementation ISpecificationEvaluator as follows with the Evaluators configured in the constructor. WhereEvaluator, OrderEvaluator and PaginationEvaluator are all in the Ardalis.Specification and works well NHibernate as well.
public class LinqToQuerySpecificationEvaluator : ISpecificationEvaluator { private ListEvaluators { get; } = new List (); public LinqToQuerySpecificationEvaluator() { Evaluators.AddRange(new IEvaluator[] { WhereEvaluator.Instance, OrderEvaluator.Instance, PaginationEvaluator.Instance, FetchEvaluator.Instance }); } public IQueryable GetQuery (IQueryable query, ISpecification specification) where T : class { if (specification is null) throw new ArgumentNullException(nameof(specification)); if (specification.Selector is null && specification.SelectorMany is null) throw new SelectorNotFoundException(); if (specification.Selector is not null && specification.SelectorMany is not null) throw new ConcurrentSelectorsException(); query = GetQuery(query, (ISpecification )specification); return specification.Selector is not null ? query.Select(specification.Selector) : query.SelectMany(specification.SelectorMany!); } public IQueryable GetQuery (IQueryable query, ISpecification specification, bool evaluateCriteriaOnly = false) where T : class { if (specification is null) throw new ArgumentNullException(nameof(specification)); var evaluators = evaluateCriteriaOnly ? Evaluators.Where(x => x.IsCriteriaEvaluator) : Evaluators; foreach (var evaluator in evaluators) query = evaluator.GetQuery(query, specification); return query; } }
Now we can create a reference to LinqToQuerySpecificationEvaluator in our repository that may look something like this:
public class Repository : IRepository { private readonly ISession _session; private readonly ISpecificationEvaluator _specificationEvaluator; public Repository(ISession session) { _session = session; _specificationEvaluator = new LinqToQuerySpecificationEvaluator(); } ... other repository methods public IEnumerableList (ISpecification specification) where T : class { return _specificationEvaluator.GetQuery(_session.Query ().AsQueryable(), specification).ToList(); } public IEnumerable List (ISpecification specification) where T : class { return _specificationEvaluator.GetQuery(_session.Query ().AsQueryable(), specification).ToList(); } public void Dispose() { _session.Dispose(); } }
That's it. We can now use Linq to Query in our specifications just like we normally do with Ardalis.Specification:
public class TrackByName : Specification{ public TrackByName(string trackName) { Query.Where(x => x.Name == trackName); } }
Now that we've covered Linq-based queries, let's move on to handling Criteria API and Query Over, which require a different approach.
Since Criteria API and Query Over has their own implementation to generate SQL, and doesn't use IQueryable, they are incompatible with the IEvaluator interface. My solution is to avoid using the IEvaluator interface for these methods in this case, but rather focus on the benefits of the specification pattern. But I also want to be able to mix
Linq to Query, Criteria and Query Over with in my solution (if you only need one of these implementations, you can cherry-pick for your best needs).
To be able to do that, I add four new classes that inherits Specification or Specification
NOTE: The assembly where you define these classes needs a reference to NHibernate as we define actions for Criteria and a QueryOver, that can be found in NHibernate
public class CriteriaSpecification: Specification { private Action ? _action; public Action GetCriteria() => _action ?? throw new NotSupportedException("The criteria has not been specified. Please use UseCriteria() to define the criteria."); protected void UseCriteria(Action action) => _action = action; } public class CriteriaSpecification : Specification { private Action ? _action; public Action GetCriteria() => _action ?? throw new NotSupportedException("The criteria has not been specified. Please use UseCriteria() to define the criteria."); protected void UseCriteria(Action action) => _action = action; } public class QueryOverSpecification : Specification { private Action >? _action; public Action > GetQueryOver() => _action ?? throw new NotSupportedException("The Query over has not been specified. Please use the UseQueryOver() to define the query over."); protected void UseQueryOver(Action > action) => _action = action; } public class QueryOverSpecification : Specification { private Func , IQueryOver >? _action; public Func , IQueryOver > GetQueryOver() => _action ?? throw new NotSupportedException("The Query over has not been specified. Please use the UseQueryOver() to define the query over."); protected void UseQueryOver(Func , IQueryOver > action) => _action = action; }
Then we can use pattern matching in our repository to change how we do queries with NHibernate
public IEnumerableList (ISpecification specification) where T : class { return specification switch { CriteriaSpecification criteriaSpecification => _session.CreateCriteria () .Apply(query => criteriaSpecification.GetCriteria().Invoke(query)) .List (), QueryOverSpecification queryOverSpecification => _session.QueryOver () .Apply(queryOver => queryOverSpecification.GetQueryOver().Invoke(queryOver)) .List (), _ => _specificationEvaluator.GetQuery(_session.Query ().AsQueryable(), specification).ToList() }; } public IEnumerable List (ISpecification specification) where T : class { return specification switch { CriteriaSpecification criteriaSpecification => _session.CreateCriteria () .Apply(query => criteriaSpecification.GetCriteria().Invoke(query)) .List (), QueryOverSpecification queryOverSpecification => _session.QueryOver () .Apply(queryOver => queryOverSpecification.GetQueryOver().Invoke(queryOver)) .List (), _ => _specificationEvaluator.GetQuery(_session.Query ().AsQueryable(), specification).ToList() }; }
The Apply() method above are an extension method that simplifies the query to a single line:
public static class QueryExtensions { public static T Apply(this T obj, Action action) { action(obj); return obj; } public static TResult Apply (this T obj, Func func) { return func(obj); } }
NOTE: The assembly where you define these classes needs a reference to NHibernate as we define actions for Criteria, that can be found in NHibernate
public class TrackByNameCriteria : CriteriaSpecification
NOTE: The assembly where you define these classes needs a reference to NHibernate as we define actions for a QueryOver, that can be found in NHibernate
public class TrackByNameQueryOver : QueryOverSpecification
By extending Ardalis.Specification for NHibernate, we unlock the ability to use Linq to Query, Criteria API, and Query Over—all within a single repository pattern. This approach offers a highly adaptable and powerful solution for NHibernate users
免责声明: 提供的所有资源部分来自互联网,如果有侵犯您的版权或其他权益,请说明详细缘由并提供版权或权益证明然后发到邮箱:[email protected] 我们会第一时间内为您处理。
Copyright© 2022 湘ICP备2022001581号-3