在平時開發中Hibernate提供的hql基本能夠滿足我們的日常需求。但是在有些特殊的情況下，還是需要使用原生的
sql,并且希望sql查詢出來的結果能夠綁定到pojo上。hibernate API中的createSQLQuery 和createQuery接口。
就像在這次的項目中，因為表結構要變化，有個新的需求：
要從一個表中查詢極個別的字段并且還有幾個是求多條數據的和的，之前一直在使用
hibernate的API，使用的都是映射過得對象。
原對象及表結構是這樣的：
@Entity @Table(name="T_BILL_ACCT_ITEM") @NamedQuery(name="TBillAcctItem.findAll", query="SELECT t FROM TBillAcctItem t") public class TBillAcctItem implements Serializable { private static final long serialVersionUID = 1L; @Id @Column(name="ACCT_ITEM_ID") private long acctItemId; @Column(name="ACCT_ID") private long acctId; @Column(name="BILLING_CYCLE_ID") private String billingCycleId; @Column(name="PRODUCT_ID") private String productId; @Column(name="SERVICE_ID") private String serviceId; @Column(name="ACCT_ITEM_CODE") private String acctItemCode; @Column(name="ORIGINAL_AMOUNT") private int originalAmount; @Column(name="CDR_DISCOUNT") private int cdrDiscount; @Column(name="ACCT_DISCOUNT") private int acctDiscount; @Column(name="RECE_AMOUNT") private int receAmount; @Column(name="REAL_AMOUNT") private int realAmount; @Column(name="CHARGE_OFF_SOURCE") private int chargeOffSource; @Column(name="STATE") private int state;但是我現在需要查詢出來的信息是這樣的一個pojo類：
public class ProductBillInfo implements Serializable{ private static final long serialVersionUID = 1L; private String productId;//產品標識 private String serverId;//服務標示 private int realAmount;//實收金額（sum求和） private int receAmount;//應收金額（sum求和） private int state;//賬目狀態 private String billingCycle;//賬期(月)因為
hibernate要查詢的對象是要和表結構一一映射的，現在求和字段這些個是映射不了的，
之前的方法就有問題了。 找了很多看了hibernate的API 找到這個東西。 如下：
大概的使用過程：
StringBuffer b = new StringBuffer(); //... 省略SQL拼接代碼 String sql = b.toString(); SQLQuery query = session.createSQLQuery(sql); query.addScalar("productId", StandardBasicTypes.STRING);//要查詢出來的字段、類型 List<ProductBillInfo> lnfo =query.list();下面是我用到的查詢pojo的方法中的實現:
@SuppressWarnings("unchecked") public List<ProductBillInfo> findByAcctIdAndCycle1(long acctId, String cycleBegin, String cycleEnd, int state){ List<String> cycles = DateUtil.getAllCycle(cycleBegin, cycleEnd); StringBuffer buf = new StringBuffer(); buf.append("select t.PRODUCT_ID as productId , t.SERVICE_ID as serviceId ," + "sum(t.REAL_AMOUNT) as realAmount ,sum(t.RECE_AMOUNT) as receAmount ," + "t.STATE as state ,t.BILLING_CYCLE_ID as billingCycleId " + " from T_BILL_ACCT_ITEM t where t.STATE= '" + state + "' AND t.ACCT_ID='" + acctId + "' AND t.BILLING_CYCLE_ID in ("); StringBuffer bf = new StringBuffer(); for(String id : cycles){ if(bf.toString().equals("")){ bf.append("'"+id+"'"); } else{ bf.append(","+"'"+id+"'"); } } buf.append(bf.toString()); buf.append(") GROUP BY t.PRODUCT_ID,t.BILLING_CYCLE_ID,t.SERVICE_ID"); SQLQuery query = getSession().createSQLQuery(buf.toString()); query.addScalar("productId", StandardBasicTypes.STRING); query.addScalar("serviceId", StandardBasicTypes.STRING); query.addScalar("realAmount", StandardBasicTypes.INTEGER); query.addScalar("receAmount", StandardBasicTypes.INTEGER); query.addScalar("state", StandardBasicTypes.INTEGER); query.addScalar("billingCycleId", StandardBasicTypes.STRING); query.setResultTransformer(Transformers.aliasToBean(ProductBillInfo.class)); List<ProductBillInfo> lnfo =query.list(); return lnfo; }需要說明的一點是
query.addScalar("deviceId",Hibernate.STRING); ，老版本的使用的數據的類型都是 org.hibernate.type包下面的，
新版本的是在：org.
hibernate.type.StandardBasicTypes包下面的
并且在
語法中要使用到in（‘’、‘’、‘’）的語法，于是寫了下面的一個拼接小方法：
public static void main(String[] args) { List<String> c = new ArrayList<String>(); c.add("1");c.add("2");c.add("3"); StringBuffer bf = new StringBuffer(); for(String id : c){ if(bf.toString().equals("")){ bf.append("'"+id+"'"); } else{ bf.append(","+"'"+id+"'"); } } System.out.println(bf.toString()); } 打印結果是： '1','2','3'
使用StringBuffer拼接到原生的
sql語句中
轉自：http://www.aichengxu.com/view/35553
posted on 2015-08-12 09:41
長春語林科技 閱讀(815)
評論(0) 編輯 收藏 所屬分類:
hibernate