hibernate裏createSQLQuery

1、addEntity()和setResultTransformer()方法mysql

1.sql

使用SQLQuery
對原生SQL查詢執行的控制是經過SQLQuery接口進行的,經過執行Session.createSQLQuery()獲取這個接口。最簡單的狀況下,咱們能夠採用如下形式:
數據庫

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

這個查詢指定了:session

SQL查詢字符串oracle

查詢返回的實體app

這裏,結果集字段名被假設爲與映射文件中指明的字段名相同。對於鏈接了多個表的查詢,這就可能形成問題,由於可能在多個表中出現一樣名字的字段。下面的方法就能夠避免字段名重複的問題:函數

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

這個查詢指定了:this

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();

 

2.

使用hibernate3的createSQLQuery遇到的問題

爲了給訪問加速,把DAO中的一些HQL的操做改爲了SQL,其實最主要的緣由是:操做的是多張表,返回的數據也來源於多個表的字段;
String sql = 「select A.id ID, A.name NAME, B.salary SALARY from employee A , Salary B where.......」;
Query query =getSession().createSQLQuery(sql)
.setResultTransformer(Transformers.aliasToBean(ReturnEmployee.class));
因爲返回的ID, NAME, SALARY 非一個和表對應的一個BEAN,因此本身須要創建一個ReturnEmployee的BEAN,屬性包括ID, NAME, SALARY;在mysql下調試,成功。
可是在ORACLE環境下卻報錯:

org.hibernate.PropertyNotFoundException: Could not find setter for ID on class com.ReturnEmployee

通過幾個小時的查錯,調試,沒有發現問題的所在,只能擺脫GOOGLE了,最後在國外的一個論壇上找到了答案:

this is actually a limitation of some databases which return alias all uppercase instead of using the casing you actually specified.

until then use .addScalar(..) to workaround it.

原來是Hibernate對ORALCE的支持有BUG,因此修改代碼爲:
Query query = getSession().createSQLQuery(sql).addScalar("ID")
.addScalar("NAME").addScalar("SALARY");
就能夠了,須要注意的是
List employeeData = query.list();
返回的employeeData 中的數據是object[],這樣取值:
List employeeBean = new ArrayList();
for (int i = 0; i < employeeData.size(); i++) {
Employee employee = new Employee();//把"裸"數據組裝到本身的employee類

Object[] object = (Object[]) employeeData.get(i);
employee.setId(object[0].toString());
employee.setName(object[1].toString());
employee.setOrgType(object[2].toString());

employeeBean.add(employee);
}

另還能夠返回一個Map對象,也就是說在在list裏包含多個Map,代碼以下
Query query = session.createSQLQuery("select id,name from Tree t where pid in (select id from Tree) ").setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP); //
返回一個map,KEY:DB中名稱一致(大小寫一致)遍歷list時就能夠

Map map = (Map)list.get[i];

map.get("id");map.get("name");來取值。按你的SQL語句select後的字段名來做爲mapKey,但這個key必須與數據庫中的字段名如出一轍。


還能夠用做函數方面的。如
Query query = session.createSQLQuery("select sum(id) SUMID from Tree t where pid in (select id from Tree)
.addScalar("SUMID",Hibernate.INTEGER) //
轉換類型,按DB中的type

.setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP); //
返回一個map,KEY:DB中名稱一致(大小寫一致)

直接就map.get("SUMID")能夠取值了

 

還有一點就是這個方法在Hibernate3.2版本上才能正常運行。

 

 

查到如今,有了一些眉目,小結以下:

1oraclechar字段在hibernate裏映射爲character類型,是varchar的子集。

2,複雜SQLcreateSQLQuery方法查詢沒問題,若是查詢多個字段,遍歷用object[]造型,下標從0開始輸出值,不須要映射文件;若是願意能夠寫一個映射bean,方便取用。

3,若是查詢SQL中是隻有一個字段,那就不能用object[]數組接收,只能用object類接收,直接輸出object.toString(),便是這個字段的值。

4,能夠用addScalarString arg,Type type)方法定義要返回的字段類型,如

s.createSQLQuery(shuiQingHQL).addScalar("STCD",Hibernate.STRING).addScalar("STNM")

這樣就解決了CHAR字段類型只出一位字符的問題。

可是須要把其餘字段也addScalar()進來!

5addScalarString arg)裏的參數是須要大寫的!

 

2、SQLQuery增刪改查

Hibernate中使用SQLQuery的查詢:

            BaseHibernateDAO dao = new BaseHibernateDAO();
            //查詢語句
            String strSql  = " select * from hrrole h where h.code like ? and h.id <> ?";
            //設置查詢對象
            SQLQuery query = dao.getSession().createSQLQuery(strSql);
            //設置查詢參數
            query.setString(0,(String)this.getCode().getText());
            //設置查詢參數
            query.setString(1,this.getTextField1().getText().toString());
            //添加到一個類中
            query.addEntity(HrRole.class);
            //結果數據
            ArrayList<HrRole> idlist = (ArrayList<HrRole>) query.list();
            //判斷是否有值
            if(idlist.size() != 0){
                 //錯誤信息
                 this.label2.setText("代碼已存在");
            }

Hibernate中使用SQLQuery的更新:

    public void updateR(String Code,String NewCode){
         BaseHibernateDAO dao = new BaseHibernateDAO();
        try{
         Transaction tx = dao.getSession().beginTransaction();
         String sql1 = "update roleandgrant set rolecode = '" + Code + "'" + " where rolecode ='" + NewCode + "'";
         String sql2 = "update emprole set rolecode = '" + Code + "'" + " where rolecode ='" + NewCode + "'";
         SQLQuery query1 = dao.getSession().createSQLQuery(sql1);
         SQLQuery query2 = dao.getSession().createSQLQuery(sql2);
         query1.addEntity(RoleAndGrant.class);
         query2.addEntity(EmpVsRole.class);
         query2.executeUpdate();
         query1.executeUpdate();
         tx.commit();
         dao.closeSession();
        }catch(Exception ex){
            System.out.println(ex);
            dao.closeSession();
        }
    }

Hibernate中使用SQLQuery的刪除:

     public void DeleteR(String Code){         BaseHibernateDAO dao = new BaseHibernateDAO();         try{          Transaction tx = dao.getSession().beginTransaction();          String sql1 = "delete from  roleandgrant where rolecode ='" + Code + "'";          String sql2 = "delete from emprole where rolecode ='" + Code + "'";          SQLQuery query1 = dao.getSession().createSQLQuery(sql1);          SQLQuery query2 = dao.getSession().createSQLQuery(sql2);          query1.addEntity(RoleAndGrant.class);          query2.addEntity(EmpVsRole.class);          query2.executeUpdate();          query1.executeUpdate();          tx.commit();          dao.closeSession();         }catch(Exception ex){             System.out.println(ex);             dao.closeSession();         }     }

相關文章
相關標籤/搜索