采用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的数据审计日志

数据审计日志:

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

我们先来看一下效果.

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

这是他追踪到的信息,我们可以很方便的把这些信息存入数据库或者你的日志存储里(文本,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();
                }
复制代码

最终结果如下:

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

可以看到我们很方便的监控到了我们刚刚进行的三次操作.

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

第四章:查询缓存

代码如下:

复制代码
//使用默认的缓存时间
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();

免责声明:文章转载自《采用EntityFramework.Extended 对EF进行扩展(Entity Framework 延伸系列2)》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇ELK 架构之 Logstash 和 Filebeat 安装配置GCC高级测试功能扩展——程序性能测试工具gprof、程序覆盖测试工具gcov下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

过滤sql特殊字符方法集合

///<summary>///过滤不安全的字符串///</summary>///<param name="Str"></param>///<returns></returns>publicstaticstringFilteSQLStr(stringStr){Str=Str.Replac...

jboss8+EJB3+MDB Queue

1)在使用jboss8即WildFly进行MDB的试验时首先要在jboss8中配置jms 队列。      我使用的是修改配置文件的方式配置Jms Queue队列。      进入jboss8 安装目录的standaloneconfiguration文件夹下:      因为使用的是standalone-full.xml文件,所以将该文件的文件名修改为st...

干掉mapper.xml!MyBatis新特性动态SQL真香!

干掉mapper.xml!MyBatis新特性动态SQL真香! 当我们使用MyBatis的时候,需要在mapper.xml中书写大量的SQL语句。当我们使用MyBatis Generator(MBG)作为代码生成器时,也会生成大量的mapper.xml文件。其实从MBG 1.3.6版本以后,MyBatis官方已经推荐使用Dynamic SQL,使用这一新特...

Spring MVC与Dubbo的整合一

一、Dubbo是什么 一款分布式服务框架 高性能和透明化的RPC远程服务调用方案 SOA服务治理方案 每天为2千多个服务提供大于30亿次访问量支持,并被广泛应用于阿里巴巴集团的各成员站点以及别的公司的业务中。 具体dubbo的背景和简介以及框架等基础知识参考这位大神的博客 二、提供者的Dubbo配置 首先我们先配置服务的提供者 1.给作为提供者的Spr...

SQL触发器(1)

在实习过程中涉及到SQL触发器,在校时未学习过触发器的知识,因而进行上网自学整理,以下内容为我对网上资料收集整合,若侵权请联系删除,谢谢。 一、触发器概念  定义: 何为触发器?在SQL Server里面也就是对某一个表的一定的操作,触发某种条件,从而执行的一段程序。触发器是一个特殊的存储过程。  常见的触发器有三种:分别应用于Insert , Updat...

ASP.NET Core WebAPI学习-1

Web API学习 ASP.NET Core WebAPI学习-1 ASP.NET Core WebAPI学习-2 ASP.NET Core WebAPI学习-3 ASP.NET Core WebAPI学习-4 ASP.NET Core WebAPI学习-5 ASP.NET Core WebAPI学习-6 创建Web API项目 打开Visual...