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

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

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

 

1、EntityFramework DynamicFilters 是什么，它能作什么？

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

　　一、何为数据过滤？

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

　

　　二、何为动态？

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

 

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

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

 

2、 没有它时，咱们是怎么作的？

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

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

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

 

3、EntityFramework DynamicFilters给咱们带来了改变

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

 1 　　　　protected override void OnModelCreating(DbModelBuilder modelBuilder)
 2         {
 3             base.OnModelCreating(modelBuilder);
 4 
 5             //限制全部针对BlogEntry查询的过虑（只获取未删除的）
 6             //这里的全局过虑，使用了委托，以便在每次须要计算值
 7             //重要：若是值使用的是一个委托，请确保它在你的应用中是全局的，
 8             modelBuilder.Filter("BlogEntryFilter", (BlogEntry b, bool isDeleted) => (b.IsDeleted == isDeleted),
 9                                                 () => false);
10 
11         }

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

 1          /// <summary>
 2         /// 查询
 3         /// </summary>
 4         /// <param name="context"></param>
 5         /// <param name="userName"></param>
 6         private static void Query(ExampleContext context, string userName)
 7         {
 8             var account = context.Accounts
 9                 .Include(a => a.BlogEntries).FirstOrDefault(a => a.UserName == userName);

13             Console.WriteLine("帐号{0}的博客有：",userName);
14             if (account == null) return;
15             foreach (var blog in account.BlogEntries)
16             {
17                 Console.WriteLine("{0}",blog.Id);
18             }
19         }    

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

若是你在某种状况下不想使用过虑器时，你可使用以下代码将其禁用：

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

 

注意：禁用只对当前上下文DbContext实例有效，不影响别的上下文实例。若是你想对全部的上下文实例有效时，能够在 OnModelCreating方法中使用全局禁用函数：

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

 

启用的代码相似，这里就很少少了，直接看代码：

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

 

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

 1  class Program {
 2         static void Main(string[] args) {
 3 
 4             // 过滤器默认启用
 5             var context = new ExampleContext();
 6 
 7             Console.WriteLine(" 使用过滤器BlogEntryFilter进行查询");
 8             Query(context, "homer");
 9 
10             //禁用过滤器
11             context.DisableFilter("BlogEntryFilter");
12             
13             Console.WriteLine(" 禁用过滤器BlogEntryFilter进行查询");
14             Query(context, "homer");
15 
16             Console.ReadLine();
17         }
18 
19         /// <summary>
20         /// 查询
21         /// </summary>
22         /// <param name="context"></param>
23         /// <param name="userName"></param>
24         private static void Query(ExampleContext context, string userName)
25         {
26             var account = context.Accounts
27                 .Include(a => a.BlogEntries).FirstOrDefault(a => a.UserName == userName);
28 
29             Console.WriteLine("帐号{0}的博客有：",userName);
30             if (account == null) return;
31             foreach (var blog in account.BlogEntries)
32             {
33                 Console.WriteLine("{0}",blog.Id);
34             }
35         }
36     }

 

代码输出以下：

 

4、EntityFramework DynamicFilters原理概述

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

 1   private static void Filter<TEntity>(DbModelBuilder modelBuilder, string filterName, LambdaExpression predicate, params object[] valueList)
 2         {
 3             InitializeDynamicFilters(null);
 4 
 5             filterName = ScrubFilterName(filterName);
 6 
 7             modelBuilder.Conventions.Add(new DynamicFilterConvention(filterName, typeof(TEntity), predicate));
 8 
 9             //  Always add the filter to _GlobalParameterValues - need it to be able to disable it
10             _GlobalParameterValues.TryAdd(filterName, new DynamicFilterParameters());
11 
12             int numParams = predicate.Parameters == null ? 0 : predicate.Parameters.Count;
13             int numValues = valueList == null ? 0 : valueList.Length;
14             for (int i = 1; i < numParams; i++)
15             {
16                 object value = ((i - 1) < numValues) ? valueList[i - 1] : null;
17                 SetFilterGlobalParameterValue(null, filterName, predicate.Parameters[i].Name, value);
18             }
19         }

 

整个项目的源代码很少，若是你有兴趣，请阅读源代码。文中使用的代码，请于结尾处下载。

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

 

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

 

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

谢谢你们的持续关注，个人博客地址：http://www.cnblogs.com/VolcanoCloud/