EntityFramework.Extended 对EF进行扩展

前言

Entity Framework 延伸系列目录

今天咱们来说讲EntityFramework.Extended

首先科普一下这个EntityFramework.Extended是什么,以下:

这是一个对Entity Framework进行扩展的类库.

彻底支持EF 5.0/6.0+，

GitHub地址 https://github.com/loresoft/EntityFramework.Extended，

最后一次更新是在2015/07/10

这个库支持批量更新，删除。查询结果缓存和审计日志。

这个扩展对于每次批量操纵只生成一条sql语句，而不会像EntityFramework供给的原生办法那样批量N条数据就要生成N条sql语句

 

本文采用的环境与技术

系统:WIN7

数据库:SQL Server2008

相关技术:MVC5+EF6.1.3+EntityFramework.Extended6.0

 

第一章:批量操做数据库

批量删除:

//记得引用
using EntityFramework.Extensions;
//这两种写法均可以,Context是你的EF上下文对象.
context.LogData.Delete(a => a.EntityKey == "aa");
context.LogData.Where(a => a.EntityKey == "aa").Delete();

 

批量更新:

//data为修改的行数
int   data =context.LogData.Where(a=>a.EntityKey=="aa").Update(b=> new LogData { EntityName = "ss" });
//第二种写法,这种是针对DbSet的,已经标注过期了
 var data = context.LogData.Update(a => a.EntityKey == "aa",b=> new LogData { EntityName = "ss" });

批量增长:

//这个和Extended无关..EF自己就自带了,单纯的给新手一个实例而已,大神无视..
int data= context.LogData.AddRange(new List<LogData>());

 

第二章:批量查询数据库

批量查询:

                    var count =context.LogData.FutureCount();
                    var data = context.LogData.FutureFirstOrDefault(); 
                    var datalist = context.LogData.Future();
                    //在同一个代码上下文中,count,data,datalist这三个对象
                    //任意一个,第一次tolist或者.Value的时候,会链接一次数据库
                    //同时查询这三个数据,而不会分三次查询
                    var datalists = datalist.ToList();
                    int countdata = count.Value;        

原理是这样的:

E文原文:

Future queries work by creating the appropriate IFutureQuery object that keeps the IQuerable. The IFutureQuery object is then stored in IFutureContext.FutureQueries list. Then, when one of the IFutureQuery objects is enumerated, it calls back to IFutureContext.ExecuteFutureQueries() via the LoadAction delegate. ExecuteFutureQueries builds a batch query from all the stored IFutureQuery objects. Finally, all the IFutureQuery objects are updated with the results from the query.

本屌的辣鸡二流子翻译:

Future 会根据IQuerable建立出他自定义的IFutureQuery对象,而后将他加入到IFutureContext.FutureQueries查询队列当中,当队列中的一个对象调用LoadAction那么就会执行IFutureContext.ExecuteFutureQueries()方法, ExecuteFutureQueries 会构建一个批处理查询的IFutureQuery,最后将全部IFutureQuery的查询结果进行更新(也就是查询).

 

第三章:EF的数据审计日志

数据审计日志:

先说一下这个审计的概念,就是对全部的实体的操做(增,删,改)进行监控.

咱们先来看一下效果.

这是他追踪到的信息,咱们能够很方便的把这些信息存入数据库或者你的日志存储里(文本,XML,缓存)都行 随你.

下面咱们开始讲解用法:

首先咱们能够在应用程序的入口( Application_Start)配置(我这里以MVC的Web应用来举例):

这里的配置可不加,用默认的也行,固然有须要的能够参考

https://github.com/loresoft/EntityFramework.Extended/wiki/Audit-Log

这里有更详细的配置介绍

  protected void Application_Start()
        {
            AreaRegistration.RegisterAllAreas();
            FilterConfig.RegisterGlobalFilters(GlobalFilters.Filters);
            RouteConfig.RegisterRoutes(RouteTable.Routes);
            BundleConfig.RegisterBundles(BundleTable.Bundles);
            //这里是审计日志的配置
            var auditConfiguration = AuditConfiguration.Default;
            auditConfiguration.IncludeRelationships = true;
            auditConfiguration.LoadRelationships = false;
            auditConfiguration.DefaultAuditable = true;
           
        }

下面咱们开始直接用,

举个栗子:

                using (StudentInfoEntities us = new StudentInfoEntities())
                {
                    //开启日志
                    var logaudit = us.BeginAudit();
                   //进行增删改操做
                    us.LogData.Add(new LogData() { EntityKey = "aa", EntityName = "asd", Name = "asd" });
                    var data = us.LogData.Where(a => a.Id == 15).FirstOrDefault();
                    data.Name = "Test";
                    var delete = us.LogData.Where(a => a.Id == 9).FirstOrDefault();
                    us.LogData.Remove(delete);
                    //正常保存
                    us.SaveChanges();
                   //获取审计日志
                    var log = logaudit.LastLog;
                    //将日志转为XML字符串,或存入XML文件
                    string dda = log.ToXml();
                }

最终结果以下:

能够看到咱们很方便的监控到了咱们刚刚进行的三次操做.

(重要提示:这里须要注意的是,这里的审计日志只能监控到常规的写法的增删改,对于上面的批量增删改很诡异的是监控不到的,做为本身写的扩展库,本身却监控不到 - -,这不得不说是很蛋疼..)

 

 

第四章:查询缓存

代码以下:

//使用默认的缓存时间
var tasks = db.Tasks
    .Where(t => t.CompleteDate == null)
    .FromCache();

//查询结果缓存300秒
var tasks = db.Tasks
    .Where(t => t.AssignedId == myUserId && t.CompleteDate == null)
    .FromCache(CachePolicy.WithDurationExpiration(TimeSpan.FromSeconds(300)));

这个我用的很少,就不详细的赘述了,有兴趣的朋友能够自行查看

https://github.com/loresoft/EntityFramework.Extended/wiki/Query-Result-Cache

 

写在最后

文章到此就结束了,写文章的过程也是本身温故而知新的过程.写的很差但愿大神多多指正,我很但愿能起到抛砖引玉的效果,上篇文章就获得了不少好的建议,但愿你们不啬赐教.