实体框架高级应用之动态过滤 EntityFramework DynamicFilters

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

我们开门见山，直奔主题。

一、EntityFramework DynamicFilters 是什么，它能做什么？

EntityFramework DynamicFilters是一个开源项目。你可以到这里去下载它的源码。顾名思义，它为我们做的事，就是帮我们动态过滤数据。为了照顾初学者，我们从头道来。

1、何为数据过滤？

数据过滤说简单点，就是去掉我们不想要的数据。SQL语句中的where从句，Linq中的where从句，还有扩展方法Where，就是完成这件光荣任务的。

2、何为动态？

动态的意思就是不死板地应用我们所写的条件，比如，我们在一个地方写了where从句，它只能用于这次查询，下次遇到相似的情况时，我们还得老老实实的写 where xxx=xxx。很长的一段时间，我们一直这样，很和谐地使用着这种方法。突然有一天，抓了抓头：如果类似的情况，能自动加上相应的过虑条件，或是应用相应的规则，该有多好？于是就有动态。当然这里的动态，只是我们面对问题的一个方面。

3、废话半天，它到底能做什么，具体点，好不？

它可以为我们创建全局的，针对实体框架查询的过虑器，这些过滤器会自动应用于每一个查询。能被用于支持多租户，软删除，等等。过滤器能通过返回布尔类型的Linq表达式来创建，同时还支持Contains()操作符（方法）。目前支持的数据库有MS SQL Server(包含 Azure），MySql,Oracle。

二、没有它时，我们是怎么做的？

我们以软删除（不是真正意义上的删除数据，只是在相应的记录上作一个删除标识）为例。正因为数据没有被真正地删除，只是被我们用一个标识给标记起来了，那么，我们就得在每一个查询的地方加上一个条件（过滤掉标记为删除的数据），代码可能长成这样：

var blogs = context.BlogEntries.Where(b => b.IsDeleted == false).ToList();

上面的代码就不用多解释了，相信你能看明白。如果是sql 语句，你可能会说，这有什么难的，我找一个地方，把所有的查询拼接上这个条件不就OK。确实如此，但，这里只是拿这个简单的场景来作为示例，复杂的场景呢？其次，Linq表达式拼接条件，不是像字符串那样随心所欲，至少很大一部分人是这样，当然也包含我。每一个查询都手工加上这样的条件，不光是工作量增加了，可维护性降低了，还分散了我们的核心业务逻辑的注意力。

三、EntityFramework DynamicFilters给我们带来了改变

当然，它只是众多解决方案之一，只是作者无私的分享出来了，没把它当成宝供在自己的电脑里。 我只需要在上下文DbContext的OnModelCreating 方法中添加过滤器。代码如下：

protected override void OnModelCreating(DbModelBuilder modelBuilder)
{
base.OnModelCreating(modelBuilder); //限制所有针对BlogEntry查询的过虑（只获取未删除的）
//这里的全局过虑，使用了委托，以便在每次需要计算值
//重要：如果值使用的是一个委托，请确保它在你的应用中是全局的，
modelBuilder.Filter("BlogEntryFilter", (BlogEntry b, bool isDeleted) => (b.IsDeleted == isDeleted),
() => false); }

就这样，它就会在我们每一个关于Blog实体的查询中添加上条件（b => b.IsDeleted == false）。我们无需关心它如何添加这个条件，使用的地方，完全透明，就像没有它一样。示例代码如下：

/// <summary>
/// 查询
/// </summary>
/// <param name="context"></param>
/// <param name="userName"></param>
private static void Query(ExampleContext context, string userName)
{
var account = context.Accounts
.Include(a => a.BlogEntries).FirstOrDefault(a => a.UserName == userName);
Console.WriteLine("账号{0}的博客有：",userName);
if (account == null) return;
foreach (var blog in account.BlogEntries)
{
Console.WriteLine("{0}",blog.Id);
}
}

但需要注意的是，如果在同一个上下文DbContext实例中，运用过虑器之前，过虑器有被禁用过，而数据被缓存时，过滤器就不会起任何效果，所有使用时，你一定要避免在同一个上下文中因更改过滤器而影响结果的情况。

如果你在某种情况下不想使用过虑器时，你可以使用如下代码将其禁用：

//禁用过滤器
context.DisableFilter("BlogEntryFilter");

注意：禁用只对当前上下文DbContext实例有效，不影响别的上下文实例。如果你想对所有的上下文实例有效时，可以在 OnModelCreating方法中使用全局禁用函数：

//全局禁用过滤器
modelBuilder.DisableFilterGlobally("BlogEntryFilter");

启用的代码类似，这里就不多少了，直接看代码：

//启用过滤器
context.EnableFilter("BlogEntryFilter");
context.EnableAllFilters();

说了这么多，我们来看看运用过滤器的效果吧，代码如下：

class Program {
static void Main(string[] args) { // 过滤器默认启用
var context = new ExampleContext(); Console.WriteLine(" 使用过滤器BlogEntryFilter进行查询");
Query(context, "homer"); //禁用过滤器
context.DisableFilter("BlogEntryFilter"); Console.WriteLine(" 禁用过滤器BlogEntryFilter进行查询");
Query(context, "homer"); Console.ReadLine();
} /// <summary>
/// 查询
/// </summary>
/// <param name="context"></param>
/// <param name="userName"></param>
private static void Query(ExampleContext context, string userName)
{
var account = context.Accounts
.Include(a => a.BlogEntries).FirstOrDefault(a => a.UserName == userName); Console.WriteLine("账号{0}的博客有：",userName);
if (account == null) return;
foreach (var blog in account.BlogEntries)
{
Console.WriteLine("{0}",blog.Id);
}
}
}

代码输出如下：

四、EntityFramework DynamicFilters原理概述

它是通过在对象 DbModelBuilder 上添加扩展方法Filter实现的，核心代码如下：

private static void Filter<TEntity>(DbModelBuilder modelBuilder, string filterName, LambdaExpression predicate, params object[] valueList)
{
InitializeDynamicFilters(null); filterName = ScrubFilterName(filterName); modelBuilder.Conventions.Add(new DynamicFilterConvention(filterName, typeof(TEntity), predicate)); // Always add the filter to _GlobalParameterValues - need it to be able to disable it
_GlobalParameterValues.TryAdd(filterName, new DynamicFilterParameters()); int numParams = predicate.Parameters == null ? : predicate.Parameters.Count;
int numValues = valueList == null ? : valueList.Length;
for (int i = ; i < numParams; i++)
{
object value = ((i - ) < numValues) ? valueList[i - ] : null;
SetFilterGlobalParameterValue(null, filterName, predicate.Parameters[i].Name, value);
}
}

整个项目的源代码不多，如果你有兴趣，请阅读源代码。文中使用的代码，请于结尾处下载。

最后，我要说明的是，文中并没有把 EntityFramework DynamicFilters的方方面面说完，只是说了一些常见的场景。更多的细节，说阅读源码，或者和大家一起实践、交流。

文中示例源代码下载地址：http://files.cnblogs.com/files/VolcanoCloud/EFDynamicFilterDemo.rar

实体框架交流QQ群: 458326058，欢迎有兴趣的朋友加入一起交流

谢谢大家的持续关注，我的博客地址：http://www.cnblogs.com/VolcanoCloud/