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

前言

今天我们来讲讲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

写在最后

文章到此就结束了,写文章的过程也是自己温故而知新的过程.写的不好希望大神多多指正,我很希望能起到抛砖引玉的效果,上篇文章就得到了很多好的建议,希望大家不啬赐教.

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏跟着阿笨一起玩NET

EPPlus与Excel完美的结合

笔者近期在公司项目中需要生产比较复杂的Excel报表, 问题点是单个Excel文件中必须能包含多个sheet, 按照以前项目的经验, 此情况需要使用MS Off...

831
来自专栏Android 研究

Android系统启动——2init进程

严格上讲,Android系统实际上是运行于Linux内核之上的一系列"服务进程",并不算一个完成意义上的"操作系统";而这一系列进程是维持Android设备正常...

1212
来自专栏小樱的经验随笔

【经验分享】后台常用的万能密码

这万能密码好几年前就有了。我都不当回事,结果这次真派上用场了,还真进了后台了 网站后台万能密码就是在用户名与密码处都写入下列字符,如果知道管理员帐号的话直接添...

3495
来自专栏GreenLeaves

Web API系列之三 基本功能实现

Web API系列之二讲解了如何搭建一个WebApi的基架,本文主要在其基础之上实现基本的功能.下面开始逐步操作: 一、配置WebApi的路由-用于配置外部如何...

1935
来自专栏蜉蝣禅修之道

Extjs自定义多字段VTypes

1603
来自专栏Create Sun

基础拾遗-----mongoDB操作

前言   nosq互联网中运用极广的技术,mongo应该算是必不可少的技术之一,虽说我在项目中redis用的较多,mongo在项目中算是用的比较少的技术,但是也...

32611
来自专栏别先生

JSch - Java实现的SFTP(文件上传详解篇)

  JSch是Java Secure Channel的缩写。JSch是一个SSH2的纯Java实现。它允许你连接到一个SSH服务器,并且可以使用端口转发,X11...

1321
来自专栏Linux驱动

24.Linux-Nand Flash驱动(分析MTD层并制作NAND驱动)

1.本节使用的nand flash型号为K9F2G08U0M,它的命令如下: ? 1.1我们以上图的read id(读ID)为例,它的时序图如下: ? 首先需要...

25310
来自专栏一个会写诗的程序员的博客

Java 9 新特性 极简介绍

Java 9 的定义功能是一套全新的模块系统。当代码库越来越大,创建复杂,盘根错节的“意大利面条式代码”的几率呈指数级的增长。这时候就得面对两个基础的问题: 很...

502
来自专栏林德熙的博客

win10 UWP 序列化 BinaryXML序列化

将对象的状态信息转换为可以存储或传输的形式的过程。在序列化期间,对象将其当前状态写入到临时或持久性存储区。以后,可以通过从存储区中读取或反序列化对象的状态,重新...

582

扫码关注云+社区