动态创建Lambda表达式实现高级查询

时间:2023-03-08 16:12:21

需求简介

最近这几天做的东西总算是回归咱的老本行了,给投资管理项目做一个台账的东西,就是类似我们的报表。其

中有一个功能是一个高级查询的需求,在查询条件方面大概有7、8个查询条件。需求就是如果一个条件都不输入就默

认查询全部的数据,那个条件不为空的时候就在查询条件上面添加对响应字段的限制,也就是说我们在写查询条件的

时候不能写死,因为我们不知道我们到底有几个条件?到底有几个条件。所以需要我们动态的创建Lambd表达式。看

了看他们相似的功能,在实现的时候用的动态拼接SQL语句,那些SQL代码啊?看到都头疼,所以我直接放弃了,用咱

自己熟悉的知识来实现。和这个相似的功能自己在之前的《图书馆项目》中实现过,请点击我

具体实现—小Demo

首先需要引入命名空间

using System.Linq.Expressions.Expression;

  1. //创建一个数组用来当做例子
  2. var ints = new int []{ 1, 2 , 3 , 4 , 5 , 6 };
  3. // 要创建形如 i => i < 5
  4. //创建参数 i
  5. var parameter  = Expression.Parameter(typeof(int),”i”);
  6. //创建常数 5
  7. var constant = Expression.Constant(5);
  8. //创建 i > 5
  9. var bin = Expression.GreaterThan(parameter,constant);
  10. //获取Lambda表达式
  11. var lambda=Expression.Lambda<Func<Int32,Boolean>>(bin,parameter);
  12. //取得查询结果
  13. var query = ints.Where(lambda.Compile());

通过上面一个小Demo我们可以简单的看到动态创建Lambda表达式的雏形,下面在介绍一个比较复杂的例子。

  1. BinaryExpression condition = null;
  2. //要构造的表达式i==1||i==2||i==3.....
  3. for (int i = 0; i < ints.Length; i++)
  4. {
  5. ConstantExpression ce = Expression.Constant(i);
  6. if (condition == null)
  7. {
  8. condition = Expression.Equal(parameter, ce);
  9. }
  10. else
  11. {
  12. var right = Expression.Equal(parameter, ce);
  13. condition = Expression.Or(condition, right);
  14. }
  15. }
  16. Expression<Func<Int32, Boolean>> lambda = Expression.Lambda<Func<Int32, Boolean>>(condition, parameter);

实体类的实现

上面都是比较简单的小例子,但是在我们项目中都是来对实体进行条件查询的,所以呢小编在下面会给大家介

绍一下如何对实体类进行构造。

  1. //p => p.Name == "1" && p.Address == "2"
  2. ParameterExpression parameter1 = Expression.Parameter(typeof(Person), "p");
  3. MemberExpression member1 = Expression.PropertyOrField(parameter1, "Name");
  4. MemberExpression member2 =  Expression.PropertyOrField(parameter1, "Address"),
  5. ConstantExpression constant1 = Expression.Constant("郑浩");
  6. ConstantExpression constant2 = Expression.Constant("河北");
  7. var query1 = Expression.Equal(member1, constant1);//Equal等于;GreaterThanOrEqual大于;LessThanOrEqual小于
  8. var query2 = Expression.Equal(member2, constant2);
  9. var query = Expression.And(query1, query2);//and 与;or或
  10. var lambda1 = Expression.Lambda<Func<Person, Boolean>>(query, parameter1);
  11. var list = MethodExtend.GetUser(lambda1.Compile());

代码介绍:

1)创建表达式的开始部分:p=>

2、3)创建我们要查询的字段:p.Name和p.Address

4、5)给给变量赋值,这些值和变量可以任意匹配

6、7)匹配查询条件和对应的值:p.Name=="郑浩";p.Address=="河北"

8、9)连接查询条件;p.Name=="郑浩"&&p.Address=="河北"

10)创建最后的查询条件:p=>p.Name=="郑浩"&&p.Address=="河北"

11)最后执行查询条件

项目实战

我首先创建了一个接口,因为这个功能不是我自己使用,还有别的模块也需要这个功能;

  1. namespace Seagull2.Investment.WebApi
  2. {
  3. /// <summary>
  4. /// 可实现表达式接口
  5. /// </summary>
  6. public interface IExpressionable<T> where T : class
  7. {
  8. /// <summary>
  9. /// 创建表达式
  10. /// </summary>
  11. /// <returns></returns>
  12. Expression<Func<T, bool>> CreateExpression();
  13. }
  14. }

我将创建Landa表达式的部分放在module中,这个module是和界面对应,接收界面传递参数,代码如下:

  1. public class RealEstateProjectCondition : IExpressionable<View_RealEstateProject>
  2. {
  3. /// <summary>
  4. /// 项目所在省份
  5. /// </summary>
  6. public string ProjectOfProvince { get; set; }
  7. /// <summary>
  8. /// 项目所在城市
  9. /// </summary>
  10. public string ProjectOfCity { get; set; }
  11. /// <summary>
  12. /// 项目业态名称
  13. /// </summary>
  14. public string ProjectFormatName { get; set; }
  15. /// <summary>
  16. /// 所属业务团队
  17. /// </summary>
  18. public string BusiGroup { get; set; }
  19. /// <summary>
  20. /// 项目所处阶段
  21. /// </summary>
  22. public string PrjStageCode { get; set; }
  23. /// <summary>
  24. /// 申请起始日期
  25. /// </summary>
  26. public DateTimeOffset? ApplyStartDate { get; set; }
  27. /// <summary>
  28. /// 申请起始日期
  29. /// </summary>
  30. public DateTimeOffset? ApplyEndDate { get; set; }
  31. /// <summary>
  32. /// 基金规模(亿元)上线
  33. /// </summary>
  34. public decimal? StartFundSize { get; set; }
  35. /// <summary>
  36. /// 基金规模(亿元)下线
  37. /// </summary>
  38. public decimal? EndFundSize { get; set; }
  39. /// <summary>
  40. /// 创建房地产投资查询条件表达式
  41. /// </summary>
  42. /// <returns></returns>
  43. public Expression<Func<View_RealEstateProject, bool>> CreateExpression()
  44. {
  45. ParameterExpression parameter = Expression.Parameter(typeof(View_RealEstateProject), "p");
  46. //项目类型编码
  47. ConstantExpression constantPrjTypeCode = Expression.Constant("A0BE01A2-1BE3-4AAE-8DE3-B84BB6B2A58A");
  48. MemberExpression memberPrjTypeCode = Expression.PropertyOrField(parameter, "PrjTypeCode");
  49. var query = Expression.Equal(memberPrjTypeCode, constantPrjTypeCode);
  50. //项目所在省份
  51. if (!string.IsNullOrEmpty(this.ProjectOfProvince))
  52. {
  53. ConstantExpression constantProjectOfProvince = Expression.Constant(this.ProjectOfProvince);
  54. MemberExpression memberProjectOfCity = Expression.PropertyOrField(parameter, "ProjectOfProvince");
  55. query = Expression.And(query, Expression.Equal(memberProjectOfCity, constantProjectOfProvince));
  56. }
  57. //项目所在城市
  58. if (!string.IsNullOrEmpty(this.ProjectOfCity))
  59. {
  60. ConstantExpression constantProjectOfCity = Expression.Constant(this.ProjectOfCity);
  61. MemberExpression memberProjectOfCity = Expression.PropertyOrField(parameter, "ProjectOfCity");
  62. query = Expression.And(query, Expression.Equal(memberProjectOfCity, constantProjectOfCity));
  63. }
  64. //项目业态名称
  65. if (!string.IsNullOrEmpty(this.ProjectFormatName))
  66. {
  67. ConstantExpression constantProjectFormatName = Expression.Constant(this.ProjectFormatName);
  68. MemberExpression memberProjectFormatName = Expression.PropertyOrField(parameter, "ProjectFormatName");
  69. query = Expression.And(query, Expression.Equal(memberProjectFormatName, constantProjectFormatName));
  70. }
  71. //所属业务团队
  72. if (!string.IsNullOrEmpty(this.BusiGroup))
  73. {
  74. ConstantExpression constantBusiGroup = Expression.Constant(this.BusiGroup);
  75. MemberExpression memberBusiGroup = Expression.PropertyOrField(parameter, "BusiGroup");
  76. query = Expression.And(query, Expression.Equal(memberBusiGroup, constantBusiGroup));
  77. }
  78. //项目所处阶段
  79. if (!string.IsNullOrEmpty(this.PrjStageCode))
  80. {
  81. ConstantExpression constantPrjStageCode = Expression.Constant(this.PrjStageCode);
  82. MemberExpression memberPrjStageCode = Expression.PropertyOrField(parameter, "PrjStageCode");
  83. query = Expression.And(query, Expression.Equal(memberPrjStageCode, constantPrjStageCode));
  84. }
  85. //申请开始时间
  86. if (this.ApplyStartDate.HasValue)
  87. {
  88. ConstantExpression constantApplyStartDate = Expression.Constant(this.ApplyStartDate.Value);
  89. MemberExpression memberApplyStartDate = Expression.PropertyOrField(parameter, "ApplyDate");
  90. query = Expression.And(query, Expression.GreaterThanOrEqual(memberApplyStartDate, constantApplyStartDate));
  91. }
  92. //申请结束时间
  93. if (this.ApplyEndDate.HasValue)
  94. {
  95. ConstantExpression constantApplyEndDate = Expression.Constant(this.ApplyEndDate.Value);
  96. MemberExpression memberApplyEndDate = Expression.PropertyOrField(parameter, "ApplyDate");
  97. query = Expression.And(query, Expression.LessThanOrEqual(memberApplyEndDate, constantApplyEndDate));
  98. }
  99. //投资规模(亿元)上线
  100. if (this.StartFundSize.HasValue)
  101. {
  102. ConstantExpression constantStartFundSize = Expression.Constant(this.StartFundSize.Value);
  103. MemberExpression memberStartFundSize = Expression.PropertyOrField(parameter, "FundSize");
  104. query = Expression.And(query, Expression.GreaterThanOrEqual(memberStartFundSize, constantStartFundSize));
  105. }
  106. //投资规模(亿元)下线
  107. if (this.EndFundSize.HasValue)
  108. {
  109. ConstantExpression constantEndFundSize = Expression.Constant(this.EndFundSize.Value);
  110. MemberExpression memberEndFundSize = Expression.PropertyOrField(parameter, "FundSize");
  111. query = Expression.And(query, Expression.LessThanOrEqual(memberEndFundSize, constantEndFundSize));
  112. }
  113. //版本结束时间
  114. ConstantExpression constantVesionEndTime = Expression.Constant(null);
  115. MemberExpression memberVesionEndTime = Expression.PropertyOrField(parameter, "VersionEndTime");
  116. query = Expression.And(query, Expression.Equal(memberVesionEndTime, constantVesionEndTime));
  117. //有效性
  118. ConstantExpression constantValidStatus = Expression.Constant(true);
  119. MemberExpression memberValidStatus = Expression.PropertyOrField(parameter, "ValidStatus");
  120. query = Expression.And(query, Expression.Equal(memberValidStatus, constantValidStatus));
  121. return Expression.Lambda<Func<View_RealEstateProject, bool>>(query, parameter);
  122. }
  123. }

这样我们的controller和service都非常的简单明了,把查询条件作为实体的一部分。

service代码:

  1. public List<View_RealEstateProject> LoadView_RealEstateProject(RealEstateProjectCondition condition)
  2. {
  3. using (var db = new InvestmentDbContext())
  4. {
  5. return db.View_RealEstateProject.Where(condition.CreateExpression()).ToList();
  6. }
  7. }

controller代码:

  1. [HttpPost, HttpGet]
  2. public IHttpActionResult LoadQueryResult(RealEstateProjectCondition condition)
  3. {
  4. return Json(_realEstabDasbordService.LoadView_RealEstateProject(condition));
  5. }

小结

关于动态创建Lamda表达式就给大家介绍到这,通过动态创建表达式非常方便实现高级查询,和拼接sql来说这

还是非常简单的,并且出错的几率大大降低,所以我没有采用他们类似功能的实现,所以说我们在实现某些需求的时

候需要我们好好考虑在下手写代码,能参考的东西不一定是最合适的,还需要我们自己探索一些,希望给大家带来帮

助。

http://blog.csdn.net/hao134838/article/details/51404151