如何結合hibernate進(jìn)行復雜的查詢(xún)功能設計
偶一直想弄明白使用hibernate怎么能實(shí)現一些多表關(guān)聯(lián)的查詢(xún)功能，網(wǎng)上的例子都是一些簡(jiǎn)單的查詢(xún)示例，對負責的業(yè)務(wù)可能有困難，凌晨突然發(fā)現一篇文檔感覺(jué)很不錯（又興奮中……），推薦一下：http://dev.csdn.net/develop/article/63/63043.shtm 。個(gè)人感覺(jué)如果將查詢(xún)條件定義成一個(gè)TO，這樣的設計會(huì )更好一些！不僅解決了偶關(guān)于在hibernate中如何進(jìn)行復雜查詢(xún)的疑問(wèn)，而且告訴了我如何設計查詢(xún)功能（即使不用hibernate）！
原文如下：
Hibernate是典型的OPM工具，它將每一個(gè)物理表格（Table）映射成為對象（Object），這發(fā)揮了面向對象的優(yōu)勢，使設計和開(kāi)發(fā)人員可以從面向對象的角度來(lái)進(jìn)行對數據庫的管理。
在設計到多表操作時(shí)，Hibernate提供了與數據庫表關(guān)系相對應的對象映射關(guān)系，一對一、一對多和多對多在這里都可以通過(guò)Hibernate的對象映射關(guān)系（Set等）來(lái)實(shí)現。這為一般情況下的數據庫多表操作提供了便捷途徑。關(guān)于這方面的介紹已經(jīng)很多，在這里不再復述。
但是，在有些情況下的多表操作，比如一個(gè)統計顧客在2005年的消費總金額的SQL操作如下：
select b.name, count(a.fee) mix(a.chargeBeginTime) max(a.chargeEndTime) from charge a, customer b where a.idCustomer = b.idCustomer and a.chargeBeginTime >= '2005-01-01' and a.chargeEndTime < '2005-12-31' gourp by a.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的自帶文檔中有類(lèi)似下面的多表查詢(xún)操作提示：
“select new OjbectC(field1, field2,...) from ObjectA a, ObjectB b ...”，
分析一下可以看出這個(gè)操作有兩個(gè)缺點(diǎn)：
1）必須聲明并創(chuàng )建類(lèi)ObjectC，根據Hibernate的特點(diǎn)，需要寫(xiě)一個(gè)ObjectC.hbm.xml的PO映射，在只用到創(chuàng )建查詢(xún)結果的新對象的時(shí)候，這個(gè)映射可以是個(gè)虛的，即可以沒(méi)有一個(gè)真正的數據庫表和ObjectC對應，但是這樣的一個(gè)虛設的邏輯顯然已經(jīng)違背了Hibernate的思想初衷；
2）這個(gè)辦法只能查詢(xún)出但條結果記錄并只能創(chuàng )建單個(gè)的ObjectC對象，這是很局限的，因此在某些情況下根本不能使用（比如本例）。
所以，對于本例，上面的方法是行不通的。
其實(shí)，仔細看看Hibernate的API，就會(huì )發(fā)現這個(gè)問(wèn)題很好解決。在net.sf.hibernate包中有下面三個(gè)對我們很有用的接口：
1、Interface ScrollableResults
這個(gè)接口類(lèi)似JDBC中的ResultSet一樣，提供了對返回結果集合的遍歷和字段訪(fǎng)問(wèn)方法，如：
public boolean next() 游標后移
public boolean previous() 游標前移
public boolean scroll(int i) 游標移動(dòng)到指定未知
public void beforeFirst() 游標在首記錄前
public void afterLast() 游標在末記錄后
public Object[] get() 將當前記錄的字段值以Object對象數組形式返回
public Object get(int i) 將當前記錄的特定字段值以Object對象形式返回
public Integer getInteger(int col) 將當前記錄的特定字段值以Integer對象返回
public Long getLong(int col) 將當前記錄的特定字段值以L(fǎng)ong對象返回
public String getText(int col) 將當前記錄的特定字段值以Text對象返回
public String getString(int col) 將當前記錄的特定字段值以String對象返回
...等等
2、Interface Query
Query接口封裝了對數據庫的查詢(xún)等操作，在這里，我們使用到它的原因是在于它的scroll()方法可以返回一個(gè)ScrollableResults實(shí)例：
public ScrollableResults scroll() 將查詢(xún)結果以ScrollableResults實(shí)例返回，但需要注意的是查詢(xún)返回的結果其實(shí)只是一些id，當需要的時(shí)候（比如我們使用ScrollableResults.next()方法后移游標時(shí)）這條需要用到的記錄才會(huì )被真正初始化（這種技術(shù)可以稱(chēng)作：延時(shí)初始化）
3、Interface Session
Session是Hibernate的核心中的核心，通過(guò)Session的createQuery()方法，我們能生成一個(gè)Query實(shí)例：
public Query createQuery(String queryString) 用給出的HQL查詢(xún)串創(chuàng )建一個(gè)Query實(shí)例
好了，了解了上面的三個(gè)接口，問(wèn)題就能夠很好的解決了。需要如下幾個(gè)文件：
Customer.java PO對象
Charge.java PO對象
TotalCharge.java 用于保存統計結果Bean
Customer.hbm.xml PO映射
Charge.hbm.xml PO映射
TotalChargeDao.java 統計Dao定義
TotalChargeDaoImpl.java 統計Dao定義實(shí)現
DaoFactory.java Dao工廠(chǎng)
HibernateSessionFactory.java Session工廠(chǎng)
因為這里主要討論的重點(diǎn)是對Customer和Charge的聯(lián)合查詢(xún)，所以Customer.java、Charge.java、Customer.hbm.xml、Charge.hbm.xml四個(gè)文件以及TotalChargeDao.java、DaoFactory.java、HibernateSessionFactory.java的源代碼在這里省略掉。
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.Date chargeTimeBegin,
java.util.Date chargeTimeEnd) {
this.name = name;
this.fee = fee;
this.chargeTimeBegin = chargeTimeBegin;
this.chargeTimeEnd = chargeTimeEnd;
}public void setName(String name) {
this.name = name;
}public Double getFee() {
return fee;
}public void setFee(Double fee) {
this.fee = fee;
}public java.util.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 = chargeTimeEnd;
}
}
TotalChargeDaoImpl.java 代碼：
package test.dao.impl;
import java.util.*;
import test.bean.*;
import test.dao.*;
import net.sf.hibernate.*;
/**
*作者：孫星
**/
public class TotalChargeDaoImple extends TotalChargeDao{
//下面方法集成自TotalChargeDao
public List statTotalCharge(Date statTimeBegin, Date statTimeEnd) throws DaoException{
List res = new Vector();//將用于存放保存的結果集合
Session session = null;
ScrollableResults srs ＝ null;
try{
session = HibernateSessionFactory.openSession();//得到一個(gè)Hibernate Session
//下面創(chuàng )建一個(gè)匿名Query實(shí)例并調用它的scroll()方法返回以ScrollableResults形式組織的查詢(xún)結果
srs = session.createQuery(“select b.name, count(a.fee) mix(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();
//將查詢(xún)結果放入List保存
while(srs.next()){
res.add(new TotalCharge(srs.getString(0), srs,getDouble(1), srs.getDate(2), srs.getDate(3)));
}
}catch(HibernateException he){
;//loging err.....
if(srs!=null){
try{
srs.close();
}catch(Exception e){
;
}
}
}finally{
try{
session.close();
}catch(Exception e){
;
}
}
return res;
}
}
Trackback: http://tb.blog.csdn.net/TrackBack.aspx?PostId=1753292
聯(lián)系客服
