采用EntityFramework.Extended 对EF进行扩展(Entity Framework 延伸系列2)

EntityFramework 非常好用,结构优美.. 但是美中有不足. 
1.对动态查询条件支持的不是很好 
2.批量操作支持的不是很好. 
下面就是几个第三方库,对EntityFramework 的扩展.具体如何使用请百度吧..

/**********************************************/ 
LinqKit(免费) 
动态拼装查询条件 
http://www.nuget.org/packages/LinqKit/

PM> Install-Package LinqKit

• 1

/**********************************************/

EFUtilities (免费) 
优先推荐的. 
1.功能包含单属性更新. 
2.Delete by query 
3.Batch insert entities 
4.Batch update entities 
5.Partial updates / Not loading the data from DB first 
6.Update by query 
…

如何使用看项目官网 
https://github.com/MikaelEliasson/EntityFramework.Utilities

代码获取方式如下:

支持EF4和5 
https://www.nuget.org/packages/EFUtilities/0.1.0

PM> Install-Package EFUtilities -Version 0.1.0

• 1

支持EF6 
https://www.nuget.org/packages/EFUtilities

PM> Install-Package EFUtilities

• 1

/**********************************************/

efbulkinsert(免费) 
批量插入 
http://efbulkinsert.codeplex.com/

EF4
PM> Install-Package EntityFramework.BulkInsert-ef4
https://www.nuget.org/packages/EntityFramework.BulkInsert-ef4

EF5
PM> Install-Package EntityFramework.BulkInsert-ef5
https://www.nuget.org/packages/EntityFramework.BulkInsert-ef5

EF6
PM> Install-Package EntityFramework.BulkInsert-ef6
https://www.nuget.org/packages/EntityFramework.BulkInsert-ef6

/**********************************************/

EntityFramework.Extended (免费) 
批量更新和删除,缓存 
https://github.com/loresoft/EntityFramework.Extended 
使用方法

PM> Install-Package EntityFramework.Extended

Install-Package Microsoft.AspNet.Mvc -Version 5.2.3
Install-Package EntityFramework

Install-Package Z.EntityFramework.Extensions -Version 3.13.10

Uninstall-Package Z.EntityFramework.Extensions -Version 3.13.10

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

也可以在nuget上直接安装这个包，它的说明有点过时了，最新版本已经改用对IQueryable<T>的扩展，而不是DbSet<T>（已经标记为弃用）,所以跟我一样有隔离癖好的就可以大胆使用了。下面介绍如何批量删除、更新、查询。

批量删除

本来我们需要这样删除

//EF原生的删除需要先取出entity然后remove

context.Remove(context.Users.First(u=>u.Key==xxx);

//如果要删除更多

foreach(var user in context.Users.Where(u => u.FirstName == "firstname").ToList())

{

context.Remove(user);

}

本来一句sql可以解决的问题，变得复杂了。

 使用ORM是为了跟sql尽量的解耦，并且能在编译时检查出更多的错误，但是上面的写法让人堵的慌，如果你也有这种感觉下面的写法是不是就是你脑子里想要的东西呢。

----引用EF Extend Libary后删除只需要一次就完成了，效率高了很多，也不需要太多的连接资源，使用更方便了

//delete all users where FirstName matches

context.Users.Delete(u => u.FirstName == "firstname");

//当然如果我这样写也可以

context.Users.Where(...).Delete();

当第一次看到EF EL的时候就被这种写法吸引住了，这不就是我们一直找的东西么。

批量更新

//批量更新用户名中包含大写J的用户设置工资为999

context.Users.Update(

    u => u.Name.Contans("J"),

    u2 => new User {Salary = 999});

 

//第一个参数也可以传入已经有的IQuaryable的参数如下

var users = context.Users.Where(u => u.FirstName == "firstname");

context.Users.Update(users, u => new User {FirstName = "newfirstname"});<br><br>//当然了我最喜欢的还是这样的写法<br>context.Users.Where(u => u.FirstName == "firstname").Update(u=>new User{FirstName = "newfirstname"})

　　是不是更喜欢这个扩展库了？我是爱不释手了，可惜现在才开始用。

 批量查询

 其实现在的查询已经很棒了，默认的延迟查询都能满足基本需求，但是有时候总希望更极致一点，比如现有的查询无法满足分页这个顽固的需求。

//看看EF EL怎么解决

// 复用的查询

var q = db.Tasks.Where(t => t.Priority == 2);

// 获取总数

var q1 = q.FutureCount();

// 获取分页的数据

var q2 = q.Skip(pageIndex).Take(pageSize).Future();

 

// 这里会触发上面所有Future函数中的查询包装到一个连接中执行

int total = q1.Value;

//因为已经得到结果了，这里不会再次查询

var tasks = q2.ToList();