最近在整合springsecurity,由于表间都是用的多对多,所以当要join取数据时,传统的ORM思想带来性能问题,HQL语句写的太大,所以就想采用传统的SQL.现记录如下,留做后用.
这里只留关键程序.其它的忽略.
/**根据手工创建的sql语句来查询,返回指定的class对象 * @param sqlQuery * @param clazz * @return */ public List<? extends BaseModel> findListBySQLQuery(String sqlQuery, Class<? extends BaseModel> clazz) { Query q= getSession().createSQLQuery(sqlQuery); q.setResultTransformer(new CustomResultTransformer(clazz)); return q.list(); }如果你的系统里没有BaseModel,将上面的去掉就是了.
CustomResultTransformer 是从一个同学的博客里抄来的.这里就不写出来了,大家可以在javaeye上搜索一下.
最后的效果就是,比如执行SELECT a.id, a.roleName FROM dbo.role a INNER JOIN groupRole c ON a.roleId = c.roleId INNER JOIN dbo.groups b ON c.groupID = b.groupID inner join dbo.groupUser d on b.groupId=d.groupID inner join dbo.users e on d.userid=e.userid WHERE (e.userName =?).然后我们有一个VO类userinfo,那么这个VO类里的id,roleName都会被set上值,其它的属性忽略.并且不报错.
人生从此就舒坦了.
当然,学好HQL才是我们的正途,这些歪门邪道的还是少用的好.
下面是最新的代码，解决了3个问题，
1.如果没有对应的set则不注入。以前是报错。
2.如果从数据库中取出的是空，也不注入。以前是报错。
3.如果从数据库中取出的值 类型不对，刚强制转换为setter需要的值。
/* * (#)CustomResultTransformer.java 1.0 2010-6-21 */package com.framework.hibernate.util;import java.lang.reflect.Field;import java.util.List;import org.apache.commons.beanutils.ConvertUtils;import org.apache.commons.lang.ArrayUtils;import org.hibernate.HibernateException;import org.hibernate.property.ChainedPropertyAccessor;import org.hibernate.property.PropertyAccessor;import org.hibernate.property.PropertyAccessorFactory;import org.hibernate.property.Setter;import org.hibernate.transform.ResultTransformer; /** * 本类的使用意义 2.public List<?> findObjectBySql(String queryString,Class<?> pojoClass){ 3. //使用SQL构造查询对象，此SQL是可以被JDBC接受的SQL，如SELECT * FROM XXX_TABLE 4. Query query = * this.getSession().createSQLQuery(queryString); 5. //设置结果集转换器，这是本文重点所在 6. query.setResultTransformer(new CustomResultTransformer(pojoClass)); 7. //返回查询结果 8. return query.list(); * 自定义的数据库字库转换成POJO */public class CustomResultTransformer implements ResultTransformer{ private static final long serialVersionUID = 1L; private final Class resultClass; private Class[] clazz; private Setter[] setters; private final PropertyAccessor propertyAccessor; public CustomResultTransformer ( Class resultClass ) { if ( resultClass == null ) throw new IllegalArgumentException ( "resultClass cannot be null" ); this.resultClass = resultClass; propertyAccessor = new ChainedPropertyAccessor ( new PropertyAccessor[] { PropertyAccessorFactory.getPropertyAccessor ( resultClass , null ), PropertyAccessorFactory.getPropertyAccessor ( "field" ) } ); } // 结果转换时，HIBERNATE调用此方法 public Object transformTuple ( Object[] tuple , String[] aliases ) { Object result; try { if ( setters == null ) {// 首先初始化，取得目标POJO类的所有SETTER方法 setters = new Setter[aliases.length]; clazz = new Class[aliases.length]; for ( int i = 0 ; i < aliases.length ; i++ ) { String alias = aliases[i]; if ( alias != null ) { // 我的逻辑主要是在getSetterByColumnName方法里面，其它都是HIBERNATE的另一个类中COPY的 // 这里填充所需要的SETTER方法 setters[i] = getSetterByColumnName ( alias , i ); } } } result = resultClass.newInstance ( ); // 这里使用SETTER方法填充POJO对象 for ( int i = 0 ; i < aliases.length ; i++ ) { if ( setters[i] != null && tuple[i] != null ) { try { setters[i].set ( result , ConvertUtils.convert ( tuple[i] , clazz[i] ) , null ); } catch ( SecurityException e ) { e.printStackTrace ( ); } } } } catch ( InstantiationException e ) { throw new HibernateException ( "Could not instantiate resultclass: " + resultClass.getName ( ) ); } catch ( IllegalAccessException e ) { throw new HibernateException ( "Could not instantiate resultclass: " + resultClass.getName ( ) ); } return result; } // 根据数据库字段名在POJO查找JAVA属性名，参数就是数据库字段名，如：USER_ID private Setter getSetterByColumnName ( String alias , int index ) { // 取得POJO所有属性名 Field[] fieldsSuperClass = resultClass.getSuperclass ( ).getDeclaredFields ( ); Field[] fieldsMine = resultClass.getDeclaredFields ( ); Field[] fields = (Field[]) ArrayUtils.addAll ( fieldsSuperClass , fieldsMine ); if ( fields == null || fields.length == 0 ) { throw new RuntimeException ( "实体" + resultClass.getName ( ) + "不含任何属性" ); } // 把字段名中所有的下杠去除 String proName = alias.replaceAll ( "_" , "" ).toLowerCase ( ); for ( Field field : fields ) { if ( field.getName ( ).toLowerCase ( ).equals ( proName ) ) { // 去除下杠的字段名如果和属性名对得上，就取这个SETTER方法 clazz[index] = field.getType ( ); return propertyAccessor.getSetter ( resultClass , field.getName ( ) ); } } //throw new RuntimeException("找不到数据库字段 ：" + alias + " 对应的POJO属性或其getter方法，比如数据库字段为USER_ID或USERID，那么JAVA属性应为userId"); return null; } public List transformList ( List collection ) { return collection; } }