由浅入深表达式树（完结篇）重磅打造 Linq To 博客园

2023-10-16 13:24:16

　　一个多月之后，由浅入深表达式系列的最后一篇终于要问世了。想对所有关注的朋友说声：“对不起，我来晚了！” 希望最后一篇的内容对得起这一个月时间的等待。在学习完表达式树的创建和遍历之后，我们要利用它的特性来写一个我们自己的Linq Provider。人家都有Linq to Amazon为什么我们不能有Linq to cnblogs呢？今天我们就来一步一步的打造自己的Linq Provider,文章未尾已附上源码下载地址。如果对于表达式树的创建和遍历还是熟悉的话，建议先看前面两篇：

　　创建表达式树
http://www.cnblogs.com/jesse2013/p/expressiontree-part1.html

　　遍历表达式树
　 http://www.cnblogs.com/jesse2013/p/expressiontree-part2.html

　　更新：之前没有描述清楚本篇博客的意图，导致很多朋友的误解表示抱歉。本系列重在理解表达式目录树，以及Linq Provider。最后一篇是Linq Provider的实现，之所有会写这么多的代码去做一件简单的事（拉取博客园首页文章列表）完全是为了有一个生动的例子去展示如何实现自己的Linq Provider。和我们项目中的三层架构，或者直接序列化到本地是没有可比性的。

　　当然，表达式目录树以及Linq Provider的强大也远非这个小小的Demo能体现得了的，如果你真正知道Linq Provider和表达式树目录树是什么，用来干什么的，也许你就能明白本篇博客的意图了。如果不了解的，建议读完前面两篇之后再做评论。因为你在自己不理解的情况下就直接去评论其它的领域，你就失去了一个了解它的机会。:)

实现目标

　　我们实现的目标就像Linq to SQL一样，可以用Linq查询语句来查询数据，我们这里面的数据用到了博客园官方的Service去查询到最新的发布到首页的博客信息。看下面的代码：

var 
provider = new 
CnblogsQueryProvider();

var 
queryable = new 
Query<Post>(provider);
 

var 
query =

    from 
p in 
queryable

    where 
p.Diggs >= 10 &&

    p.Comments > 10 &&

    p.Views > 10 &&

    p.Comments < 20

    select 
p;
 

var 
list = query.ToList();

　　作为实时访问远程的Service，我们还应该具体以下几点要求：

延迟加载，即到最后使用的时候才真正的去请求数据
只返回需要的数据，不能把所有的数据全下载过来再到本地过滤，那就没有意义了

最后实现的结果：

数据准备

　　根据博客园公开的API显示，获取首页文章列表非常容易，大家可以点下面的URL来体检一把。我们最后给的参数是100000，当然真实返回肯定是没有那么多的，我们是希望把能够取回来的都取回来。

　　http://wcf.open.cnblogs.com/blog/sitehome/recent/100000　

　　点击完上面的URL之后呢，问题就来了，它只有一个参数。我并不能传给它查询条件，比如说根据标题来搜索，或者根据评论数，浏览量来过滤。难道我的计划就此要泡汤了么，刚开始我很不开心，为什么博客园就不能提供灵活一点的Service呢？但是事实就是这样，咋是程序员呀，需求摆在这，怎么着还得实现是不？没有办法，我给它封装了一层。在它的基础上做了一个自己的Service。

封装博客园Service

　　我们如何在博客园公开Service的基础上加一层实现条件查询呢？主要思路是这样的：

为文章建立实体类（Post)
将博客园Service返回的数据解析成Post的集合，我们可以加上自己的缓存机制，可以采用1分钟才到博客园取一次数据
把我们上面创建的post集合当作数据库，建立查询Service

　　我们首先要做的就是为博客园的博客建立实体类。

public 
class 
Post
{

    // Id

    public 
int 
Id { get; set; }
 

    // 标题

    public 
string 
Title { get; set; }
 

    // 发布时间

    public 
DateTime Published { get; set; }
 

    // 推荐数据

    public 
int 
Diggs { get; set; }
 

    // 访问人数

    public 
int 
Views { get; set; }
 

    // 评论数据

    public 
int 
Comments { get; set; }
 

    // 作者

    public 
string 
Author { get; set; }
 

    // 博客链接

    public 
string 
Href { get; set; }
 

    // 摘要

    public 
string 
Summary { get; set; }
}

　　接着，我们要将博客园返回给我们的XML数据转换成我们要的post集合，所以我们要用到Linq to XML。

_list = new 
List<CnblogsLinqProvider.Post>();

var 
document = XDocument.Load(

    "http://wcf.open.cnblogs.com/blog/sitehome/recent/100000"

    );
 
var 
elements = document.Root.Elements();

var 
result = from 
entry in 
elements

                where 
entry.HasElements == true

                select 
new 
CnblogsLinqProvider.Post

                {

                    Id = Convert.ToInt32(entry.Elements()

                        .SingleOrDefault(x => x.Name.LocalName == "id").Value),
 
                    Title = entry.Elements()

                        .SingleOrDefault(x => x.Name.LocalName == "title").Value,
 
                    Published = Convert.ToDateTime(entry.Elements()

                        .SingleOrDefault(x => x.Name.LocalName == "published").Value),
 
                    Diggs = Convert.ToInt32(entry.Elements()

                        .SingleOrDefault(x => x.Name.LocalName == "diggs").Value),
 
                    Views = Convert.ToInt32(entry.Elements()

                        .SingleOrDefault(x => x.Name.LocalName == "views").Value),
 
                    Comments = Convert.ToInt32(entry.Elements()

                        .SingleOrDefault(x => x.Name.LocalName == "comments").Value),
 
                    Summary = entry.Elements()

                        .SingleOrDefault(x=>x.Name.LocalName=="summary").Value,
 
                    Href = entry.Elements()

                        .SingleOrDefault(x => x.Name.LocalName == "link")

                        .Attribute("href").Value,
 
                    Author = entry.Elements()

                        .SingleOrDefault(x => x.Name.LocalName == "author")

                        .Elements()

                        .SingleOrDefault(x => x.Name.LocalName == "name").Value

                };
 
_list.AddRange(result);

　　然后就到了我们的查询了，实际上我们有了IEnumrable<Post>的数据就可以直接在本地用Linq去查询它了。但是这不是我们想要的，因为我们上面的步骤是把所有的数据一次性全部下载下来了，而不是根据我们的需求返回数据。另外我们这里面是在博客园Service的基础上做一层封装，实现通过Url直接查询首页的文章。为什么要通过Url来查询？因为我们最后会通过我们自己的LinqProvider将Linq查询语句直接翻译成Url这样就能够实现远程的返回数据了。来看看我们对Url参数的定义：

标题中包括模式的文章：http://linqtocnblogs.cloudapp.net?Title=模式
访问人数大于5并且评论大于10的文章 http://linqtocnblogs.cloudapp.net?MinViews=5&MinComments=10

利用JsonResult 返回json数据来创建我们的Service

　　作为Service，我们返回Json或者XML格式的数据都是可以的。当然实现这个需求的方法有很多种，我们这里面有选了一种最简单方便又比较适合我们需求方式。不需要WCF Service也不需要Web API，直接用MVC里面的Action返回JsonResult就可以了。

[HttpGet]

public 
JsonResult Index(SearchCriteria criteria = null)
{

    var 
result = PostManager.Posts;

    if 
(criteria != null)

    {

        if 
(!string.IsNullOrEmpty(criteria.Title))

            result = result.Where(

                p => p.Title.IndexOf(criteria.Title, StringComparison.OrdinalIgnoreCase) >= 0);
 
        if 
(!string.IsNullOrEmpty(criteria.Author))

            result = result.Where(p => p.Author.IndexOf(criteria.Author, StringComparison.OrdinalIgnoreCase) >= 0);
 
        if 
(criteria.Start.HasValue)

            result = result.Where(p => p.Published >= criteria.Start.Value);
 
        if 
(criteria.End.HasValue)

            result = result.Where(p => p.Published <= criteria.End.Value);
 
        if 
(criteria.MinComments > 0)

            result = result.Where(p => p.Comments >= criteria.MinComments);
 
        if 
(criteria.MinDiggs > 0)

            result = result.Where(p => p.Diggs >= criteria.MinDiggs);
 
        if 
(criteria.MinViews > 0)

            result = result.Where(p => p.Diggs >= criteria.MinViews);
 
        if 
(criteria.MaxComments > 0)

            result = result.Where(p => p.Comments <= criteria.MaxComments);
 
        if 
(criteria.MaxDiggs > 0)

            result = result.Where(p => p.Diggs <= criteria.MaxDiggs);
 
        if 
(criteria.MaxViews > 0)

            result = result.Where(p => p.Diggs <= criteria.MaxViews);

    }

    return 
Json(result, JsonRequestBehavior.AllowGet);
}

　　利用Action来做这种Service还有一个好处就是我们不需要一个一个的声明查询参数，只需要把所有的参数放到一个model中就可以了。剩下的事就交给Model Binder吧。

public 
class 
SearchCriteria

   {

       public 
string 
Title { get; set; }

       public 
string 
Author { get; set; }

        

       public 
DateTime? Start { get; set; }

       public 
DateTime? End { get; set; }
 

       public 
int 
MinDiggs { get; set; }

       public 
int 
MaxDiggs { get; set; }

       public 
int 
MinViews { get; set; }

       public 
int 
MaxViews { get; set; }

       public 
int 
MinComments { get; set; }

       public 
int 
MaxComments { get; set; }

   }

　　如果大家想更熟悉这个Service的功能，可以参考上面的参数自己去体验一下(用IE会直接下载.json的文件，用Chrom是可以直接在浏览器里面看数据的)。但是我没有做任何安全性的措施，希望大侠高抬贵手，别把网站整挂了就行。

认识IQueryable和IQueryProvider接口

　　有了上面的Service之后，我们要做的事情就简单多了，但是在我们真正开始动手写自己的Linq Provider之前，先来看看IQueryable和IQueryProvider这两个重要的接口。

IQueryable

　　IQueryable本身并没有包含多少的东西，它只有三个属性：

ElementType 代表当然这个Query所对应的类型
Expression 包含了我们当然Query所执行的所有查询或者是其它的操作
IQueryProvider则是负责处理上面的Expression的实现

　　更为重要的是，在IQueryable这个接口之上，.net为我们提供了很多的扩展方法：

　　我们平常用到的Where,Select,Max,Any都包括在其中，具体的方法大家可以到System.Linq.Queryable这个静态类下去看。大家注意一下，传给Where方法的正是我们现在学习的Expression。

　在另外一个很重要的接口IEnumrable下，也有着同样的扩展方法：

　　这些扩展方法来自System.Linq.Enumrable这个静态类下。我们可以看到两组扩展方法的不同之处在于IQueryable下传入的Expression类型，而IEnumrable下传入的是委托。这样做的用意是什么呢？您请接着往下看。

IQueryProvider

　　我们上面讲到了Enumrable和Queryable这两个静态类下的扩展方法，对于Enumrable下的扩展方法来说他们传入的是委托，对于委托而言直接执行就可以了。

public 
static 
IEnumerable<T> Where<T>(this 
IEnumerable<T> list, Func<T, bool> predicate)
{

    var 
result = new 
List<T>();

    foreach 
(var 
element in 
list)

    { 

        // 调用委托是验证这个元素是否符合条件

        if(predicate(element))

            result.Add(element);

    }

    return 
result;
}

　　上面的代码给大家作一个参考，相信不难理解，所以Enumrable下的静态方法都是操作本地数据的。而对于Queryable下的静态方法而言，他们接收的是表达式，还记得表达式的最大特征吗？可以在运行时去遍历解释然后执行，那么这样就可以将表达式转换成各种其它的方式去获取数据，伟大的Linq to SQL就是这么实现的。而这背后的大功臣就是我们的Linq Provider了，而IQueryProvider就是LinqProvider的接口。

　　IQueryProvider只有两个操作，CreateQuery和Execute分别有泛型版本和非泛型版本。 CreatQuery用于构造一个IQueryable<T>的对象，这个类其实没有任何实现，只是继承了IQueryable和IEnumrable接口。主要用于计算指定表达式目录树所表示的查询，返回的结果是一个可枚举的类型。而Execute会执行指定表达式目录树所表示的查询，返回指定的结果。所有的内幕就在这个Execute方法里面，拿我们要进行的Linq to cnblogs方法来举例，我们将把传入的表达式目录树翻译成一个URL就是指向我们封装好的Service的URL，通过发起web request到这个URL，拿到response进行解析，最终得到我们所要的数据，这就是我们Linq to cnblogs的思路。

Linq to cnblogs的实现

　　有了前面的数据准备和一些实现的大致思路以后，我们就可以着手开始实现我们的CnblogsQueryProvider了。我们的思路大致是这样的：

实现自己的ExpressionVisitor类去访问表达式目录数，将其翻译成可以访问Service的Url
调用WebRequest去访问这个Url
将上面返回的Response解析成我们要的对象

实现PostExpressionVisitor

　　关于表达式树的访问，我们在第二篇中已经有了比较详细的介绍。如果对于表达式树的遍历不清楚的，可以去第二篇《遍历表达式》中查阅。在这里，我们创建一个我们自己的ExpressionVisitor类，去遍历表达式树。我们暂时只需要生成一个SearchCriteria(我们上面已经定义好了，对于查询条件建的模)对象即可。

  1 public class PostExpressionVisitor
  2 {
  3 private SearchCriteria _criteria;
  4 
  5 // 入口方法
  6 public SearchCriteria ProcessExpression(Expression expression)
  7 {
  8     _criteria = new SearchCriteria();
  9     VisitExpression(expression);
 10     return _criteria;
 11 }
 12 
 13 private void VisitExpression(Expression expression)
 14 {
 15     switch (expression.NodeType)
 16     { 
 17         // 访问 &&
 18         case ExpressionType.AndAlso:
 19             VisitAndAlso((BinaryExpression)expression);
 20             break;
 21         // 访问 等于
 22         case ExpressionType.Equal:
 23             VisitEqual((BinaryExpression)expression);
 24             break;
 25         // 访问 小于和小于等于
 26         case ExpressionType.LessThan:
 27         case ExpressionType.LessThanOrEqual:
 28             VisitLessThanOrEqual((BinaryExpression)expression);
 29             break;
 30         // 访问大于和大于等于
 31         case ExpressionType.GreaterThan:
 32         case ExpressionType.GreaterThanOrEqual:
 33             GreaterThanOrEqual((BinaryExpression)expression);
 34             break;
 35         // 访问调用方法，主要有于解析Contains方法，我们的Title会用到
 36         case ExpressionType.Call:
 37             VisitMethodCall((MethodCallExpression)expression);
 38             break;
 39         // 访问Lambda表达式
 40         case ExpressionType.Lambda:
 41             VisitExpression(((LambdaExpression)expression).Body);
 42             break;
 43     }
 44 }
 45 
 46 // 访问  &&
 47 private void VisitAndAlso(BinaryExpression andAlso)
 48 {
 49     VisitExpression(andAlso.Left);
 50     VisitExpression(andAlso.Right);
 51 }
 52 
 53 // 访问 等于
 54 private void VisitEqual(BinaryExpression expression)
 55 {
 56     // 我们这里面只处理在Author上的等于操作
 57     // Views, Comments, 和 Diggs 我们都是用的大于等于，或者小于等于
 58     if ((expression.Left.NodeType == ExpressionType.MemberAccess) &&
 59         (((MemberExpression)expression.Left).Member.Name == "Author"))
 60     {
 61         if (expression.Right.NodeType == ExpressionType.Constant)
 62             _criteria.Author = 
 63                 (String)((ConstantExpression)expression.Right).Value;
 64 
 65         else if (expression.Right.NodeType == ExpressionType.MemberAccess)
 66             _criteria.Author = 
 67                 (String)GetMemberValue((MemberExpression)expression.Right);
 68 
 69         else
 70             throw new NotSupportedException("Expression type not supported for author: " + 
 71                 expression.Right.NodeType.ToString());
 72     }
 73 }
 74 
 75 // 访问大于等于
 76 private void GreaterThanOrEqual(BinaryExpression expression)
 77 {
 78     // 处理 Diggs >= n  推荐人数
 79     if ((expression.Left.NodeType == ExpressionType.MemberAccess) &&
 80         (((MemberExpression)expression.Left).Member.Name == "Diggs"))
 81     {
 82         if (expression.Right.NodeType == ExpressionType.Constant)
 83             _criteria.MinDiggs = 
 84                 (int)((ConstantExpression)expression.Right).Value;
 85 
 86         else if (expression.Right.NodeType == ExpressionType.MemberAccess)
 87             _criteria.MinDiggs =
 88                 (int)GetMemberValue((MemberExpression)expression.Right);
 89 
 90         else
 91             throw new NotSupportedException("Expression type not supported for Diggs:"
 92                 + expression.Right.NodeType.ToString());
 93     }
 94     // 处理 Views>= n   访问人数
 95     else if ((expression.Left.NodeType == ExpressionType.MemberAccess) &&
 96     (((MemberExpression)expression.Left).Member.Name == "Views"))
 97     {
 98         if (expression.Right.NodeType == ExpressionType.Constant)
 99             _criteria.MinViews = 
100                 (int)((ConstantExpression)expression.Right).Value;
101 
102         else if (expression.Right.NodeType == ExpressionType.MemberAccess)
103             _criteria.MinViews =
104                 (int)GetMemberValue((MemberExpression)expression.Right);
105 
106         else
107             throw new NotSupportedException("Expression type not supported for Views: " 
108                 + expression.Right.NodeType.ToString());
109     }
110     // 处理 comments >= n   评论数
111     else if ((expression.Left.NodeType == ExpressionType.MemberAccess) &&
112     (((MemberExpression)expression.Left).Member.Name == "Comments"))
113     {
114         if (expression.Right.NodeType == ExpressionType.Constant)
115             _criteria.MinComments =
116                 (int)((ConstantExpression)expression.Right).Value;
117 
118         else if (expression.Right.NodeType == ExpressionType.MemberAccess)
119             _criteria.MinComments = 
120                 (int)GetMemberValue((MemberExpression)expression.Right);
121 
122         else
123             throw new NotSupportedException("Expression type not supported for Comments: "
124                 + expression.Right.NodeType.ToString());
125     }
126     // 处理 发布时间>=
127     else if ((expression.Left.NodeType == ExpressionType.MemberAccess) &&
128     (((MemberExpression)expression.Left).Member.Name == "Published"))
129     {
130         if (expression.Right.NodeType == ExpressionType.Constant)
131             _criteria.Start = 
132                 (DateTime)((ConstantExpression)expression.Right).Value;
133 
134         else if (expression.Right.NodeType == ExpressionType.MemberAccess)
135             _criteria.Start = 
136                 (DateTime)GetMemberValue((MemberExpression)expression.Right);
137 
138         else
139             throw new NotSupportedException("Expression type not supported for Published: " 
140                 + expression.Right.NodeType.ToString());
141     }
142 }
143 
144 // 访问 小于和小于等于
145 private void VisitLessThanOrEqual(BinaryExpression expression)
146 {
147     // 处理 Diggs <= n  推荐人数
148     if ((expression.Left.NodeType == ExpressionType.MemberAccess) &&
149         (((MemberExpression)expression.Left).Member.Name == "Diggs"))
150     {
151         if (expression.Right.NodeType == ExpressionType.Constant)
152             _criteria.MaxDiggs =
153                 (int)((ConstantExpression)expression.Right).Value;
154 
155         else if (expression.Right.NodeType == ExpressionType.MemberAccess)
156             _criteria.MaxDiggs =
157                 (int)GetMemberValue((MemberExpression)expression.Right);
158 
159         else
160             throw new NotSupportedException("Expression type not supported for Diggs: " 
161                 + expression.Right.NodeType.ToString());
162     }
163     // 处理 Views<= n   访问人数
164     else if ((expression.Left.NodeType == ExpressionType.MemberAccess) &&
165     (((MemberExpression)expression.Left).Member.Name == "Views"))
166     {
167         if (expression.Right.NodeType == ExpressionType.Constant)
168             _criteria.MaxViews = 
169                 (int)((ConstantExpression)expression.Right).Value;
170 
171         else if (expression.Right.NodeType == ExpressionType.MemberAccess)
172             _criteria.MaxViews =
173                 (int)GetMemberValue((MemberExpression)expression.Right);
174 
175         else
176             throw new NotSupportedException("Expression type not supported for Views: " 
177                 + expression.Right.NodeType.ToString());
178     }
179     // 处理 comments <= n   评论数
180     else if ((expression.Left.NodeType == ExpressionType.MemberAccess) &&
181     (((MemberExpression)expression.Left).Member.Name == "Comments"))
182     {
183         if (expression.Right.NodeType == ExpressionType.Constant)
184             _criteria.MaxComments =
185                 (int)((ConstantExpression)expression.Right).Value;
186 
187         else if (expression.Right.NodeType == ExpressionType.MemberAccess)
188             _criteria.MaxComments = 
189                 (int)GetMemberValue((MemberExpression)expression.Right);
190 
191         else
192             throw new NotSupportedException("Expression type not supported for Comments: "
193                 + expression.Right.NodeType.ToString());
194     }
195 
196         // 处理发布时间 <= 
197     else if ((expression.Left.NodeType == ExpressionType.MemberAccess) &&
198     (((MemberExpression)expression.Left).Member.Name == "Published"))
199     {
200         if (expression.Right.NodeType == ExpressionType.Constant)
201             _criteria.End = 
202                 (DateTime)((ConstantExpression)expression.Right).Value;
203 
204         else if (expression.Right.NodeType == ExpressionType.MemberAccess)
205             _criteria.End =
206                 (DateTime)GetMemberValue((MemberExpression)expression.Right);
207 
208         else
209             throw new NotSupportedException("Expression type not supported for Published: " 
210                 + expression.Right.NodeType.ToString());
211     }
212 }
213 
214 // 访问 方法调用
215 private void VisitMethodCall(MethodCallExpression expression)
216 {
217     if ((expression.Method.DeclaringType == typeof(Queryable)) &&
218         (expression.Method.Name == "Where"))
219     {
220         VisitExpression(((UnaryExpression)expression.Arguments[1]).Operand);
221     }
222     else if ((expression.Method.DeclaringType == typeof(String)) &&
223         (expression.Method.Name == "Contains"))
224     {
225         // Handle Title.Contains("")
226         if (expression.Object.NodeType == ExpressionType.MemberAccess)
227         {
228             MemberExpression memberExpr = (MemberExpression)expression.Object;
229             if (memberExpr.Expression.Type == typeof(Post))
230             {
231                 if (memberExpr.Member.Name == "Title")
232                 {
233                     Expression argument;
234                     argument = expression.Arguments[0];
235                     if (argument.NodeType == ExpressionType.Constant)
236                     {
237                         _criteria.Title = 
238                             (String)((ConstantExpression)argument).Value;
239                     }
240                     else if (argument.NodeType == ExpressionType.MemberAccess)
241                     {
242                         _criteria.Title = 
243                             (String)GetMemberValue((MemberExpression)argument);
244                     }
245                     else
246                     {
247                         throw new NotSupportedException("Expression type not supported: " 
248                             + argument.NodeType.ToString());
249                     }
250                 }
251             }
252         }
253     }
254     else
255     {
256         throw new NotSupportedException("Method not supported: "
257             + expression.Method.Name);
258     }
259 }
260 
261 // 获取属性值
262 private Object GetMemberValue(MemberExpression memberExpression)
263 {
264     MemberInfo memberInfo;
265     Object obj;
266 
267     if (memberExpression == null)
268         throw new ArgumentNullException("memberExpression");
269 
270 
271     if (memberExpression.Expression is ConstantExpression)
272         obj = ((ConstantExpression)memberExpression.Expression).Value;
273     else if (memberExpression.Expression is MemberExpression)
274         obj = GetMemberValue((MemberExpression)memberExpression.Expression);
275     else
276         throw new NotSupportedException("Expression type not supported: "
277             + memberExpression.Expression.GetType().FullName);
278 
279     memberInfo = memberExpression.Member;
280     if (memberInfo is PropertyInfo)
281     {
282         PropertyInfo property = (PropertyInfo)memberInfo;
283         return property.GetValue(obj, null);
284     }
285     else if (memberInfo is FieldInfo)
286     {
287         FieldInfo field = (FieldInfo)memberInfo;
288         return field.GetValue(obj);
289     }
290     else
291     {
292         throw new NotSupportedException("MemberInfo type not supported: " 
293             + memberInfo.GetType().FullName);
294     }
295 }
296 }

View Code

实现CnblogsQueryProvider

　　有了上面的访问类之后，我们的CnblogsQueryProvider就非常简单了。

 1 public class CnblogsQueryProvider:QueryProvider
 2 {
 3     public override String GetQueryText(Expression expression)
 4     {
 5         SearchCriteria criteria;
 6 
 7         // 翻译查询条件
 8         criteria = new PostExpressionVisitor().ProcessExpression(expression);
 9 
10         // 生成URL
11         String url = PostHelper.BuildUrl(criteria);
12 
13         return url;
14     }
15 
16     public override object Execute(Expression expression)
17     {
18         String url = GetQueryText(expression);
19         IEnumerable<Post> results = PostHelper.PerformWebQuery(url);
20         return results;
21     }
22 }

View Code

　　我们里面只覆盖了基类的两个方法，GetQueryText和Execute。

GetQueryText根据访问类得到的SearchCriteria去和成访问Service的Url
Execute访问则负责去请求这个Url拿到数据返回即可

PostHelper请求数据

　　我们这里面有一个帮助类PostHelper，就负责了根据criteria生成Url以及请求Url获取数据的功能。

 1 static internal string BuildUrl(SearchCriteria criteria,string url=null)
 2 {
 3     if (criteria == null)
 4         throw new ArgumentNullException("criteria");
 5 
 6     var sbUrl = new StringBuilder(url ?? "http://linqtocnblogs.cloudapp.net/");
 7     var sbParameter = new StringBuilder();
 8 
 9     if (!String.IsNullOrEmpty(criteria.Title))
10         AppendParameter(sbParameter, "Title", criteria.Title);
11                 
12     if (!String.IsNullOrEmpty(criteria.Author))
13         AppendParameter(sbParameter, "Author", criteria.Author);
14 
15     if (criteria.Start.HasValue)
16         AppendParameter(sbParameter, "Start", criteria.Start.Value.ToString());
17 
18     if (criteria.End.HasValue)
19         AppendParameter(sbParameter, "End", criteria.End.Value.ToString());
20 
21     if (criteria.MinDiggs > 0)
22         AppendParameter(sbParameter, "MinDiggs", criteria.MinDiggs.ToString());
23 
24     if (criteria.MinViews > 0)
25         AppendParameter(sbParameter, "MinViews", criteria.MinViews.ToString());
26 
27     if (criteria.MinComments> 0)
28         AppendParameter(sbParameter, "MinComments",
29             criteria.MinComments.ToString());
30 
31     if (criteria.MaxDiggs > 0)
32         AppendParameter(sbParameter, "MaxDiggs", criteria.MaxDiggs.ToString());
33 
34     if (criteria.MaxViews > 0)
35         AppendParameter(sbParameter, "MaxViews", criteria.MaxViews.ToString());
36 
37     if (criteria.MaxComments > 0)
38         AppendParameter(sbParameter, "MaxComments",
39             criteria.MaxComments.ToString());
40 
41     if (sbParameter.Length > 0)
42         sbUrl.AppendFormat("?{0}", sbParameter.ToString());
43 
44     return sbUrl.ToString();
45 }
46 
47 static internal void AppendParameter(StringBuilder sb,string name,string value)
48 {
49     if (sb.Length > 0)
50         sb.Append("&");
51 
52     sb.AppendFormat("{0}={1}",name,value);
53 }
54 
55 static internal IEnumerable<Post> PerformWebQuery(string url)
56 {
57     var request = WebRequest.Create(url);
58     request.Credentials = CredentialCache.DefaultCredentials;
59 
60     var response = (HttpWebResponse)request.GetResponse();
61     using(var reader= new StreamReader(response.GetResponseStream()))
62     {
63         var body = reader.ReadToEnd();
64         return JsonConvert.DeserializeObject<List<Post>>(body);
65     }
66 }
67 }

View Code

　　因为我们的Service是返回的Json数据，所以这里，我们借助了Json.Net将其转成我们所要的List<Post>的数据。

　　就是这么简单，我们的Linq to cnblogs就大功告成了。

　点击这里下载源码：http://pan.baidu.com/s/1gd85l1T

由浅入深表达式树（完结篇）重磅打造 Linq To 博客园

码农公寓

目录

实现目标

数据准备

封装博客园Service

利用JsonResult 返回json数据来创建我们的Service

认识IQueryable和IQueryProvider接口

IQueryable

IQueryProvider

Linq to cnblogs的实现

实现PostExpressionVisitor

实现CnblogsQueryProvider

PostHelper请求数据

相关文章