如何結合hibernate進行復雜的查詢功能設計
阿新 • • 發佈：2019-01-28
Hibernate是典型的OPM工具，它將每一個物理表格（Table）對映成為物件（Object），這發揮了面向物件的優勢，使設計和開發人員可以從面向物件的角度來進行對資料庫的管理。
在設計到多表操作時，Hibernate提供了與資料庫表關係相對應的物件對映關係，一對一、一對多和多對多在這裡都可以通過Hibernate的物件對映關係（Set等）來實現。這為一般情況下的資料庫多表操作提供了便捷途徑。關於這方面的介紹已經很多，在這裡不再複述。
但是，在有些情況下的多表操作，比如一個統計顧客在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的自帶文件中有類似下面的多表查詢操作提示：
“select new OjbectC(field1, field2,...) from ObjectA a, ObjectB b ...”，
分析一下可以看出這個操作有兩個缺點：
1）必須宣告並建立類ObjectC，根據Hibernate的特點，需要寫一個ObjectC.hbm.xml的PO對映，在只用到建立查詢結果的新物件的時候，這個對映可以是個虛的，即可以沒有一個真正的資料庫表和ObjectC對應，但是這樣的一個虛設的邏輯顯然已經違背了Hibernate的思想初衷；
2）這個辦法只能查詢出但條結果記錄並只能建立單個的ObjectC物件，這是很侷限的，因此在某些情況下根本不能使用（比如本例）。
所以，對於本例，上面的方法是行不通的。
其實，仔細看看Hibernate的API，就會發現這個問題很好解決。在net.sf.hibernate包中有下面三個對我們很有用的介面：
1、Interface ScrollableResults
這個介面類似JDBC中的ResultSet一樣，提供了對返回結果集合的遍歷和欄位訪問方法，如：
public boolean next
public boolean previous() 遊標前移
public boolean scroll(int i) 遊標移動到指定未知
public void beforeFirst() 遊標在首記錄前
public void afterLast() 遊標在末記錄後
public Object[] get() 將當前記錄的欄位值以Object物件陣列形式返回
public Object get(int i) 將當前記錄的特定欄位值以Object物件形式返回
public Integer getInteger(int col) 將當前記錄的特定欄位值以Integer物件返回
public
public String getText(int col) 將當前記錄的特定欄位值以Text物件返回
public String getString(int col) 將當前記錄的特定欄位值以String物件返回
...等等
2、Interface Query
Query介面封裝了對資料庫的查詢等操作，在這裡，我們使用到它的原因是在於它的scroll()方法可以返回一個ScrollableResults例項：
public ScrollableResults scroll() 將查詢結果以ScrollableResults例項返回，但需要注意的是查詢返回的結果其實只是一些id，當需要的時候（比如我們使用ScrollableResults.next()方法後移遊標時）這條需要用到的記錄才會被真正初始化（這種技術可以稱作：延時初始化）
3、Interface Session
Session是Hibernate的核心中的核心，通過Session的createQuery()方法，我們能生成一個Query例項：
public Query
好了，瞭解了上面的三個介面，問題就能夠很好的解決了。需要如下幾個檔案：
Customer.java PO物件
Charge.java PO物件
TotalCharge.java 用於儲存統計結果Bean
Customer.hbm.xml PO對映
Charge.hbm.xml PO對映
TotalChargeDao.java 統計Dao定義
TotalChargeDaoImpl.java 統計Dao定義實現
DaoFactory.java Dao工廠
HibernateSessionFactory.java Session工廠
因為這裡主要討論的重點是對Customer和Charge的聯合查詢，所以Customer.java、Charge.java、Customer.hbm.xml、Charge.hbm.xml四個檔案以及TotalChargeDao.java、DaoFactory.java、HibernateSessionFactory.java的原始碼在這裡省略掉。
TotalCharge.java 的原始碼：
TotalChargeDaoImpl.java 程式碼：
看，現在問題解決了。坐下來，喝杯Java吧！
在設計到多表操作時，Hibernate提供了與資料庫表關係相對應的物件對映關係，一對一、一對多和多對多在這裡都可以通過Hibernate的物件對映關係（Set等）來實現。這為一般情況下的資料庫多表操作提供了便捷途徑。關於這方面的介紹已經很多，在這裡不再複述。
但是，在有些情況下的多表操作，比如一個統計顧客在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的自帶文件中有類似下面的多表查詢操作提示：
“select new OjbectC(field1, field2,...) from ObjectA a, ObjectB b ...”，
分析一下可以看出這個操作有兩個缺點：
1）必須宣告並建立類ObjectC，根據Hibernate的特點，需要寫一個ObjectC.hbm.xml的PO對映，在只用到建立查詢結果的新物件的時候，這個對映可以是個虛的，即可以沒有一個真正的資料庫表和ObjectC對應，但是這樣的一個虛設的邏輯顯然已經違背了Hibernate的思想初衷；
2）這個辦法只能查詢出但條結果記錄並只能建立單個的ObjectC物件，這是很侷限的，因此在某些情況下根本不能使用（比如本例）。
所以，對於本例，上面的方法是行不通的。
其實，仔細看看Hibernate的API，就會發現這個問題很好解決。在net.sf.hibernate包中有下面三個對我們很有用的介面：
1、Interface ScrollableResults
這個介面類似JDBC中的ResultSet一樣，提供了對返回結果集合的遍歷和欄位訪問方法，如：
public boolean next
public boolean previous() 遊標前移
public boolean scroll(int i) 遊標移動到指定未知
public void beforeFirst() 遊標在首記錄前
public void afterLast() 遊標在末記錄後
public Object[] get() 將當前記錄的欄位值以Object物件陣列形式返回
public Object get(int i) 將當前記錄的特定欄位值以Object物件形式返回
public Integer getInteger(int col) 將當前記錄的特定欄位值以Integer物件返回
public
public String getText(int col) 將當前記錄的特定欄位值以Text物件返回
public String getString(int col) 將當前記錄的特定欄位值以String物件返回
...等等
2、Interface Query
Query介面封裝了對資料庫的查詢等操作，在這裡，我們使用到它的原因是在於它的scroll()方法可以返回一個ScrollableResults例項：
public ScrollableResults scroll() 將查詢結果以ScrollableResults例項返回，但需要注意的是查詢返回的結果其實只是一些id，當需要的時候（比如我們使用ScrollableResults.next()方法後移遊標時）這條需要用到的記錄才會被真正初始化（這種技術可以稱作：延時初始化）
3、Interface Session
Session是Hibernate的核心中的核心，通過Session的createQuery()方法，我們能生成一個Query例項：
public Query
好了，瞭解了上面的三個介面，問題就能夠很好的解決了。需要如下幾個檔案：
Customer.java PO物件
Charge.java PO物件
TotalCharge.java 用於儲存統計結果Bean
Customer.hbm.xml PO對映
Charge.hbm.xml PO對映
TotalChargeDao.java 統計Dao定義
TotalChargeDaoImpl.java 統計Dao定義實現
DaoFactory.java Dao工廠
HibernateSessionFactory.java Session工廠
因為這裡主要討論的重點是對Customer和Charge的聯合查詢，所以Customer.java、Charge.java、Customer.hbm.xml、Charge.hbm.xml四個檔案以及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() { public TotalCharge(String name, Double fee, java.util.Date chargeTimeBegin, public void setName(String name) { public Double getFee() { public void setFee(Double fee) { public java.util.Date getChargeTimeBegin() { public void setChargeTimeBegin(java.util.Date chargeTimeBegin) { public java.util.Date getChargeTimeEnd() { public void setChargeTimeEnd(java.util.Date 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();//得到一個Hibernate Session //下面建立一個匿名Query例項並呼叫它的scroll()方法返回以ScrollableResults形式組織的查詢結果 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(); //將查詢結果放入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; } } |
看，現在問題解決了。坐下來，喝杯Java吧！