| /** * 根据 DetachedCriteria 得 到 分页结果, 运行期间会根据 criteria 自动运算总行数, 注意如果 criteria 中 set 了 Projection, 则返回结果 List 中为 Projection 指定类型 * @param hibernateTemplate the hibernateTemplate * @param criteria the criteria * @param firstResult the first result row number * @param maxResults the max result * @return the pagination support * @throws org.springframework.dao.DataAccessException in case of Hibernate errors */ public static PaginationSupport findByCriteria(HibernateTemplate hibernateTemplate, final DetachedCriteria criteria, final int firstResult, final int maxResults) throws DataAccessException { return (PaginationSupport) hibernateTemplate.execute(new HibernateCallback() { public Object doInHibernate(Session session) throws HibernateException, SQLException { Criteria executableCriteria = criteria.getExecutableCriteria(session); // Get the orginal orderEntries OrderEntry[] orderEntries = HibernateUtils.getOrders(executableCriteria); // Remove the orders executableCriteria = HibernateUtils.removeOrders(executableCriteria); // get the original projection Projection projection = HibernateUtils.getProjection(executableCriteria); int totalCount = ((Integer) executableCriteria.setProjection(Projections.rowCount()).uniqueResult()).intValue(); executableCriteria.setProjection(projection); if (projection == null) { // Set the ResultTransformer to get the same object structure with hql executableCriteria.setResultTransformer(CriteriaSpecification.ROOT_ENTITY); } // Add the orginal orderEntries executableCriteria = HibernateUtils.addOrders(executableCriteria, orderEntries); // Now, the Projection and the orderEntries have been resumed List items = HibernateUtils.getPageResult(executableCriteria, firstResult, maxResults); return new PaginationSupport(items, totalCount, firstResult, maxResults); } }, true); } /** * 一些常用的 Hibernate 方法, 注意, 一些方法可能只适用于 Hibernate3.0.5 !!! * @see org.springframework.orm.hibernate3.HibernateTemplate * @since 2005-9-13 * @author 王政 * @version $Id: HibernateUtils.java,v 1.4 2005/09/19 01:00:28 wangzheng Exp $ */ public abstract class HibernateUtils { private static Log logger = LogFactory.getLog(HibernateUtils.class); public static final String CRITERIA_ASSERT_ERROR_MESSAGE = " 's type is not " + CriteriaImpl.class + ", please make sure you are using Hibernate3.0.5!!! "; /** * 将 Criteria 加上分页条件并输出结果 * @param criteria the criteria * @param offset the offset * @param maxPageItems the maxPageItems * @return the result list */ public static List getPageResult(Criteria criteria, int offset, int maxPageItems) throws HibernateException { criteria.setFirstResult(offset); criteria.setMaxResults(maxPageItems); return criteria.list(); } /** * 根据 DetachedCriteria 得 到 分页结果, 运行期间会根据 criteria 自动运算总行数, 注意如果 criteria 中 set 了 Projection, 则返回结果 List 中为 Projection 指定类型 * @param hibernateTemplate the hibernateTemplate * @param criteria the criteria * @param firstResult the first result row number * @param maxResults the max result * @return the pagination support * @throws org.springframework.dao.DataAccessException in case of Hibernate errors */ public static PaginationSupport findByCriteria(HibernateTemplate hibernateTemplate, final DetachedCriteria criteria, final int firstResult, final int maxResults) throws DataAccessException { return (PaginationSupport) hibernateTemplate.execute(new HibernateCallback() { public Object doInHibernate(Session session) throws HibernateException, SQLException { Criteria executableCriteria = criteria.getExecutableCriteria(session); // Get the orginal orderEntries OrderEntry[] orderEntries = HibernateUtils.getOrders(executableCriteria); // Remove the orders executableCriteria = HibernateUtils.removeOrders(executableCriteria); // get the original projection Projection projection = HibernateUtils.getProjection(executableCriteria); int totalCount = ((Integer) executableCriteria.setProjection(Projections.rowCount()).uniqueResult()).intValue(); executableCriteria.setProjection(projection); if (projection == null) { // Set the ResultTransformer to get the same object structure with hql executableCriteria.setResultTransformer(CriteriaSpecification.ROOT_ENTITY); } // Add the orginal orderEntries executableCriteria = HibernateUtils.addOrders(executableCriteria, orderEntries); // Now, the Projection and the orderEntries have been resumed List items = HibernateUtils.getPageResult(executableCriteria, firstResult, maxResults); return new PaginationSupport(items, totalCount, firstResult, maxResults); } }, true); } /** * 根据 hql 得 到 总行数 * @param hibernateTemplate * @param queryString hql * @param isNamedQuery 是否是 named query * @param paramNames 如果是 named query, 为 named query 中的参数名称, 否则无意义 * @param paramValues 参数值 * @return 满足条件的总行数 * @throws IllegalArgumentException if queryString is blank * @throws org.springframework.dao.DataAccessException in case of Hibernate errors */ public static int getTotalCount(HibernateTemplate hibernateTemplate, String queryString, boolean isNamedQuery, String[] paramNames, Object[] paramValues) throws IllegalArgumentException, DataAccessException { if (StringUtils.isBlank(queryString)) { throw new IllegalArgumentException(" queryString can't be blank "); } String countQueryString = " select count (*) " + JdbcUtils.removeSelect(JdbcUtils.removeOrders(queryString)); List countList; if (isNamedQuery) { countList = hibernateTemplate.findByNamedParam(countQueryString, paramNames, paramValues); } else { countList = hibernateTemplate.find(countQueryString, paramValues); } return ((Integer) countList.get(0)).intValue(); } /** * 从 criteria 中取得 {@link Projection}, 接口中没有公开此方法, 因此从 {@link CriteriaImpl} 中取得 * @see CriteriaImpl#getProjection() * @param criteria the criteria * @return the Projection */ public static Projection getProjection(Criteria criteria) { assertType(criteria); CriteriaImpl impl = (CriteriaImpl) criteria; return impl.getProjection(); } private static void assertType(Criteria criteria) { Assert.notNull(criteria, " criteria is required. "); String message = criteria + CRITERIA_ASSERT_ERROR_MESSAGE; if (! CriteriaImpl.class.isInstance(criteria)) { if (logger.isDebugEnabled()) { logger.debug(message); } throw new SkyonException(message); } } /** * μ玫? criteria 中的 OrderEntry[] * @param criteria the criteria * @return the OrderEntry[] */ public static OrderEntry[] getOrders(Criteria criteria) { assertType(criteria); CriteriaImpl impl = (CriteriaImpl) criteria; Field field = getOrderEntriesField(criteria); try { return (OrderEntry[]) ((List) field.get(impl)).toArray(new OrderEntry[0]); } catch (Exception e) { logAndThrowException(criteria, e); throw new InternalError(" Runtime Exception impossibility can't throw "); } } /** * 移除 criteria 中的 OrderEntry[] * @param criteria the criteria * @return the criteria after removed OrderEntry[] */ public static Criteria removeOrders(Criteria criteria) { assertType(criteria); CriteriaImpl impl = (CriteriaImpl) criteria; try { Field field = getOrderEntriesField(criteria); field.set(impl, new ArrayList()); return impl; } catch (Exception e) { log |
