Linq to Sql : 动态构造Expression进行动态查询

简介:

    前一篇在介绍动态查询时,提到一个问题:如何根据用户的输入条件,动态构造这个过滤条件表达式呢?
Expression<Func<ProductExt, bool>> predicate t => t.ProductName.Contains("che") && t.UnitPrice >= 22;

    理想情况下,我希望可以像下面这样来构造predicate,这样,我们就可以使用&、| 、&=、|=来任意拼接过滤条件了:

   1: Expression<Func<ProductExt, bool>> predicate = null;
   2: predicate &= (t => t.ProductName.Contains("che")) | (t => t.UnitPrice >= 22);

    但是理想与现实之间,似乎总有不可逾越的鸿沟……

 

    前面的代码中,我们总是要写一常串Expression<Func<T, bool>>,写得都有点儿烦了,我妄想自定义一个类型,这样就不用每次都写这么长了,然后再针对这个自定义类型再进行运算符重载……然后我发现,Expression<Delegate>是密封类型(sealed),不给重载,没办法,只好老老实实的写,运算符重载也泡汤了。

 

   无奈之下,只好实现了下面的这种方式,勉强凑合用着:

   1: Expression<Func<ProductExt, bool>> predicate = null;
   2: predicate = predicate.AndAlso(p => p.CompanyName.Length > 2)
   3:      .OrElse((Products p) => p.ProductName.Contains("che"))
   4:      .AndAlso((Products p) => p.UnitPrice >= 22);

    运算得到的结果如下:p => (((p.CompanyName.Length > 2) || p.ProductName.Contains("che")) && (p.UnitPrice >= 22))

    有了这个OrElse和AndAlso扩展,我们就可以对Expression<Func<T, bool>>为所欲为了……

    不过跟之前文章中提到的一样,这里有个限制:虽然我们的Expression中,第一个可以凡泛型参数可以传任意值(譬如传ProductExt或Products或其他的,可以不必要求是同一种类型),但条件中用到的对象属性(譬如CompanyName、ProductName、UnitPrice ),必须在T中存在同名属性。

 

 2010-12-31更新:

 更新了ParameterConverter类,之前对二元运算符的右侧和方法参数直接求值的,所以不能处理Expression中含有&& 和 || 等二元运算符、及方法参数中包含Expression参数(例如list.Contains(p.CompanyName))的情况;现在增加了参数访问计数,如果二元表达式&&和||、及方法的参数中不包含Expression参数,则进行求值,否则不求值。代码如下:

复制代码
 1       public   class  ParameterConverter : ExpressionVisitor
 2      {
 3           protected  LambdaExpression SourceExpression {  get set ; }
 4           protected  ParameterExpression Parameter {  get set ; }
 5           protected   bool  UseOuterParameter  =   false ;
 6 
 7           public  ParameterConverter(LambdaExpression expression)
 8          {
 9               this .SourceExpression  =  (LambdaExpression)expression;
10          }
11 
12           public  ParameterConverter(LambdaExpression expression, ParameterExpression parameter) :  this (expression)
13          {
14               this .Parameter  =  parameter;
15               this .UseOuterParameter  =   true ;
16          }
17 
18           public  LambdaExpression Replace(Type targetType)
19          {
20               if  ( this .SourceExpression  ==   null )
21                   return   null ;
22 
23               if  ( ! this .UseOuterParameter)
24                   this .Parameter  =  Expression.Parameter(targetType,  this .SourceExpression.Parameters[ 0 ].Name);
25 
26              Expression body  =   this .Visit( this .SourceExpression.Body);
27               this .SourceExpression  =  Expression.Lambda(body,  this .Parameter);
28               return   this .SourceExpression;
29          }
30 
31           protected   override  Expression VisitParameter(ParameterExpression p)
32          {
33               return   this .Parameter;
34          }
35 
36           protected   override  Expression VisitMemberAccess(MemberExpression m)
37          {
38              Expression exp  =   this .Visit(m.Expression);
39              PropertyInfo propertyInfo  =  m.Member  as  PropertyInfo;
40               return  propertyInfo  ==   null   ?  m : Expression.Property(exp, propertyInfo.Name);
41          }
42 
43           protected   override  Expression VisitBinary(BinaryExpression b)
44          {
45              Expression left  =   this .Visit(b.Left);
46              Expression right  =  Calc(b.Right); // 对二元运算符右边的表达式进行求值
47              Expression conversion  =   this .Visit(b.Conversion);
48               if  (b.NodeType  ==  ExpressionType.Coalesce  &&  b.Conversion  !=   null )
49                   return  Expression.Coalesce(left, right, conversion  as  LambdaExpression);
50               else
51                   return  Expression.MakeBinary(b.NodeType, left, right, b.IsLiftedToNull, b.Method);
52          }
53 
54           protected   override  ReadOnlyCollection < Expression >  VisitExpressionList(
55                  ReadOnlyCollection < Expression >  original)
56          {
57               if  (original  ==   null   ||  original.Count  ==   0 )
58                   return  original;
59 
60               // 对参数进行求值运算
61              List < Expression >  list  =   new  List < Expression > ();
62               for  ( int  i  =   0 , n  =  original.Count; i  <  n; i ++ )
63              {
64                  list.Add(Calc(original[i]));  // 对调用函数的输入参数进行求值
65              }
66               return  list.AsReadOnly();
67          }
68 
69           private   static  Expression Calc(Expression e)
70          {
71              LambdaExpression lambda  =  Expression.Lambda(e);
72               return  Expression.Constant(lambda.Compile().DynamicInvoke( null ), e.Type);
73          }
74      }
复制代码


 

  最后,上代码:LinqToSqlExtension

 博客园的文件貌似有缓存,删掉重新上传,总是覆盖不了,只好单独上传了 ParameterConverter.rar


本文转自Silent Void博客园博客,原文链接:http://www.cnblogs.com/happyhippy/archive/2010/01/28/1658410.html,如需转载请自行联系原作者

相关文章
|
14天前
|
SQL NoSQL Java
Java使用sql查询mongodb
通过使用 MongoDB Connector for BI 和 JDBC,开发者可以在 Java 中使用 SQL 语法查询 MongoDB 数据库。这种方法对于熟悉 SQL 的团队非常有帮助,能够快速实现对 MongoDB 数据的操作。同时,也需要注意到这种方法的性能和功能限制,根据具体应用场景进行选择和优化。
49 9
|
1月前
|
SQL 存储 人工智能
Vanna:开源 AI 检索生成框架,自动生成精确的 SQL 查询
Vanna 是一个开源的 Python RAG(Retrieval-Augmented Generation)框架,能够基于大型语言模型(LLMs)为数据库生成精确的 SQL 查询。Vanna 支持多种 LLMs、向量数据库和 SQL 数据库,提供高准确性查询,同时确保数据库内容安全私密,不外泄。
126 7
Vanna:开源 AI 检索生成框架,自动生成精确的 SQL 查询
|
2月前
|
SQL Java
使用java在未知表字段情况下通过sql查询信息
使用java在未知表字段情况下通过sql查询信息
42 8
|
2月前
|
SQL 安全 PHP
PHP开发中防止SQL注入的方法,包括使用参数化查询、对用户输入进行过滤和验证、使用安全的框架和库等,旨在帮助开发者有效应对SQL注入这一常见安全威胁,保障应用安全
本文深入探讨了PHP开发中防止SQL注入的方法,包括使用参数化查询、对用户输入进行过滤和验证、使用安全的框架和库等,旨在帮助开发者有效应对SQL注入这一常见安全威胁,保障应用安全。
69 4
|
2月前
|
SQL 监控 关系型数据库
SQL语句当前及历史信息查询-performance schema的使用
本文介绍了如何使用MySQL的Performance Schema来获取SQL语句的当前和历史执行信息。Performance Schema默认在MySQL 8.0中启用,可以通过查询相关表来获取详细的SQL执行信息,包括当前执行的SQL、历史执行记录和统计汇总信息,从而快速定位和解决性能瓶颈。
|
2月前
|
SQL 存储 缓存
如何优化SQL查询性能?
【10月更文挑战第28天】如何优化SQL查询性能?
184 10
|
2月前
|
SQL 关系型数据库 MySQL
|
3月前
|
SQL 数据库 开发者
功能发布-自定义SQL查询
本期主要为大家介绍ClkLog九月上线的新功能-自定义SQL查询。
|
3月前
|
SQL 移动开发 Oracle
SQL语句实现查询连续六天数据的方法与技巧
在数据库查询中,有时需要筛选出符合特定时间连续性条件的数据记录
|
3月前
|
SQL Java 数据库连接
如何使用`DriverManager.getConnection()`连接数据库,并利用`PreparedStatement`执行参数化查询,有效防止SQL注入。
【10月更文挑战第6天】在代码与逻辑交织的世界中,我从一名数据库新手出发,通过不断探索与实践,最终成为熟练掌握JDBC的开发者。这段旅程充满挑战与惊喜,从建立数据库连接到执行SQL语句,再到理解事务管理和批处理等高级功能,每一步都让我对JDBC有了更深的认识。示例代码展示了如何使用`DriverManager.getConnection()`连接数据库,并利用`PreparedStatement`执行参数化查询,有效防止SQL注入。
154 5