?http://zjsoft.iteye.com/blog/143431

使用SQLQuery
對原生SQL查詢執行的控制是通過SQLQuery接口進行的，通過執行Session.createSQLQuery()獲取這個接口。最簡單的情況下，我們可以采用以下形式：

?

List?cats? = ?sess.createSQLQuery( " select?*?from?cats " ).addEntity(Cat. class ).list();

?

這個查詢指定了:

SQL查詢字符串

查詢返回的實體

這里，結果集字段名被假設為與映射文件中指明的字段名相同。對于連接了多個表的查詢，這就可能造成問題，因為可能在多個表中出現同樣名字的字段。下面的方法就可以避免字段名重復的問題:

?

List?cats? = ?sess.createSQLQuery( " select?{cat.*}?from?cats?cat " ).addEntity( " cat " ,?Cat. class ).list();

?

這個查詢指定了:

SQL查詢語句，它帶一個占位符，可以讓Hibernate使用字段的別名.

查詢返回的實體，和它的SQL表的別名.

addEntity()方法將SQL表的別名和實體類聯系起來，并且確定查詢結果集的形態。

addJoin()方法可以被用于載入其他的實體和集合的關聯.

?

List?cats? = ?sess.createSQLQuery(
" select?{cat.*},?{kitten.*}?from?cats?cat,?cats?kitten?where?kitten.mother?=?cat.id " )
.addEntity( " cat " ,?Cat. class )
.addJoin( " kitten " ,? " cat.kittens " )
.list();

?

原生的SQL查詢可能返回一個簡單的標量值或者一個標量和實體的結合體。

?

Double?max? = ?(Double)?sess.createSQLQuery( " select?max(cat.weight)?as?maxWeight?from?cats?cat " )
.addScalar( " maxWeight " ,?Hibernate.DOUBLE);
.uniqueResult();

?

除此之外，你還可以在你的hbm文件中描述結果集映射信息，在查詢中使用。

?

List?cats? = ?sess.createSQLQuery(
" select?{cat.*},?{kitten.*}?from?cats?cat,?cats?kitten?where?kitten.mother?=?cat.id " )
.setResultSetMapping( " catAndKitten " )
.list();

?

命名SQL查詢
可以在映射文檔中定義查詢的名字,然后就可以象調用一個命名的HQL查詢一樣直接調用命名SQL查詢.在這種情況下,我們不 需要調用addEntity()方法.

?

< sql - query?name = " persons " >
? < return ?alias = " person " ? class = " eg.Person " />
?Select?person.NAME?AS?{person.name},person.AGE?AS?{person.age},person.SEX?AS?{person.sex}?FROM?PERSON?person?Where?person.NAME?LIKE?:namePattern
</ sql - query >

?

List?people? = ?sess.getNamedQuery( " persons " ).setString( " namePattern " ,?namePattern)
.setMaxResults( 50 )
.list();

?

?

http://fishyych.iteye.com/blog/123328

在hibernate執行標準的sql，一開始寫了如下的代碼： java 代碼

public?List?querySQL(final?String?sql)?{ ??

????HibernateTemplate?ht?=?getHibernateTemplate(); ??

????return?(List)?ht.execute(new?HibernateCallback()?{ ??

????????????public?Object?doInHibernate(Session?session)?throws?HibernateException?{ ??

???????????????????try?{ ??

???????????????????????SQLQuery?query?=?session.createSQLQuery(sql); ??

???????????????????????return?query.list(); ??

???????????????????}?catch?(RuntimeException?e)?{ ??

???????????????????????log.error("query?sql?catch?exception:?"?,?e); ??

???????????????????????throw?e; ??

???????????????????} ??

????????????} ??

????????}); ??

} ??

執行一般的查詢還沒有問題，但是對于某些復雜的sql語句，比如如下這句：

??????? sql="select fact.inetip as item1,count(distinct(fact.mac)) as item2 from report_fact_t fact where " +
??????? "not exists (select * from netbar_outsideips_t ips where fact.inetip=ips.ip) " +
??????? "and terminallog_time=str_to_date('2007-09-04','%Y-%m-%d') group by inetip";
就會報出如下的異常：

java 代碼

[appfuse]?ERROR?[main]?LookupDaoHibernate.doInHibernate(56)?|?query?sql?catch?exception:? ??

org.hibernate.exception.SQLGrammarException:?could?not?execute?query ??

????at?org.hibernate.exception.SQLStateConverter.convert(SQLStateConverter.java:67) ??

????at?org.hibernate.exception.JDBCExceptionHelper.convert(JDBCExceptionHelper.java:43) ??

。。。 ??

??

Caused?by:?java.sql.SQLException:?Column?'inetip'?not?found. ??

????at?com.mysql.jdbc.SQLError.createSQLException(SQLError.java:910) ??

????at?com.mysql.jdbc.ResultSet.findColumn(ResultSet.java:955) ??

????at?com.mysql.jdbc.ResultSet.getString(ResultSet.java:5447)??

很是奇怪的報錯！查看了它的文檔，也沒有看到有啥特別的說明。最后通過試驗發現對于復雜的對象類型，必須用addScalar說明數據的類型，才能正常工作。修改后的代碼如下：

?

public?List?querySQL(final?String?sql,?final?Map<String,Type>?paramMap)?{ ??

????HibernateTemplate?ht?=?getHibernateTemplate(); ??

????return?(List)?ht.execute(new?HibernateCallback()?{ ??

????????????public?Object?doInHibernate(Session?session)?throws?HibernateException?{ ??

???????????????????try?{ ??

???????????????????????SQLQuery?query?=?session.createSQLQuery(sql); ??

???????????????????????Set?entrySet=paramMap.entrySet(); ??

???????????????????????for?(Iterator?it=entrySet.iterator();it.hasNext();)?{ ??

???????????????????????????Entry?entry=(Entry)it.next(); ??

???????????????????????????query=query.addScalar((String)entry.getKey(),(Type)entry.getValue()); ??

???????????????????????} ??

???????????????????????return?query.list(); ??

???????????????????}?catch?(RuntimeException?e)?{ ??

???????????????????????log.error("query?sql?catch?exception:?"?,?e); ??

???????????????????????throw?e; ??

???????????????????} ??

????????????} ??

????????}); ??

}??

外部調用的時候，要傳遞數據的類型：

java 代碼

???sql="select?fact.inetip?as?item1,count(distinct(fact.mac))?as?item2?from?report_fact_t?fact?where?"?+ ??

???"not?exists?(select?*?from?netbar_outsideips_t?ips?where?fact.inetip=ips.ip)?"?+ ??

???"and?terminallog_time=str_to_date('2007-09-04','%Y-%m-%d')?group?by?inetip"; ??

??

???Map?paramMap=new?HashMap(); ??

???paramMap.put("item1",?Hibernate.STRING); ??

???paramMap.put("item2",Hibernate.INTEGER); ??

??

List?results?=?dao.querySQL(sql,paramMap);??

修改以后就不會有問題啦

?

總結

以上是生活随笔為你收集整理的使用SQLQuery的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。