彩票走势图

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

转帖|使用教程|编辑:龚雪|2015-09-29 15:55:17.000|阅读 439 次

概述:EntityFramework DynamicFilters是我们创建全局的,针对实体框架查询的过虑器,这些过滤器会自动应用于每一个查询。能被用于支持多租户,软删除,等等。

# 慧都年终大促·界面/图表报表/文档/IDE等千款热门软控件火热促销中 >>

一、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实现的,核心代码如下:

 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         }

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

本文转自《付灿的技术博客》


标签:

本站文章除注明转载外,均为本站原创或翻译。欢迎任何形式的转载,但请务必注明出处、不得修改原文相关链接,如果存在内容上的异议请邮件反馈至chenjj@cahobeh.cn


为你推荐

  • 推荐视频
  • 推荐活动
  • 推荐产品
  • 推荐文章
  • 慧都慧问
扫码咨询


添加微信 立即咨询

电话咨询

客服热线
023-68661681

TOP