思享工具箱

NHibernate 3.x新功能实践（一） QueryOver（上）

摘要：
本文主要介绍QueryOver的常见应用程序，并通过一个运行示例详细阐述了每个查询场景。最近，我刚刚完成了一个项目。我利用一个难得的机会学习QueryOver，基本上实践了项目中的大多数查询场景，并计划在未来的新项目中使用QueryOver。
一、引言

    NHibernate3.0增加了一种新的查询API——QueryOver。QueryOver构建在NHibernate原有的ICriteria API之上，支持Lambda表达式与扩展方法，可编写类型安全的查询语句，这样就克服了ICriteria API字符串硬编码的弊端，可借助VS提供的智能提示方便代码输入，减少输入错误。同时可利用VS等重构功能自动更新因实体字段名更改而导致的查询语句的变更，方便代码重构。本文主要介绍QueryOver的常见应用，并结合一个可运行的实例对各查询场景进行详尽的阐述。

　　时间过得真快，离最近一次在博客园写文章都快2年时间了。这些年工作是忙不到尽头，很少有空闲的时间可以静下心来写博文，空闲时间有的话也看书、睡觉、跟新技术去了。不过有句名言说得好：时间就像女人的乳沟挤挤总会有的，呵呵。最近刚结掉一个项目，利用难得的空隙机会研究了一下QueryOver，基本上实践了项目中的大部分查询场景，并计划在后面的新项目中使用QueryOver。

      只要熟悉ICriteria API与LINQ，玩玩QueryOver并不难，如果有个现成的详实例子就会节省不少学习时间，但是网上关于QueryOver的可运行的实例很少，再加上NHibernate在线帮助文档对QueryOver的介绍一如既往的简洁，所以就做了个实例来介绍QueryOver，并在文章最后提供源代码下载，以给刚接触QueryOver的朋友分享经验。

二、开发环境与工具
      先介绍一下这个实例的开发环境与工具：
三、实例场景

      为便于理解与掌握，举个故意简化的实例：客户(Customer)与订单(Order)，一个客户可以下多个订单。实体类的代码如下： 

（1）实体基类： Entity

 1 using System;
 2 using System.Collections.Generic;
 3 using System.Linq;
 4 using System.Text;
 5 
 6 namespace MyWorkShop.Model.Entities
 7 {
 8     public abstract class Entity<TId>
 9     {
10         public virtual TId Id { get; protected set; }
11     }
12 }

  （2）客户类：Customer，映射的数据表为MyWorkShop_Customer

 1 using System;
 2 using System.Collections.Generic;
 3 using System.Linq;
 4 using System.Text;
 5 
 6 namespace MyWorkShop.Model.Entities
 7 {
 8     public class Customer:Entity<int>
 9     {
10         public virtual string Name { get; set; }
11         public virtual string Address { get; set; }
12         public virtual string Phone { get; set; }
13     }
14 }

 （3）订单类：Order，映射的数据表为MyWorkShop_Order

 1 using System;
 2 using System.Collections.Generic;
 3 using System.Linq;
 4 using System.Text;
 5 
 6 namespace MyWorkShop.Model.Entities
 7 {
 8     //Guid做主键
 9     public class Order : Entity<Guid>
10     {
11         //下单客户
12         public virtual Customer Customer { get; set; }
13         //下单时间
14         public virtual DateTime OrderedDateTime { get; set; }
15         //订单金额
16         public virtual Decimal? Amount { get; set; } 
17     }
18 }
 四、查询场景

 1. 筛选数据（Restriction）

 （1）根据客户姓名查找客户，假设客户姓名唯一

 1 public Customer GetByName(string customerName)
 2 {
 3     Customer entity = null;
 4             
 5     using (var session = NHibernateSession)
 6     using (var transaction = session.BeginTransaction())
 7     {
 8        
 9         entity = session.QueryOver<Customer>()
10             .Where(c => c.Name == customerName)
11             .SingleOrDefault();
12 
13         transaction.Commit();
14     }
15     return entity;
16 }

输出的SQL：

SELECT this_.Id as Id5_0_, this_.Name as Name5_0_, this_.Address as Address5_0_, this_.Phone as Phone5_0_ FROM MyWorkShop_Customer this_ WHERE this_.Name = @p0;@p0 = 'Name' [Type: String (50)]

代码说明：

  • 筛选条件调用Where方法，使用Lambda表达式“c => c.Name == customerName”，这样就消除了ICriteria的字段名字符串硬编码的问题；
  • 返回单个值调用SingleOrDefault()，若查询结果不唯一则抛出异常NHibernate.NonUniqueResultException。

（2）根据客户地址查找多个客户

 1 public IEnumerable<Customer> GetByAddress(string address)
 2 {
 3     IEnumerable<Customer> list = null;
 4 
 5     using (var session = NHibernateSession)
 6     using (var transaction = session.BeginTransaction())
 7     {
 8         list = session.QueryOver<Customer>()
 9             .Where(c => c.Address == address)
10             .List();
11 
12         transaction.Commit();
13     }
14 
15     return list;
16 }

 输出的SQL：

SELECT this_.Id as Id5_0_, this_.Name as Name5_0_, this_.Address as Address5_0_, this_.Phone as Phone5_0_ FROM MyWorkShop_Customer this_ WHERE this_.Address = @p0;@p0 = 'Address' [Type: String (100)]

代码说明：

  •  查询多条数据调用List()方法。

 （3）根据客户姓名模糊查找客户

 1 public IEnumerable<Customer> GetByLikeName(string likeName)
 2 {
 3     IEnumerable<Customer> list = null;
 4 
 5     using (var session = NHibernateSession)
 6     using (var transaction = session.BeginTransaction())
 7     {
 8         list = session.QueryOver<Customer>()
 9             .WhereRestrictionOn(o => o.Name).IsLike(likeName, MatchMode.Anywhere)
10             .List();
11 
12         transaction.Commit();
13     }
14 
15     return list;
16 }

输出的SQL：

SELECT this_.Id as Id5_0_, this_.Name as Name5_0_, this_.Address as Address5_0_, this_.Phone as Phone5_0_ FROM MyWorkShop_Customer this_ WHERE this_.Name like @p0;@p0 = '%e%' [Type: String (50)]

 代码说明：

  •  对于某些SQL函数与操作符（比如like、between...and...），没有直接对应的Lambda表达式，需要先使用WhereRestrictionOn方法指定筛选条件的列，然后再调用相应的方法指定筛选条件；
  • IsLike方法指定字符串匹配查找。

 （4）查找金额在指定范围内的订单

2 public IEnumerable<Order> GetByAmount(decimal minAmount, decimal maxAmount)
 3 {
 4     IEnumerable<Order> list = null;
 5 
 6     using (var session = NHibernateSession)
 7     using (var transaction = session.BeginTransaction())
 8     {
 9         list = session.QueryOver<Order>()
10             .Where(o => o.Amount >= minAmount)
11             .And(o => o.Amount <= maxAmount)
12             .OrderBy(o => o.Amount).Desc
13             .List();
14 
15         transaction.Commit();
16     }
17 
18     return list;
19 }

 输出的SQL：

SELECT this_.Id as Id8_0_, this_.CustomerId as CustomerId8_0_, this_.OrderedDateTime as OrderedD3_8_0_, this_.Amount as Amount8_0_ FROM MyWorkShop_Order this_ WHERE this_.Amount >= @p0 and this_.Amount <= @p1 ORDER BY this_.Amount desc;@p0 = 100 [Type: Decimal (0)], @p1 = 200 [Type: Decimal (0)]

 代码说明：

  • 多个条件可使用Where...And...逐个指定，也可以在一个Where方法中指定，比如上面的条件可以写成Where(o => o.Amount >= minAmount && o.Amount <= maxAmount)；
  • 排序使用OrderBy，升序降序使用Asc与Desc。

2.连接（Join）

（1）内连接：根据客户姓名查找订单

 1 public IEnumerable<Order> GetByCustomerName(string customerName)
 2 {
 3     IEnumerable<Order> list = null;
 4 
 5     using (var session = NHibernateSession)
 6     using (var transaction = session.BeginTransaction())
 7     {
 8         list = session.QueryOver<Order>()
 9             .OrderBy(o=>o.Amount).Desc
10             .Inner.JoinQueryOver<Customer>(o => o.Customer)
11             .Where(c => c.Name == customerName)            
12             .List();
13 
14         transaction.Commit();
15     }
16 
17     return list;
18 }

 输出的SQL：

SELECT this_.Id as Id8_1_, this_.CustomerId as CustomerId8_1_, this_.OrderedDateTime as OrderedD3_8_1_, this_.Amount as Amount8_1_, customer1_.Id as Id9_0_, customer1_.Name as Name9_0_, customer1_.Address as Address9_0_, customer1_.Phone as Phone9_0_ FROM MyWorkShop_Order this_ inner join MyWorkShop_Customer customer1_ on this_.CustomerId=customer1_.Id WHERE customer1_.Name = @p0 ORDER BY this_.Amount desc;@p0 = 'Name' [Type: String (50)]

 代码说明：

  • .Inner.JoinQueryOver指定内连接，如果省略Inner仅写JoinQueryOver默认就是内连接；
  • .Left、.Right则分别为左外连接、右外连接
（2）使用别名进行内连接：根据客户姓名查找订单
 1 public IEnumerable<Order> GetByCustomerNameViaAlias(string customerName)
 2 {
 3     //定义用于内连接的别名变量，该变量必须赋值为null
 4     Customer customer = null;
 5 
 6     IEnumerable<Order> list = null;
 7 
 8     using (var session = NHibernateSession)
 9     using (var transaction = session.BeginTransaction())
10     {
11         list = session.QueryOver<Order>()
12             .JoinAlias(o => o.Customer, () => customer) //指定别名customer
13             .Where(() => customer.Name == customerName)
14             .List();
15 
16         transaction.Commit();
17     }
18 
19     return list;
20 }
 输出的SQL：

       同上，略

 代码说明：
  •  可以通过.Inner.JoinQueryOver来显式进行内连接，也可以通过.JoinAlias创建连接别名进行连接；
  •  连接别名变量在QueryOver使用之前定义，并且必须赋null值。
五、总结     

      与ICriteria API相比，个人认为QueryOver并不见得会提高代码的可读性，但QueryOver解决了

ICriteria API字符串硬编码的问题，从而减少代码输入的错误，大大提高了代码重构的能力，因此用QueryOver取代ICriteria API是值得的。

       本文通过一个简单的实例，介绍了QueryOver进行条件筛选（Restriction）、连接（Join）等常见场景的应用，在下一篇文章中将介绍投影(Projection)、把投影结果转成DTO、分页、子查询（Subquery）等。

六、参考资料

 [1] NHibernate关于QueryOver的在线帮助文档

 [2] NHibernate 3.0 Cookbook    P130-137

七、实例源代码下载

      源代码下载

八、实例项目说明

1. 项目组织结构

  • MyWorkShop.Model项目：创建实体类与DTO；
  • MyWorkShop.Data项目：创建数据访问接口；
  • MyWorkShop.Data.NHibernate项目：定义数据访问的NHibernate实现，包含文中所列举的各查询方法；
  • MyWorkShop.Data.NHibernate.Test项目：对MyWorkShop.Data.NHibernate项目中各数据访问方法进行测试。

2. 测试数据库     

      测试数据库名为MyWorkShop，数据库文件位于db文件夹中，附加数据库文件即可；当然也可手工创建名为MyWorkShop的数据库。

3. NHibernate配置文件

      hibernate.cfg.xml位于MyWorkShop.Data.NHibernate.Test项目中的，可根据自己的运行环境进行相应的配置。


标签：#session#hibernate | 浏览：126 | 发布日期：

免责声明：文章转载自《NHibernate 3.x新功能实践（一） QueryOver（上）》仅用于学习参考。如对内容有疑问，请及时联系本站处理。

上篇Flask之RESTFul API前后端分离SSL加速和证书卸载的配置方式下篇

宿迁高防，2C2G15M，22元/月；香港BGP，2C5G5M，25元/月 雨云优惠码：MjYwNzM=

相关文章

【转载】阮一峰网络日志中的JWT入门

目录 跨域认证问题 JWT原理 JWT的格式 Header Payload Signature Base64URL JWT的使用方式 JWT 的几个特点 转自阮一峰网络日志：http://www.ruanyifeng.com/blog/2018/07/json_web_token-tutorial.html JWT是JSON WEB TO...

SpringBoot + Shiro实现当前在线人数统计

实现思路 数据库中添加用户是否登录is_login字段，用来记录用户的登录状态，假设1表示在线；0表示未在线，则需要进行控制： 1）当用户登录成功时，设置用户登录状态为1 2）当用户退出登录时，设置用户登录状态为0 3）当session失效时，设置对应的用户的登录状态为0 实现方法 1、更改数据库字段，编写登录状态更新函数 添加字段后，编写状态更新函数 /...

Flask 中内置的 Session 应用

目录 1.Flask 中 session 是需要 secret_key 的 2.session抛异常 3.session 用法： 4.验证session Flask中的Session非常的奇怪,他会将你的SessionID存放在客户端的Cookie中,使用起来也非常的奇怪 1.Flask 中 session 是需要 secret_key 的 fro...

Tornado 【简述】

前言 python 旗下，群英荟萃，豪杰并起。单是用于 web 开发的，就有 webpy、web2py、bottle、pyramid、zope2、flask、tornado、django 等等，不一而足。最近几年较为流行的，大概也就是flask、tornado 和 django 了。 关于以上各个 web 开发框架的性能比较，上网一搜，铺天盖地——这不是...

使用Fiddler进行APP弱网测试

一、安装Fiddler 网上说要先安装.NET Framwork4，应该是由于本机已装，所以在安装Fiddler时并没有相关提示。 Fiddler安装包：https://www.telerik.com/download/fiddler/fiddler4 二、Fiddler通过代理连上手机 首先电脑和手机要使用同一个无线网。 1. Fiddler工具->...

ActiveMQ点对点的发送和接收

最近在工作中用到了ActiveMQ的点对点模式，在此用一个范例简单描述下使用过程。 1.首先在工程导入ActiveMQ的jar包，此jar包在下载的ActiveMQ资源里，这里用的是ActiveMQ版本是5.9。 2.编写消息发送者 package com.cool.jms; import org.apache.activemq.ActiveMQCon...

最新文章

随机推荐

思享工具箱导航