再讲IQueryablelt;Tgt;，揭开表达式树的神秘面纱

接上篇《先说IEnumerable，我们每天用的foreach你真的懂它吗？》

最近园子里定制自己的orm那是一个风生水起，感觉不整个自己的orm都不好意思继续混博客园了（开个玩笑）。那么在此之前我们有必要仔细了解下 IQueryable<T> ，于是就有了此文。

什么是树？

什么是树？这个问题好像有点白痴。树不就是树嘛。看图：

我们从最下面的主干开始往上看，主枝-分支-分支....可以说是无限分支下去。我们倒过来看就是这样：

平时我们用得最多的树结构数据就是XML了，节点下面可以无限添加子节点。我们想想平时还用过什么树结构数据，比如：菜单无限分级、评论区的楼层。

这和我们今天讲的有毛关系啊。... 我们今天主要就是来分析表达式树的。、

lambda表达式和表达式树的区别：

Lambda表达式：

Func<Student, bool> func = t => t.Name == "农码一生";

表达式树： 

Expression<Func<Student, bool>> expression = t => t.Name == "农码一生";

 咋一看，没啥区别啊。表达式只是用Expression包了一下而已。那你错了，这只是Microsoft给我们展示的障眼法，我们看编译后的C#代码：

第一个lambda表达式编译成了匿名函数，第二个表达式树编译成一了一堆我们不认识的东西，远比我们原来写的lambda复杂得多。

结论：

  • 我们平时使用的表达式树，是编写的lambda表达式然后编译成的表达式树，也就是说平时一般情况使用的表达式树都是编译器帮我们完成的。（当然，我们可以可以手动的主动的去创表达式树。只是太麻烦，不是必要情况没有谁愿意去干这个苦活呢）

我们来看看表达式树到底有什么神奇的地方：

有没有看出点感觉来？Body里面有Right、Left，Right里面又有Right、Left，它们的类型都是继承自 Expression 。这种节点下面有节点，可以无限附加下去的数据结构我们称为树结构数据。也就是我们的表达式树。

补：上面的 Student 实体类：

public class Student

{

    public string Name { get; set; }


    public int Age { get; set; }


    public string Address { get; set; }


    public string Sex { get; set; }

}

解析表达式树

上面我们看到了所谓的表达式树，其他也没有想象的那么复杂嘛。不就是一个树结构数据嘛。如果我们要实现自己的orm，免不了要解析表达式树。一般说到解析树结构数据都会用到递归算法。下面我们开始解析表达式树。

先定义解析方法：

//表达式解析

public static class AnalysisExpression

{

    public static void VisitExpression(Expression expression)

    {

        switch (expression.NodeType)

        {

            case ExpressionType.Call://执行方法

                MethodCallExpression method = expression as MethodCallExpression;

                Console.WriteLine("方法名:" + method.Method.Name);

                for (int i = 0; i < method.Arguments.Count; i++)

                    VisitExpression(method.Arguments[i]);

                break;

            case ExpressionType.Lambda://lambda表达式

                LambdaExpression lambda = expression as LambdaExpression;

                VisitExpression(lambda.Body);

                break;

            case ExpressionType.Equal://相等比较

            case ExpressionType.AndAlso://and条件运算

                BinaryExpression binary = expression as BinaryExpression;

                Console.WriteLine("运算符:" + expression.NodeType.ToString());

                VisitExpression(binary.Left);

                VisitExpression(binary.Right);

                break;

            case ExpressionType.Constant://常量值

                ConstantExpression constant = expression as ConstantExpression;

                Console.WriteLine("常量值:" + constant.Value.ToString());

                break;

            case ExpressionType.MemberAccess:

                MemberExpression Member = expression as MemberExpression;

                Console.WriteLine("字段名称:{0}，类型:{1}", Member.Member.Name, Member.Type.ToString());

                break;

            default:

                Console.Write("UnKnow");

                break;

        }

    }


}

调用解析方法：

Expression<Func<Student, bool>> expression = t => t.Name == "农码一生" && t.Sex == "男";
AnalysisExpression.VisitExpression(expression);

我们来看看执行过程：

一层一层的往子节点递归，直到遍历完所有的节点。最后打印效果如下：

基本上我们想要的元素和值都取到了，接着怎么组装就看你自己的心情了。是拼成sql，还是生成url，请随意！

实现自己的IQueryable<T>、IQueryProvider

仅仅解析了表达式树就可以捣鼓自己的orm了？不行，起码也要基于 IQueryable<T> 接口来编码吧。

接着我们自定义个类 MyQueryable<T> 继承接口 IQueryable<T> ：

public class MyQueryable<T> : IQueryable<T>

 {

     public IEnumerator<T> GetEnumerator()

     {

         throw new NotImplementedException();

     }

     IEnumerator IEnumerable.GetEnumerator()

     {

         throw new NotImplementedException();

     }

     public Type ElementType

     {

         get { throw new NotImplementedException(); }

     }

     public Expression Expression

     {

         get { throw new NotImplementedException(); }

     }

     public IQueryProvider Provider

     {

         get { throw new NotImplementedException(); }

     }

 }

我们看到其中有个接口属性 IQueryProvider ，这个接口的作用大着呢，主要作用是在执行查询操作符的时候重新创建 IQueryable<T> 并且最后遍历的时候执行sql远程取值。我们还看见了 Expression  属性。

现在我们明白了 IQueryable<T> 和 Expression （表达式树）的关系了吧：

  •  IQueryable<T> 最主要的作用就是用来存储 Expression（表达式树）

下面我们也自定义现实了 IQueryProvider 接口的类 MyQueryProvider ：

public class MyQueryProvider : IQueryProvider

{

    public IQueryable<TElement> CreateQuery<TElement>(Expression expression)

    {

        throw new NotImplementedException();

    }

    public IQueryable CreateQuery(Expression expression)

    {

        throw new NotImplementedException();

    }

    public TResult Execute<TResult>(Expression expression)

    {

        throw new NotImplementedException();

    }

    public object Execute(Expression expression)

    {

        throw new NotImplementedException();

    }

}

上面全是自动生成的伪代码，下面我们来填充具体的实现：

public class MyQueryProvider : IQueryProvider

    {

        public IQueryable<TElement> CreateQuery<TElement>(Expression expression)

        {

            return new MyQueryable<TElement>(expression);

        }


        public IQueryable CreateQuery(Expression expression)

        {

            throw new NotImplementedException();

        }


        public TResult Execute<TResult>(Expression expression)

        {

            return default(TResult);

        }


        public object Execute(Expression expression)

        {

            return new List<object>();

        } 

    }  

    public class MyQueryable<T> : IQueryable<T>

    {

        public MyQueryable()

        {

            _provider = new MyQueryProvider();

            _expression = Expression.Constant(this);

        }


        public MyQueryable(Expression expression)

        {

            _provider = new MyQueryProvider();

            _expression = expression;

        }

        public Type ElementType

        {

            get { return typeof(T); }

        }


        private Expression _expression;

        public Expression Expression

        {

            get { return _expression; }

        }


        private IQueryProvider _provider;

        public IQueryProvider Provider

        {

            get { return _provider; }

        }


        public IEnumerator GetEnumerator()

        {

            return (Provider.Execute(Expression) as IEnumerable).GetEnumerator();

        }


        IEnumerator<T> IEnumerable<T>.GetEnumerator()

        {

            var result = _provider.Execute<List<T>>(_expression);

            if (result == null)

                yield break;

            foreach (var item in result)

            {

                yield return item;

            }

        }

    }

执行代码：

 var aa = new MyQueryable<Student>(); var bb = aa.Where(t => t.Name == "农码一生"); var cc = bb.Where(t => t.Sex == "男"); var dd = cc.AsEnumerable(); var ee = cc.ToList();

接着我们看看执行过程：

结论：

  • 每次在执行 Where 查询操作符的时候 IQueryProvider 会为我们创建一个新的 IQueryable<T> 

  • 调用 AsEnumerable() 方法的时候并不会去实际取值（只是得到一个IEnumerable）[注意：在EF里面查询不要先取IEnumerable后滤筛，因为AsEnumerable()会生成查询全表的sql]

  • 执行 ToList() 方法时才去真正调用迭代器 GetEnumerator() 取值

  • 真正取值的时候，会去执行 IQueryProvider 中的 Execute 方法。（就是在调用这个方法的时候解析表达式数，然后执行取得结果）

我们看到真正应该办实事的 Execute  我们却让他返回默认值了。

现在估计有人不爽了，你到是具体实现下 Execute 。好吧！（其实通过上面说的解析表达式树，你可以自己在这里做想做的任何事了。）

首先为了简单起见，我们用一个集合做为数据源：

//构造Student数组

public static List<Student> StudentArrary = new List<Student>()

{

        new Student(){Name="农码一生", Age=26, Sex="男", Address="长沙"},

        new Student(){Name="小明", Age=23, Sex="男", Address="岳阳"},

        new Student(){Name="嗨-妹子", Age=25, Sex="女", Address="四川"}

};

然后，重新写一个VisitExpression2方法：（和之前的区别： 现在目的是取表达式树中的表达式，而不是重新组装成sql或别的）

public static void VisitExpression2(Expression expression, ref List<LambdaExpression> lambdaOut)

{

    if (lambdaOut == null)

        lambdaOut = new List<LambdaExpression>();

    switch (expression.NodeType)

    {

        case ExpressionType.Call://执行方法

            MethodCallExpression method = expression as MethodCallExpression;

            Console.WriteLine("方法名:" + method.Method.Name);

            for (int i = 0; i < method.Arguments.Count; i++)

                VisitExpression2(method.Arguments[i], ref  lambdaOut);

            break;

        case ExpressionType.Lambda://lambda表达式

            LambdaExpression lambda = expression as LambdaExpression;

            lambdaOut.Add(lambda);

            VisitExpression2(lambda.Body, ref  lambdaOut);

            break;

        case ExpressionType.Equal://相等比较

        case ExpressionType.AndAlso://and条件运算

            BinaryExpression binary = expression as BinaryExpression;

            Console.WriteLine("运算符:" + expression.NodeType.ToString());

            VisitExpression2(binary.Left, ref  lambdaOut);

            VisitExpression2(binary.Right, ref  lambdaOut);

            break;

        case ExpressionType.Constant://常量值

            ConstantExpression constant = expression as ConstantExpression;

            Console.WriteLine("常量值:" + constant.Value.ToString());

            break;

        case ExpressionType.MemberAccess:

            MemberExpression Member = expression as MemberExpression;

            Console.WriteLine("字段名称:{0}，类型:{1}", Member.Member.Name, Member.Type.ToString());

            break;

        case ExpressionType.Quote:

            UnaryExpression Unary = expression as UnaryExpression;

            VisitExpression2(Unary.Operand, ref  lambdaOut);

            break;

        default:

            Console.Write("UnKnow");

            break;

    }

}

然后重新实现方法 Execute ：

public TResult Execute<TResult>(Expression expression)

{

    List<LambdaExpression> lambda = null;

    AnalysisExpression.VisitExpression2(expression, ref lambda);//解析取得表达式数中的表达式

    IEnumerable<Student> enumerable = null;

    for (int i = 0; i < lambda.Count; i++)

    {

        //把LambdaExpression转成Expression<Func<Student, bool>>类型

        //通过方法Compile()转成委托方法

        Func<Student, bool> func = (lambda[i] as Expression<Func<Student, bool>>).Compile(); 

        if (enumerable == null)

            enumerable = Program.StudentArrary.Where(func);//取得IEnumerable

        else

            enumerable = enumerable.Where(func);

    }

    dynamic obj = enumerable.ToList();//（注意：这个方法的整个处理过程，你可以换成解析sql执行数据库查询，或者生成url然后请求获取数据。）

    return (TResult)obj;

}

执行过程：

个人对 IQueryable 延迟加载的理解：

  • 前段部分的查询操作符只是把逻辑分解存入表达式树，并没有远程执行sql。

  • foreache执行的是 IEnumerable<T> ，然而 IEnumerable<T> 同样具有延迟加载的特性。每次迭代的时候才真正的取数据。且在使用导航属性的时候会再次查询数据库。(下次说延迟加载不要忘记了 IEnumerable 的功劳哦！)

小知识：

表达式树转成Lambda表达式：

Expression<Func<Student, bool>> expression = t => t.Name == "农码一生";
Func<Student, bool> func = expression.Compile();

总结：

表达式树的分析就告一段落了，其中还有很多细节或重要的没有分析到。下次有新的心得再来总结。

感觉表达式树就是先把表达式打散存在树结构里（一般打散的过程是编译器完成），然后可以根据不同的数据源或接口重新组装成自己想要的任何形式，这也让我们实现自己的orm成为了可能。

今天主要是对表达式树的解析、和实现自己的IQueryable<T>、IQueryProvider做了一个记录和总结，其中不定有错误的结论或说法，轻点拍！

文章首链：http://www.cnblogs.com/zhaopei/p/5792623.html

demo下载：http://pan.baidu.com/s/1nvAksgL 

 

推荐阅读：

http://www.cnblogs.com/jesse2013/p/expressiontree-part1.html

http://www.cnblogs.com/jesse2013/p/expressiontree-part2.html

http://www.cnblogs.com/jesse2013/p/expressiontree-Linq-to-cnblogs.html


原文地址：http://www.cnblogs.com/zhaopei/p/IQueryable-IQueryProvider.html

.NET社区新闻，深度好文，微信中搜索dotNET跨平台或扫描二维码关注

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/328691.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Java进阶之路——从初级程序员到架构师，从小工到专家

Java进阶之路——从初级程序员到架构师，从小工到专家

转载自 Java进阶之路——从初级程序员到架构师&#xff0c;从小工到专家怎样学习才能从一名Java初级程序员成长为一名合格的架构师&#xff0c;或者说一名合格的架构师应该有怎样的技术知识体系&#xff0c;这是不仅一个刚刚踏入职场的初级程序员也是工作三五年之后开始迷茫…
阅读更多...
堆排序原理及其实现(C++)

堆排序原理及其实现(C++)

https://blog.csdn.net/lzuacm/article/details/52853194 堆排序原理及其实现(C) 1. 堆排序的引入 我们知道简单选择排序的时间复杂度为O(n^2)&#xff0c;熟悉各种排序算法的朋友都知道&#xff0c;这个时间复杂度是很大的&#xff0c;所以怎样减小简单选择排序的时间复杂度…
阅读更多...
Redis集群~StackExchange.redis连接Twemproxy代理服务器

Redis集群~StackExchange.redis连接Twemproxy代理服务器

本文是Redis集群系列的一篇文章&#xff0c;主要介绍使用StackExchange.Redis进行Twemproxy&#xff08;文中简称TW&#xff09;代理服务的连接过程&#xff0c;事务上&#xff0c;对于&#xff34;&#xff37;来说&#xff0c;我们需要理解一下它的物理架构&#xff0c;它类似…
阅读更多...
List集合转分页

List集合转分页

当所要查询的数据不能通过框架自带的分页和自定义分页实现的时候&#xff0c;一般查询出来的数据大多数情况都是list的形式。这就牵扯到把list集合转成分页&#xff0c;实现分页操作。   以下就是list转page的工具 /*** list转page进行手动分页* param list 要转的list集合*…
阅读更多...
内存转换Image到Icon

内存转换Image到Icon

转载自 内存转换Image到Icon 时候我们需要在内存中转换Image格式到Icon 根据经验&#xff0c;通常我们应该可以这样做 Image image xxxx;///假设这里已经有一个Image对象 System.IO.MemoryStream mStream new System.IO.MemoryStream();///创建内存流 image.Save(mStream,…
阅读更多...
同步异步

同步异步

https://blog.csdn.net/ideality_hunter/article/details/53453285 同步和异步&#xff0c;区别 2016年12月04日 11:20:17 阅读数&#xff1a;60233 同步&#xff1a; 同步的思想是&#xff1a;所有的操作都做完&#xff0c;才返回给用户。这样用户在线等待的时间太长&…
阅读更多...
不想穷下去就请看!

不想穷下去就请看!

不想穷下去就请看! 　　 　　 　　 1、记住&#xff0c;平均每天看电视超过三个小时以上的&#xff0c;一定都是那些月收入不超过两千元的&#xff0c;如果你想要月收入超过两千&#xff0c;请不要把时间浪费在电视上。同样的道理&#xff0c;那些平均每天玩网络游戏或聊天超过…
阅读更多...
.NET开发者如何使用MyCat

.NET开发者如何使用MyCat

背景 在开发中&#xff0c;我们设计的系统的效率在很大程度上会受到数据库引擎单表的性能制约&#xff0c;因此在数据量庞大、或记录过宽时&#xff0c;需要考虑分库分表从而减轻数据库压力&#xff0c;提升查询效率。此外配置读写分离&#xff0c;让主数据库处理事务性查询&am…
阅读更多...
关于Icon，Image，ImageIcon的简单的对比参考 上篇

关于Icon，Image，ImageIcon的简单的对比参考 上篇

转载自 关于Icon&#xff0c;Image&#xff0c;ImageIcon的简单的对比参考 上篇其实就算是现在&#xff0c;我还是有不少地方概念模糊&#xff0c;但是下面的内容是是没有什么问题的。稍微介绍一下&#xff0c;或许有些地方我无法解释&#xff1a; 大部分内容都是查的Java SE…
阅读更多...
移动端为什么拿不到本地运行的web工程数据

移动端为什么拿不到本地运行的web工程数据

原因很简单 连接的是远程服务器的tomcat啊啊啊啊啊
阅读更多...
道指mt4代码_剑指offer算法题052：正则表达式匹配

道指mt4代码_剑指offer算法题052：正则表达式匹配

小编在求职找找工作期间剑指offer上的算法题刷了很多遍&#xff0c;并且每道题小编当时都总结了一种最适合面试时手撕算法的最优解法。考虑到剑指offer算法题在面试中的高频出现&#xff0c;小编每天和大家分享一道剑指offer上的算法题&#xff0c;以及小编总结的答案。下面是第…
阅读更多...
.NET 程序集单元测试工具 SmokeTest 应用指南

.NET 程序集单元测试工具 SmokeTest 应用指南

Smoke Test(冒烟测试)&#xff0c;也称Regression Test(回归测试)&#xff0c;是对软件的安装和基本功能的测试。一般地我们使用脚本来实现Smoke Test的自动化&#xff0c;可借用虚拟机的snapshot机制来保证干净的环境来进行Smoke Test&#xff0c;然后将测试好的程序集成到Con…
阅读更多...
JavaFX将Node导出为图片

JavaFX将Node导出为图片

转载自 JavaFX将Node导出为图片在JavaFX中提供了一个很实用的功能。我们可以将任意节点截图导出。代码如下:WritableImage image mapCanvas.snapshot(new SnapshotParameters(), null); try { ImageIO.write(SwingFXUtils.fromFXImage(image, null), "png", fil…
阅读更多...
要么干，要么滚，千万别混

要么干，要么滚，千万别混

原文来自网络&#xff0c;侵删&#xff01; 公司里混日子的人&#xff0c;最终伤害的是自己&#xff01;你混日子&#xff0c;就是日子混你&#xff0c;你自己是输家。 无论为谁打工&#xff0c;要为自己学东西&#xff0c;客观上为公司创造价值。 收获与投入成正比&#xff0c…
阅读更多...
basemap安装_Python画地图逃不过的basemap「完全安装手册」 | 附下载

basemap安装_Python画地图逃不过的basemap「完全安装手册」 | 附下载

基础配置&#xff1a;Mac 2017 | Python3python虐我千百遍&#xff0c;我待python如初恋Python需要跳过的安装的坑太太太太多了!!!!!前段时间看《利用python进行数据分析》这本书&#xff0c;到可视化的部分&#xff0c;看着最后的例子地图挺酷炫的&#xff0c;跟着敲代码的过程…
阅读更多...
秋招--持续更新

秋招--持续更新

7月份 阿里 电话面试挂 高并发 多线程 8月16日 17:06 网易互娱一面跪 问题 树二叉树 堆排序 各种字符串处理
阅读更多...
String与InputStream相互转换

String与InputStream相互转换

转载自 String与InputStream相互转换1.String to InputStream String str "String与InputStream相互转换";InputStream in_nocode new ByteArrayInputStream(str.getBytes()); InputStream in_withcode new ByteArrayInputStream(str.getByt…
阅读更多...
spring data jpa是什么？

spring data jpa是什么？

spring data jpa是什么&#xff1f; 版权声明&#xff1a;本文为博主原创文章&#xff0c;未经博主允许不得转载。 https://blog.csdn.net/jewelry008/article/details/76359516 Spring Data JPA能干什么 在开始之前&#xff0c;先举个简单的例子. 一张表user有三个字段&…
阅读更多...
LINQ：进阶 - LINQ 标准查询操作概述

LINQ：进阶 - LINQ 标准查询操作概述

“标准查询运算符”是组成语言集成查询 (LINQ) 模式的方法。大多数这些方法都在序列上运行&#xff0c;其中的序列是一个对象&#xff0c;其类型实现了IEnumerable<T> 接口或 IQueryable<T> 接口。标准查询运算符提供了包括筛选、投影、聚合、排序等功能在内的查询…
阅读更多...
2020年日历电子版(打印版)_“温故知新”——2020年《故宫日历》（青少版）正式发布...

2020年日历电子版(打印版)_“温故知新”——2020年《故宫日历》（青少版）正式发布...

2020《故宫日历》(青少版)。供图2020《故宫日历》(青少版)。供图中新网北京10月28日电 (记者 冉文娟)由故宫出版社和新东方教育科技集团联合推出的2020年《故宫日历》(青少版)28日在故宫博物院正式发布。《故宫日历》是故宫博物院介绍故宫藏品、传播故宫文化的普及读物。此次故…
阅读更多...
最新文章

Copyright @ 2022~2023