Hibernate在from子句中使用子查询
最近用到了Hibernate来作为数据处理部分的框架，离线criteria的确很好用，但在分页上确实让人头疼。要想分页就需要记录的总条数，如果只是一般的查询只需要
/** * 因为需要修改sql，就要传入你新的sql，criteria必须是绑定session的 * 因为我们用到了session * @param sql * @param criteria * @return */public static List<List> wrapAndExecute(String sql, Criteria criteria) {ResultSet rs = null;//最后的结果集PreparedStatement ps = null;//我们自己的PreparedStatementConnection connection = null;//session中获取的连接try {//先转型CriteriaImpl criteriaImpl = (CriteriaImpl) criteria;//获取SessionImplementor类型的sessionSessionImplementor session = criteriaImpl.getSession();//获取factorySessionFactoryImplementor factory = session.getFactory();//获取CriteriaQueryTranslator对象，按照Hibernate源码中的方式生成CriteriaQueryTranslator translator = new CriteriaQueryTranslator(factory, criteriaImpl, criteriaImpl.getEntityOrClassName(), CriteriaQueryTranslator.ROOT_SQL_ALIAS);//从CriteriaQueryTranslator对象中获取保存参数的QueryParameters对象QueryParameters queryParameters = translator.getQueryParameters();//从factory中获取implementors，一般只用一个String[] implementors = factory.getImplementors(criteriaImpl.getEntityOrClassName());//因为只用一个，所以只需要一个loader，按照Hibernate源码中的方式新建//注意有些地方由于非public所以需要用反射，反射部分代码就不贴了，注意invokeMethod要从子类找到父类，直到object//因为有些方法是写在父类中的Loader loader = new CriteriaLoader((OuterJoinLoadable) ReflectUtil.invokeMethod(session,"getOuterJoinLoadable", new Class[] { String.class }, new Object[] { implementors[0] }), factory,criteriaImpl, implementors[0], ((SessionImpl) session).getLoadQueryInfluencers());//按照Hibernate源码方法获取walkerCriteriaJoinWalker walker = new CriteriaJoinWalker((OuterJoinLoadable) factory.getEntityPersister(implementors[0]), translator, factory, criteriaImpl, criteriaImpl.getEntityOrClassName(), session.getLoadQueryInfluencers());//获取了criteria的sqlString criteriaSql = walker.getSQLString();//用传入的sql代替，注意PLACEHOLDER代表criteriaSql的占位符sql = sql.replace(PLACEHOLDER, criteriaSql);//获取session中的连接connection = session.getJDBCContext().getConnectionManager().getConnection();//构建新的PreparedStatementps = connection.prepareStatement(sql);//注意一定要过滤过参数才能绑定queryParameters.processFilters(criteriaSql, session);//通过反射绑定参数ReflectUtil.invokeMethod(loader, "bindParameterValues", new Class[] { PreparedStatement.class,QueryParameters.class, int.class, SessionImplementor.class }, new Object[] { ps, queryParameters,1, session });//获取结果集rs = session.getBatcher().getResultSet(ps);......