hibernate多表关联查询

1、Hibernate是典型的OPM工具，它将每一个物理表格（ Table ）映射成为对象（Object ）, 这发挥了面向对象的优势，使设计和开发人员可以从面向对象的角度来进行对数据库的管理。在设计到多表操作时，Hibernate提供了与数据库表关系相对应的对象映射关系，一对 一、一对多和多对多在这里都可以通过Hibernate的对象映射关系（Set等）来实现。这为一般情况下的数据库多表操作提供了便捷途径。关于这方面的介绍已经很多，在这里不再复述。但是，在有些情况下的多表操作，比如一个统计顾客在 2005年的消费总金额的 SQL操作如下：select b.n ame, coun t（a.fee）

2、 mix（a.chargeBegi nTime） max（a.chargeE ndTime） from chargea, customer b where a.idCustomer = b.idCustomer and a.chargeBeg in Time >='2005-01-01' and a.chargeEndTime < '2005-12-31' gourp by a.idCustomer customer 表禾口 charge 结构如下：customer 表结构:| Field | Type | Null | Key | Default

3、| 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 | ChargeTimeE nd | datetime | YES | NULL |在Hibernate的自带文档中有类似下面的多表查询操作提示：“ select

4、new OjbectC（field1, field2,.） from ObjectA a, ObjectB b .，”分析一下可以看出这个操作有两个缺点：1） 必须声明并创建类 ObjectC，根据Hibernate的特点，需要写一个 ObjectC.hbm. XML 的PO映射，在只用到创建查询结果的新对象的时候，这个映射可以是个虚的， 即可以没有 一个真正的数据库表和 ObjectC对应，但是这样的一个虚设的逻辑显然已经违背了Hibernate的思想初衷；2） 这个办法只能查询出但条结果记录并只能创建单个的ObjectC对象，这是很局限的， 因此在某些情况下根本不能使用（比如本例）。所以，

5、对于本例，上面的方法是行不通的。其实，仔细看看Hibernate的API，就会发现这个问题很好解决。在net.sf.hibernate包中1、In terface ScrollableResults这个接口类似 法，如：public boolea n public boolea n public boolea n有下面三个对我们很有用的接口:JDBC中的ResultSet 样，提供了对返回结果集合的遍历和字段访问方next ()游标后移previous ()游标前移 scroll (int i)游标移动到指定未知Object get ()将当前记录的字段值以Object对象数组形式返回Obje

6、ct get (int i)将当前记录的特定字段值以 Object对象形式返回 Integer getInteger (int col)将当前记录的特定字段值以 Long getLong (int col)将当前记录的特定字段值以 String getText (int col)将当前记录的特定字段值以 String getString (int col)将当前记录的特定字段值以Integer对象返回 Long对象返回 Text对象返回String对象返回public void beforeFirst () 游标在首记录前 public void afterLast () 游标在末记录后 pu

7、blic public public public public public连连. 等等2、In terface QueryQuery接口封装了对数据库的查询等操作，在这里，我们使用到它的原因是在于它的scroll()方法可以返回一个ScrollableResults 实例：public ScrollableResults scroll ()将查询结果以 ScrollableResults实例返回，但需要注意的是查询返回的结果其实只是一些id，当需要的时候(比如我们使用ScrollableResults. next()方法后移游标时)这条需要用到的记录才会被真正初始化(这种技术可以称作：延时

8、初始化)3、In terface Sessi onSession是Hibernate 的核心中的核心，通过Session的createQuery()方法，我们能生成一个Query实例：public Query createQuery (String queryString) 用给出的 HQL 查询串创建一个 Query 实例 好了，了解了上面的三个接口，问题就能够很好的解决了。需要如下几个文件:PO对象PO对象用于保存统计结果 BeanPO映射PO映射统计Dao定义统计Dao定义实现Dao工厂Session 工厂Customer. JavaCharge.javaTotalCharge.java

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

10、TotalCharge.java的源代码：package test.bean;/*作者：孙星*/public class TotalCharge private String name;private Double fee;private java.util.Date chargeTimeBegin;private java.util.Date chargeTimeEnd;public TotalCharge() public String getName() return name;public TotalCharge(String name, Double fee, java.util.D

11、ate chargeTimeBegin,java.util.Date chargeTimeEnd) = name;this.fee = fee;this.chargeTimeBegin = chargeTimeBegin;this.chargeTimeEnd = chargeTimeEnd;public void setName(String name) = name;public Double getFee() return fee;public void setFee(Double fee) this.fee = fee;public java.ut

12、il.Date getChargeTimeBegin() return chargeTimeBegin;public void setChargeTimeBegin(java.util.Date chargeTimeBegin) this.chargeTimeBegin = chargeTimeBegin;public java.util.Date getChargeTimeEnd() return chargeTimeEnd;public void setChargeTimeEnd(java.util.Date chargeTimeEnd) this.chargeTimeEnd = char

13、geTimeEnd;TotalChargeDaoImpl.java 代码:package test.dao.impl;import java.util.*;import test.bean.*;import test.dao.*;import net.sf.hibernate.*;/* *作者：孙星 */ public class TotalChargeDaoImple extends TotalChargeDao下面方法集成自TotalChargeDaopublic List statTotalCharge(Date statTimeBegin, Date statTimeEnd) thro

14、ws DaoExceptionList res = new Vector(); 将用于存放保存的结果集合Session session = null;ScrollableResults srs = null;trysession = HibernateSessionFactory.openSession();得至U个 Hibernate Session/下面创建一个匿名 Query实例并调用它的scroll()方法返回以ScrollableResults 形式组织的查询结果srs = session.createQuery( “ select , count(a.fee) mix(

15、a.chargeBeginTime) max(a.chargeEndTime) from charge a, customer b where a.idCustomer = b.idCustomer and a.chargeBeginTime >= ? and a.chargeEndTime < ? gourp by a.idCustomer “).setDate(0, statTimeBegin) .setDate(1, statTimeEnd).scroll();/将查询结果放入List保存while(srs.next()res.add(new TotalCharge(srs.

16、getString(0), srs,getDouble(1), srs.getDate(2), srs.getDate(3);catch(HibernateException he);/loging err.if(srs!=null)trysrs.close();catch(Exception e)Jfinallytrysession.close();catch(Exception e)Jreturn res;看，现在问题解决了。坐下来，喝杯Java吧！Hibernate的多表查询Hibernate的多表查询Query query = sessi on. createQuery("select t,c from Cat as c,Custom as t wherec.sex = :sex and c.id = t.id");query.setCharacter("sex", 'F');for (Iterator it = query.iterate(); it.hasNext(); ) Object queryArray = (Object)it.