JPA 查询原生SQL 转换VO对象
梵法利亚 人气:1JPA查询原生SQL转换VO对象
List<String> sqlList = RiverCourseSql.getRiverCourseSQLString(new RiverCourseDataQO()); List<RiverCourseDataVO> riverCourseDataVO = rsvrfsrBDao.executeNativeQuery2Obj(sqlList.get(0), new PageQO(), RiverCourseDataVO.class);
查询sql,然后执行功能方法。
<E> List<E> executeNativeQuery2Obj(String sql, SortQO sortQO, Class<E> clz); public <E> List<E> executeNativeQuery2Obj(String sql, SortQO sortQO, Class<E> clz) { Query query = this.entityManager.createNativeQuery(sql); this.setAliasParameter(query, sortQO); ((NativeQueryImpl)query.unwrap(NativeQueryImpl.class)).setResultTransformer(Transformers.aliasToBean(clz)); List<E> resultList = query.getResultList(); return resultList; }
JPA非注解方式原生sql查询的一些注意事项
背景:DDD系统里面有复杂的聚合统计,代码组装数据不方便
import javax.persistence.EntityManager; import javax.persistence.Query; @Autowired private EntityManager entityManager;
这里直接用自定义VO接收,sql返回结果集必须是VO的子集,不然组装数据会报错,说白了就是sql查询结果的字段必须全在vo里对应,vo可以有多余字段,但sql结果不能有多余字段
String sql = "sql"; Query nativeQuery = entityManager.createNativeQuery(sql);
给sql里动态传参设置参数 := param ,注意in后面传数组的话,根据版本不一样,有的要加括号,有的不要加,直接传数据进去就行
nativeQuery.setParameter(String var1, Object var2);
这是当前不过时的方法,将sql查询结果转成自定义VO
Transformers可以转成list和vo,nativeQueryImplementor也能转成list和vo
NativeQueryImplementor nativeQueryImplementor = nativeQuery.unwrap(NativeQueryImpl.class).setResultTransformer(Transformers.aliasToBean(VO.class)); VO vo = new VO(); try { // 这里有个坑,如果返回结果为空的话,会报错,要捕获这个异常,再进一步操作 vo = (VO)nativeQueryImplementor.getSingleResult(); } catch (EntityNotFoundException e) { e.printStackTrace(); return vo ; }
目前就这些了。
以上为个人经验,希望能给大家一个参考,也希望大家多多支持。
加载全部内容