如何结合hibernate进行复杂的查询功能设计

Hibernate是典型的OPM工具，它将每一个物理表格（Table）映射成为对象（Object），这发挥了面向对象的优势，使设计和开发人员可以从面向对象的角度来进行对数据库的管理。

在设计到多表操作时，Hibernate提供了与数据库表关系相对应的对象映射关系，一对一、一对多和多对多在这里都可以通过Hibernate的对象映射关系（Set等）来实现。这为一般情况下的数据库多表操作提供了便捷途径。关于这方面的介绍已经很多，在这里不再复述。

但是，在有些情况下的多表操作，比如一个统计顾客在2005年的消费总金额的SQL操作如下：

selectb.name,count(a.fee)mix(a.chargeBeginTime)max(a.chargeEndTime)fromchargea,customerbwherea.idCustomer=b.idCustomeranda.chargeBeginTime>='2005-01-01'anda.chargeEndTime<'2005-12-31'gourpbya.idCustomer

customer表和charge结构如下：

customer表结构：

+------------+-------------+------+-----+---------+-------+

|Field|Type|Null|Key|Default|Extra|

+------------+-------------+------+-----+---------+-------+

|IdCustomer|varchar(32)||PRI|||

|Name|varchar(30)|||||

+------------+-------------+------+-----+---------+-------+

charge表结构：

+-----------------+-------------+------+-----+---------+-------+

|Field|Type|Null|Key|Default|Extra|

+-----------------+-------------+------+-----+---------+-------+

|IdCharge|varchar(32)||PRI|||

|Fee|double|YES||NULL||

|ChargeTimeBegin|datetime|YES||NULL||

|ChargeTimeEnd|datetime|YES||NULL||

+-----------------+-------------+------+-----+---------+-------+

在Hibernate的自带文档中有类似下面的多表查询操作提示：

“selectnewOjbectC(field1,field2,...)fromObjectAa,ObjectBb...”，

分析一下可以看出这个操作有两个缺点：

1）必须声明并创建类ObjectC，根据Hibernate的特点，需要写一个ObjectC.hbm.xml的PO映射，在只用到创建查询结果的新对象的时候，这个映射可以是个虚的，即可以没有一个真正的数据库表和ObjectC对应，但是这样的一个虚设的逻辑显然已经违背了Hibernate的思想初衷；

2）这个办法只能查询出但条结果记录并只能创建单个的ObjectC对象，这是很局限的，因此在某些情况下根本不能使用（比如本例）。

所以，对于本例，上面的方法是行不通的。

其实，仔细看看Hibernate的API，就会发现这个问题很好解决。在net.sf.hibernate包中有下面三个对我们很有用的接口：

1、InterfaceScrollableResults

这个接口类似JDBC中的ResultSet一样，提供了对返回结果集合的遍历和字段访问方法，如：

publicbooleannext()游标后移

publicbooleanprevious()游标前移

publicbooleanscroll(inti)游标移动到指定未知

publicvoidbeforeFirst()游标在首记录前

publicvoidafterLast()游标在末记录后

publicObject[]get()将当前记录的字段值以Object对象数组形式返回

publicObjectget(inti)将当前记录的特定字段值以Object对象形式返回

publicIntegergetInteger(intcol)将当前记录的特定字段值以Integer对象返回

publicLonggetLong(intcol)将当前记录的特定字段值以Long对象返回

publicStringgetText(intcol)将当前记录的特定字段值以Text对象返回

publicStringgetString(intcol)将当前记录的特定字段值以String对象返回

...等等

2、InterfaceQuery

Query接口封装了对数据库的查询等操作，在这里，我们使用到它的原因是在于它的scroll()方法可以返回一个ScrollableResults实例：

publicScrollableResultsscroll()将查询结果以ScrollableResults实例返回，但需要注意的是查询返回的结果其实只是一些id，当需要的时候（比如我们使用ScrollableResults.next()方法后移游标时）这条需要用到的记录才会被真正初始化（这种技术可以称作：延时初始化）

3、InterfaceSession

Session是Hibernate的核心中的核心，通过Session的createQuery()方法，我们能生成一个Query实例：

publicQuerycreateQuery(StringqueryString)用给出的HQL查询串创建一个Query实例

好了，了解了上面的三个接口，问题就能够很好的解决了。需要如下几个文件：

Customer.javaPO对象

Charge.javaPO对象

TotalCharge.java用于保存统计结果Bean

Customer.hbm.xmlPO映射

Charge.hbm.xmlPO映射

TotalChargeDao.java统计Dao定义

TotalChargeDaoImpl.java统计Dao定义实现

DaoFactory.javaDao工厂

HibernateSessionFactory.javaSession工厂

因为这里主要讨论的重点是对Customer和Charge的联合查询，所以Customer.java、Charge.java、Customer.hbm.xml、Charge.hbm.xml四个文件以及TotalChargeDao.java、DaoFactory.java、HibernateSessionFactory.java的源代码在这里省略掉。

TotalCharge.java的源代码：

packagetest.bean;

/**

*作者：孙星

**/

publicclassTotalCharge{

privateStringname;

privateDoublefee;

privatejava.util.DatechargeTimeBegin;

privatejava.util.DatechargeTimeEnd;

publicTotalCharge(){

  }

  public String getName() {

returnname;

  }

  public TotalCharge(String name, Double fee, java.util.Date chargeTimeBegin,

java.util.DatechargeTimeEnd){

this.name=name;

this.fee=fee;

this.chargeTimeBegin=chargeTimeBegin;

this.chargeTimeEnd=chargeTimeEnd;

  }

  public void setName(String name) {

this.name=name;

  }

  public Double getFee() {

returnfee;

  }

  public void setFee(Double fee) {

this.fee=fee;

  }

  public java.util.Date getChargeTimeBegin() {

returnchargeTimeBegin;

  }

  public void setChargeTimeBegin(java.util.Date chargeTimeBegin) {

this.chargeTimeBegin=chargeTimeBegin;

  }

  public java.util.Date getChargeTimeEnd() {

returnchargeTimeEnd;

  }

  public void setChargeTimeEnd(java.util.Date chargeTimeEnd) {

this.chargeTimeEnd=chargeTimeEnd;

}

}

TotalChargeDaoImpl.java代码：

packagetest.dao.impl;

importjava.util.*;

importtest.bean.*;

importtest.dao.*;

importnet.sf.hibernate.*;

/**

*作者：孙星

**/

publicclassTotalChargeDaoImpleextendsTotalChargeDao{

//下面方法集成自TotalChargeDao

publicListstatTotalCharge(DatestatTimeBegin,DatestatTimeEnd)throwsDaoException{

Listres=newVector();//将用于存放保存的结果集合

Sessionsession=null;

ScrollableResultssrs＝null;

try{

session=HibernateSessionFactory.openSession();//得到一个HibernateSession

//下面创建一个匿名Query实例并调用它的scroll()方法返回以ScrollableResults形式组织的查询结果

srs=session.createQuery(“selectb.name,count(a.fee)mix(a.chargeBeginTime)max(a.chargeEndTime)fromchargea,customerbwherea.idCustomer=b.idCustomeranda.chargeBeginTime>=?anda.chargeEndTime<?gourpbya.idCustomer“).setDate(0,statTimeBegin).setDate(1,statTimeEnd).scroll();

//将查询结果放入List保存

while(srs.next()){

res.add(newTotalCharge(srs.getString(0),srs,getDouble(1),srs.getDate(2),srs.getDate(3)));

}

}catch(HibernateExceptionhe){

;//logingerr.....

if(srs!=null){

try{

srs.close();

}catch(Exceptione){

;

}

}

}finally{

try{

session.close();

}catch(Exceptione){

;

}

}

returnres;

}

}