Thinking In Design Pattern——Query Object模式

  • 什么是Query Object模式

  • Query Object的架构设计

  • Query Object在服务层的应用

  • 测试

Query Object模式

Query Object：可以在领域服务层构造查询然后传给资源库使用，并使用某种查询翻译器将对象查询（Query）翻译成底层数据库持久化框架可以理解的查询（即翻译成一条Sql 语句）。而Query Object即可以理解为表示数据库查询的对象。且可以构造任意查询，然后传给Repository。Query Object模式的主要好处是它完全将底层的数据库查询语言抽象出来。

如果没有某种查询机制，我们的持久化层可能会这样定义方法：

    public interface IOrderRepository{IEnumerable<Order> FindAll(Query query);IEnumerable<Order> FindAllVipCustomer();IEnumerable<Order> FindOrderBy(Guid customerId);IEnumerable<Order> FindAllCustomersWithOutOrderId();}

很明显，可以看出持久化层很不简洁，Repository将充满大量检索方法，而我们希望我们的持久化层尽量简洁些，根据传入参数能够动态的翻译成数据库查询语言，就像下面写的这样：

public interface IOrderRepository{       IEnumerable<Order> FindBy(Query query);IEnumerable<Order> FindBy(Query query, int index, int count);         }

这个Query就是核心——一个表示数据库查询的对象，好处是显而易见的：完全将底层的数据库查询语言抽象出来，因此将数据持久化和检索的基础设施关注点从业务层中分离出来。

Query Object模式的架构

  • 添加一个枚举，CriteriaOperator：
public enum CriteriaOperator{Equal,//=LessThanOrEqual,// <=NotApplicable//≠// TODO: 省略了其他的操作符，可继续添加}
  • 接着添加Criterion类，表示构成查询的过滤器部分：指定一个实体属性（OR  Mapping）、要比较的值以及比较方式：
 public class Criterion{private string _propertyName;//实体属性private object _value;//进行比较的值private CriteriaOperator _criteriaOperator;//何种比较方式public Criterion(string propertyName, object value, CriteriaOperator criteriaOperator){_propertyName = propertyName;_value = value;_criteriaOperator = criteriaOperator;}public string PropertyName {get { return _propertyName; }}public object Value{get { return _value; }}public CriteriaOperator criteriaOperator{get { return _criteriaOperator; }}/// <summary>/// Lambda表达式树：创建一个过滤器/// </summary>/// <typeparam name="T"></typeparam>/// <param name="expression"></param>/// <param name="value"></param>/// <param name="criteriaOperator"></param>/// <returns></returns>public static Criterion Create<T>(Expression<Func<T, object>> expression, Object value, CriteriaOperator criteriaOperator){string propertyName = PropertyNameHelper.ResolvePropertyName<T>(expression);Criterion myCriterion = new Criterion(propertyName, value, criteriaOperator);return myCriterion;}}
  • 为了避免在构建查询时出现令人畏惧的魔幻字符串，我们创建一个辅助方法，使用表达式参数。
public static class PropertyNameHelper{public static string ResolvePropertyName<T>(Expression<Func<T, object>> expression){var expr = expression.Body as MemberExpression;if (expr==null){var u = expression.Body as UnaryExpression;expr = u.Operand as MemberExpression;}return expr.ToString().Substring(expr.ToString().IndexOf(".")+1);}}

这样就可以像查询中添加一个新的查询条件：

query.Add(Criterion.Create<Order>(c=>c.CustomerId,customerId,CriteriaOperator.Equal));

而不是使用魔幻字符串：

  query.Add(new Criterion("CustomerId", customerId, CriteriaOperator.Equal));
  • 下面要创建表示查询的排序属性：
 public class OrderByClause{public string PropertyName { get; set; }public bool Desc { get; set; }}
  • 接着，创建另一个枚举，确定如何各个Criterion进行评估：
public enum QueryOperator{And,Or            }
  • 有时候的复杂非常难以创建，在这些情况下，可以使用指向数据库视图或存储过程的命名查询，添加一个QueryName来存放查询列表：
 public enum QueryName{       Dynamic = 0,//动态创建RetrieveOrdersUsingAComplexQuery = 1//使用已经创建好了的存储过程、视图、特别是查询比较复杂时使用存储过程}
  • 最后，添加Query类，将Query Object模式组合在一起：
    public class Query{private QueryName _name;private IList<Criterion> _criteria;public Query(): this(QueryName.Dynamic, new List<Criterion>()){ }public Query(QueryName name, IList<Criterion> criteria){ _name = name;_criteria = criteria;}public QueryName Name{get { return _name; }}/// <summary>/// 判断该查询是否已经动态生成或与Repository中某个预先建立的查询相关/// </summary>/// <returns></returns>public bool IsNamedQuery(){return Name != QueryName.Dynamic;}public IEnumerable<Criterion> Criteria{get {return _criteria ;}}          public void Add(Criterion criterion){if (!IsNamedQuery())//　动态查询
                _criteria.Add(criterion);elsethrow new ApplicationException("You cannot add additional criteria to named queries");}public QueryOperator QueryOperator { get; set; }public OrderByClause OrderByProperty { get; set; }}
  • 最后创建一个工厂类，提供已存在的查询：
 public static class NamedQueryFactory{public static Query CreateRetrieveOrdersUsingAComplexQuery(Guid CustomerId){IList<Criterion> criteria = new List<Criterion>();Query query = new Query(QueryName.RetrieveOrdersUsingAComplexQuery, criteria);criteria.Add(new Criterion ("CustomerId", CustomerId, CriteriaOperator.NotApplicable));return query;}}

Query Object在服务层的运用

  • 建立领域模型和领域服务类：
 public class Order{public Guid Id { get; set; }public bool HasShipped { get; set; }public DateTime OrderDate { get; set; }public Guid CustomerId { get; set; }}
  • 添加Repository接口：
  public interface IOrderRepository{       IEnumerable<Order> FindBy(Query query);IEnumerable<Order> FindBy(Query query, int index, int count);         }
  • 建立领域服务层：
    public class OrderService{private IOrderRepository _orderRepository;public OrderService(IOrderRepository orderRepository){_orderRepository = orderRepository;}public IEnumerable<Order> FindAllCustomersOrdersBy(Guid customerId){IEnumerable<Order> customerOrders = new List<Order>();Query query = new Query();//推介使用这种query.Add(Criterion.Create<Order>(c=>c.CustomerId,customerId,CriteriaOperator.Equal));//输入魔幻字符串，容易出错query.Add(new Criterion("CustomerId", customerId, CriteriaOperator.Equal));query.OrderByProperty = new OrderByClause { PropertyName = "CustomerId", Desc = true };customerOrders = _orderRepository.FindBy(query); return customerOrders;}public IEnumerable<Order> FindAllCustomersOrdersWithInOrderDateBy(Guid customerId, DateTime orderDate){IEnumerable<Order> customerOrders = new List<Order>();Query query = new Query();query.Add(new Criterion("CustomerId", customerId, CriteriaOperator.Equal));query.QueryOperator = QueryOperator.And; query.Add(new Criterion("OrderDate", orderDate, CriteriaOperator.LessThanOrEqual));query.OrderByProperty = new OrderByClause { PropertyName = "OrderDate", Desc = true };customerOrders = _orderRepository.FindBy(query);return customerOrders;}public IEnumerable<Order> FindAllCustomersOrdersUsingAComplexQueryWith(Guid customerId){IEnumerable<Order> customerOrders = new List<Order>();Query query = NamedQueryFactory.CreateRetrieveOrdersUsingAComplexQuery(customerId);customerOrders = _orderRepository.FindBy(query);return customerOrders;}}

OrderService类包含3个方法，他们将创建的查询传递给Repository。FindAllCustomersOrdersBy和FindAllCustomersOrdersWithInOrderDateBy方法通过Criterion和OrderByClaus添加来创建动态查询。FindAllCustomersOrdersUsingAComplexQueryWith是命名查询，使用NamedQueryFactory来创建要传给Repository的Query Object。

  • 最后创建一个翻译器：QueryTranslator，将查询对象翻译成一条可在数据库上运行的Sql命令：
public static class OrderQueryTranslator{private static string baseSelectQuery = "SELECT * FROM Orders ";public static void TranslateInto(this Query query, SqlCommand command){if (query.IsNamedQuery()){command.CommandType = CommandType.StoredProcedure;command.CommandText = query.Name.ToString();foreach (Criterion criterion in query.Criteria){command.Parameters.Add(new SqlParameter("@" + criterion.PropertyName, criterion.Value));}}else{StringBuilder sqlQuery = new StringBuilder();sqlQuery.Append(baseSelectQuery);bool _isNotfirstFilterClause = false;if (query.Criteria.Count() > 0)sqlQuery.Append("WHERE ");   foreach (Criterion criterion in query.Criteria){if (_isNotfirstFilterClause)sqlQuery.Append(GetQueryOperator(query));                                            sqlQuery.Append(AddFilterClauseFrom(criterion));command.Parameters.Add(new SqlParameter("@" + criterion.PropertyName, criterion.Value));_isNotfirstFilterClause = true;}sqlQuery.Append(GenerateOrderByClauseFrom(query.OrderByProperty));command.CommandType = CommandType.Text; command.CommandText = sqlQuery.ToString();}}private static string GenerateOrderByClauseFrom(OrderByClause orderByClause){return String.Format("ORDER BY {0} {1}",FindTableColumnFor(orderByClause.PropertyName), orderByClause.Desc ? "DESC" : "ASC");          }private static string GetQueryOperator(Query query){if (query.QueryOperator == QueryOperator.And)return "AND ";elsereturn "OR ";}private static string AddFilterClauseFrom(Criterion criterion){return string.Format("{0} {1} @{2} ", FindTableColumnFor(criterion.PropertyName), FindSQLOperatorFor(criterion.criteriaOperator), criterion.PropertyName);}private static string FindSQLOperatorFor(CriteriaOperator criteriaOperator){switch (criteriaOperator){ case CriteriaOperator.Equal:return "=";case CriteriaOperator.LessThanOrEqual:return "<=";default:throw new ApplicationException("No operator defined.");}}private static string FindTableColumnFor(string propertyName){switch (propertyName){case "CustomerId":return "CustomerId";case "OrderDate":return "OrderDate";default:throw new ApplicationException("No column defined for this property.");}}}
  • 建立简单仓储对象：
 public class OrderRepository : IOrderRepository {        private string _connectionString;public OrderRepository(string connectionString){_connectionString = connectionString;}public IEnumerable<Order> FindBy(Query query){// Move to method below with Index and count
IList<Order> orders = new List<Order>();using (SqlConnection connection =new SqlConnection(_connectionString)){SqlCommand command = connection.CreateCommand();query.TranslateInto(command);              connection.Open();using (SqlDataReader reader = command.ExecuteReader()){while (reader.Read()){orders.Add(new Order{CustomerId = new Guid(reader["CustomerId"].ToString()),OrderDate = DateTime.Parse(reader["OrderDate"].ToString()),Id = new Guid(reader["Id"].ToString())                            });}}                }return orders;}public IEnumerable<Order> FindBy(Query query, int index, int count){throw new NotImplementedException();            }       }

测试

 [TestFixture]public class SQLQueryTranslatorTests{[Test]public void The_Translator_Should_Produce_Valid_SQL_From_A_Query_Object(){int customerId = 9;string expectedSQL = "SELECT * FROM Orders WHERE CustomerId = @CustomerId ORDER BY CustomerId DESC";Query query = new Query();query.Add(new Criterion("CustomerId", customerId, CriteriaOperator.Equal));//query.Add(Criterion.Create<Order>(c => c.CustomerId, customerId, CriteriaOperator.Equal));query.OrderByProperty = new OrderByClause { PropertyName = "CustomerId", Desc = true };SqlCommand command = new SqlCommand();query.TranslateInto(command);Assert.AreEqual(expectedSQL, command.CommandText);}}

转载于:https://www.cnblogs.com/OceanEyes/archive/2012/11/14/think-in-design-pattern-query-object.html

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

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

相关文章

linux gcc编译C程序 分享

linux gcc编译C程序 分享

一个c语言程序从源文件到生成可执行文件&#xff0c;编译器需要共经历4个步骤&#xff1a;1) 预处理&#xff1a;把c文件中预处理命令扫描处理完毕&#xff0c;即对源代码文件中的文件包含(#include)、预编译语句(如宏定义#define等)进行分析&#xff0c;此时生成的文件仍然是可…
阅读更多...
java Arrays.copyOfRange使用方法

java Arrays.copyOfRange使用方法

使用场景&#xff1a;比如当一个文本框输入多个值作为查询条件&#xff0c;这时候当输入的值过多&#xff0c;我们需要最大支持多少个&#xff1f;这时候&#xff0c;输入超出个数的值&#xff0c;就被截取不要 不然后台处理逻辑就要飞前台返回不能查询这样的提示&#xff0c;…
阅读更多...
WinForm 中 comboBox控件之数据绑定

WinForm 中 comboBox控件之数据绑定

http://www.cnblogs.com/peterzb/archive/2009/05/30/1491923.html 下面介绍三种对comboBox绑定的方式&#xff0c;分别是泛型中IList和Dictionary&#xff0c;还有数据集DataTable 一、IList 现在我们直接创建一个List集合&#xff0c;然后绑定 View Code IList<string>…
阅读更多...
MySQL常用引擎有MyISAM和InnoDB区别

MySQL常用引擎有MyISAM和InnoDB区别

MySQL常用引擎有MyISAM和InnoDB&#xff0c;而InnoDB是mysql默认的引擎。MyISAM不支持行锁&#xff0c;而InnoDB支持行锁和表锁。 如何加锁&#xff1f; MyISAM在执行查询语句&#xff08;SELECT&#xff09;前&#xff0c;会自动给涉及的所有表加读锁&#xff0c;在执行更新…
阅读更多...
java中异常与return

java中异常与return

抽时间整理了下java中异常与return&#xff0c;以前这块总是弄混淆&#xff0c;觉得还是写下来慢慢整理比较好。由于水平有限&#xff0c;仅供参考。废话不多说&#xff0c;直接上代码。 下面是两个方法&#xff1a; 1 public static int throwReturn(){2 int ret…
阅读更多...
rocketmq 启动mqbroker.cmd闪退

rocketmq 启动mqbroker.cmd闪退

非常奇怪&#xff0c;broker启动闪退&#xff0c;我就摸索了好久&#xff0c;网上各种百度&#xff0c;最后得到正解 将c盘下这个store下的文件全部删除&#xff0c;就可以启动了 猜测是可能mq非正常关闭&#xff0c;导致&#xff0c;具体懂原理的大佬可以来评论区说说
阅读更多...
星星计算器

星星计算器

星星计算器&#xff1a; [ 机锋下载 ]第一款&#xff0c;呃&#xff0c;…&#xff0c;自家学习安卓的时候产的&#xff0c;功能和第二款有些类似&#xff08;而且在细节功能方面我也做了很多努力&#xff09;&#xff0c;不过已经十分强大了&#xff0c;并且有自己的创新&…
阅读更多...
java基础复习-（run方法和start方法区别）

java基础复习-（run方法和start方法区别）

1&#xff0c;run方法是Runnable接口中定义的&#xff0c;start方法是Thread类定义的。 所有实现Runnable的接口的类都需要重写run方法&#xff0c;run方法是线程默认要执行的方法&#xff0c;是绑定操作系统的&#xff0c;也是线程执行的入口。 start方法是Thread类的默认执行…
阅读更多...
Web.py Cookbook 简体中文版 - 如何使用web.background

Web.py Cookbook 简体中文版 - 如何使用web.background

注意&#xff01;&#xff01; web.backgrounder已转移到web.py 3.X实验版本中&#xff0c;不再是发行版中的一部分。你可以在这里下载&#xff0c;要把它与application.py放置在同一目录下才能正运行。 介绍 web.background和web.backgrounder都是python装饰器&#xff0c;它可…
阅读更多...
为什么wait, notify,notifyAll保存在Object类中，而不是Thread类

为什么wait, notify,notifyAll保存在Object类中，而不是Thread类

一个较难回答的 Java 问题&#xff0c; Java 编程语言又不是你设计的&#xff0c;你如何回答这个问题呢&#xff1f; 需要对 Java 编程的常识进行深入了解才行。 这个问题的好在它能反映面试者是否对 wait - notify 机制有没有了解, 以及他相关知识的理解是否明确。就像为什么…
阅读更多...
Springboot集成MapperFactory(ma.glasnost.orika.MapperFactory)类属性复制

Springboot集成MapperFactory(ma.glasnost.orika.MapperFactory)类属性复制

导入jar <dependency><groupId>ma.glasnost.orika</groupId><artifactId>orika-core</artifactId><version>1.5.2</version></dependency> 编写容器注入的类 package com.kingboy.springboot.config;import ma.glasnost.or…
阅读更多...
WPF之布局

WPF之布局

此文目的旨在让人快速了解&#xff0c;没有什么深度&#xff0c;如需深入了解布局&#xff0c;请参考msdn。 如果你要把WPF当winform使用&#xff0c;拖拖控件也无不可&#xff0c;不过建议还是不要拖的好。 本文将那些用的比较多的几个布局控件&#xff08;Grid、UniformGrid、…
阅读更多...
@Size、@Max、@Min、@Length、注解的含义和区别

@Size、@Max、@Min、@Length、注解的含义和区别

Min 验证 Number 和 String 对象是否大等于指定的值Max 验证 Number 和 String 对象是否小等于指定的值Size(min, max) 验证对象&#xff08;Array,Collection,Map,String&#xff09;长度是否在给定的范围之内Length(min, max) 验证字符串长度是否在给定的范围之内区别&#x…
阅读更多...
C# WCF WinCE 解决方案 错误提示之：已超过传入消息(65536)的最大消息大小配额。若要增加配额，请使用相应绑定元素上的 MaxReceivedMessageSize 属性...

C# WCF WinCE 解决方案 错误提示之：已超过传入消息(65536)的最大消息大小配额。若要增加配额，请使用相应绑定元素上的 MaxReceivedMessageSize 属性...

C# WCF WinCE 解决方案 错误提示之&#xff1a;已超过传入消息(65536)的最大消息大小配额。若要增加配额&#xff0c;请使用相应绑定元素上的 MaxReceivedMessageSize 属性 网上的解决方案&#xff1a; 出现这种错误&#xff0c;先去修改服务器端和客户端的MaxReceivedMessageS…
阅读更多...
mybatis xml返回对象类型和接口定义类型不一致

mybatis xml返回对象类型和接口定义类型不一致

最近在开发中发现xml定义的返回值类型xxxxMaper.xml <select id"selectPlanList" parameterType"Plan" resultMap"PlanListVo">select * from table_name</select> <resultMap type"com.demo.vo.PlanListVo" id"…
阅读更多...
算法可视化

算法可视化

http://www.cs.usfca.edu/~galles/visualization/ComparisonSort.html http://jsrun.it/norahiko/oxIy转载于:https://www.cnblogs.com/hailuo/archive/2012/12/06/2805400.html
阅读更多...
Springboot @Validated和@Valid的区别 及使用

Springboot @Validated和@Valid的区别 及使用

Valid是使用Hibernate validation的时候使用 Validated是只用Spring Validator校验机制使用 说明&#xff1a;java的JSR303声明了Valid这类接口&#xff0c;而Hibernate-validator对其进行了实现 Validation对Valid进行了二次封装&#xff0c;在使用上并没有区别&#xff0c…
阅读更多...
【dp】CF17C. Balance

【dp】CF17C. Balance

http://codeforces.com/problemset/problem/17/C 题目中给出一个仅含有a,b,c的字符串&#xff0c;已经两种操作每次选出任意两个相邻的字符&#xff0c;用第一个覆盖掉第二个或者反之&#xff0c;最后询问不考虑操作次数&#xff0c;最终有多少种不同的序列其中a&#xff0c;b,…
阅读更多...
git常用的命令收集

git常用的命令收集

1.强制推送&#xff08;慎用&#xff0c;除非你认为其他冲突等可以丢弃 或者不是很重要&#xff09;git push -- force git—全局设置用户名、密码、邮箱 git config命令的–global参数&#xff0c;用了这个参数&#xff0c;表示你这台机器上所有的Git仓库都会使用这个配置&…
阅读更多...
git文件操作命令

git文件操作命令

1.创建文件等小命令 touch a // 创建一个a文件 echo 1234 >> a // 把1234这个内容放入a文件 cat a // 打开a文件 读取出a文件中的内容 mkdir test // 创建test文件夹 rm 文件名 // 删除文件 pwd // 打印当前工作路径2.安装git的时候 都会安装git bash和git GUI 我们完全也…
阅读更多...
最新文章

Copyright @ 2022~2023