Hibernate baseDao 바 텀 패키지
package com.test.main.core.dao;
import java.math.BigDecimal;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import javax.annotation.Resource;
import org.apache.commons.lang.StringUtils;
import org.hibernate.Hibernate;
import org.hibernate.Query;
import org.hibernate.SessionFactory;
import org.hibernate.transform.Transformers;
import org.springframework.dao.DataAccessException;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;
import org.springframework.stereotype.Repository;
import org.springframework.util.Assert;
import com.test.main.core.web.Page;
@Repository("hibernateGenericDao")
public class HibernateGenericDao<T> extends HibernateDaoSupport {
@Resource(name = "sessionFactory")
public void setSuperSessionFactory(SessionFactory sessionFactory) {
super.setSessionFactory(sessionFactory);
}
/**
* hql , HibernateTemplate find .
*
* @param values：
*/
@SuppressWarnings("unchecked")
public List<T> find(String hql, Object... values) throws DataAccessException {
Assert.hasText(hql);
return getHibernateTemplate().find(hql, values);
}
/**
* HQL .
*
* @param page . orderBy .
* @param hql hql .
* @param values , .
*
* @return , .
*/
@SuppressWarnings("unchecked")
public Page<T> findPage(final Page<T> page, final String hql, final Object... values) {
Assert.notNull(page, "page ");
Query q = createQuery(hql, values);
if (page.isAutoCount()) {
long totalCount = countHqlResult(hql, values);
page.setTotalCount(totalCount);
}
setPageParameterToQuery(q, page);
List result = q.list();
page.setResult(result);
return page;
}
/**
* HQL .
*
* @param page . orderBy .
* @param hql hql .
* @param values , .
*
* @return , .
*/
@SuppressWarnings("unchecked")
public Page<T> findPage(final Page<T> page, final String hql, Map paramMap) {
Assert.notNull(page, "page ");
Query q = createQuery(hql, paramMap);
if (page.isAutoCount()) {
long totalCount = countHqlResult(hql, paramMap);
page.setTotalCount(totalCount);
}
setPageParameterToQuery(q, page);
List result = q.list();
page.setResult(result);
return page;
}
/**
* SQL .
*
* @param page . orderBy .
* @param hql hql .
* @param values , .
*
* @return , .
*/
@SuppressWarnings("unchecked")
public Page findPageBySql(final Page page, final String sql, final Object... values) {
Assert.notNull(page, "page ");
Query q = createQuerySQL(sql, values);
if (page.isAutoCount()) {
long totalCount = countSqlResult(sql, values);
page.setTotalCount(totalCount);
}
q.setFirstResult(page.getFirst() - 1);
q.setMaxResults(page.getPageSize());
List result = q.list();
page.setResult(result);
return page;
}
// Map
@SuppressWarnings("unchecked")
public Page findPageBySql(final Page page, final String sql,boolean isReturnMap, final Object... values) {
Assert.notNull(page, "page ");
Query q = createQuerySQL(sql, values);
if (page.isAutoCount()) {
long totalCount = countSqlResult(sql, values);
page.setTotalCount(totalCount);
}
q.setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP);
q.setFirstResult(page.getFirst() - 1);
q.setMaxResults(page.getPageSize());
List result = q.list();
page.setResult(result);
return page;
}
/**
* SQL Query . find() .
*
* @param values , .
*/
public Query createQuerySQL(final String sql, final Object... values) {
Assert.hasText(sql, "sql ");
Query query = getSession().createSQLQuery(sql);
if (values != null) {
for (int i = 0; i < values.length; i++) {
query.setParameter(i, values[i]);
}
}
return query;
}
/**
* count sql .
*
* hql , hql count .
*/
protected long countSqlResult(final String hql, final Object... values) {
String countHql = prepareCountSQL(hql);
try {
Long count = findUniqueSQL(countHql, values);
return count;
} catch (Exception e) {
throw new RuntimeException("hql can't be auto count, hql is:" + countHql, e);
}
}
/**
* HQL Query . find() .
*
* @param values , .
*/
public Query createQuery(final String queryString, final Object... values) {
Assert.hasText(queryString, "queryString ");
Query query = getSession().createQuery(queryString);
if (values != null) {
for (int i = 0; i < values.length; i++) {
query.setParameter(i, values[i]);
}
}
return query;
}
/**
* HQL Query . find() .
*
* @param paramMap
*/
public Query createQuery(final String queryString, final Map<String,?> paramMap) {
Assert.hasText(queryString, "queryString ");
Query query = getSession().createQuery(queryString);
if (paramMap != null) {
Iterator<String> it= paramMap.keySet().iterator();
while (it.hasNext()) {
String key = (String) it.next();
Object value=paramMap.get(key);
if(value instanceof Object[]){
query.setParameterList(key, (Object[])value);
}else{
query.setParameter(key, value);
}
}
}
return query;
}
/**
* count SQL .
*
* hql , hql count .
*/
protected long countHqlResult(final String hql, final Object... values) {
String countHql = prepareCountHql(hql);
try {
Long count = findUnique(countHql, values);
return count;
} catch (Exception e) {
throw new RuntimeException("hql can't be auto count, hql is:" + countHql, e);
}
}
/**
* count SQL .
*
* hql , hql count .
*/
protected long countHqlResult(final String hql, final Map<String, Object> paramMap) {
String countHql = prepareCountHql(hql);
try {
Long count = findUnique(countHql, paramMap);
return count;
} catch (Exception e) {
throw new RuntimeException("hql can't be auto count, hql is:" + countHql, e);
}
}
private String prepareCountHql(String orgHql) {
String fromHql = orgHql;
// select order by count , .
fromHql = "from " + StringUtils.substringAfter(fromHql, "from");
fromHql = StringUtils.substringBefore(fromHql, "order by");
String countHql = "select count(*) " + fromHql;
return countHql;
}
private String prepareCountSQL(String orgSql) {
String countSql = "select count(*) from (" + orgSql+") tt";
return countSql;
}
/**
* SQL .
*
* @param values , .
*/
public Long findUniqueSQL(final String sql, final Object... values) {
return ((BigDecimal) createQuerySQL(sql, values).uniqueResult()).longValue();
}
/**
* HQL .
*
* @param values , .
*/
public Long findUnique(final String hql, final Object... values) {
return (Long) createQuery(hql, values).uniqueResult();
}
/**
* HQL .
*
* @param paramMap , .
*/
public Long findUnique(final String hql, final Map<String,Object> paramMap) {
return (Long) createQuery(hql, paramMap).uniqueResult();
}
/**
* Query , .
*/
protected Query setPageParameterToQuery(final Query q, final Page<T> page) {
Assert.isTrue(page.getPageSize() > 0, "Page Size must larger than zero");
// hibernate firstResult 0
q.setFirstResult(page.getFirst() - 1);
q.setMaxResults(page.getPageSize());
return q;
}
}
package com.test.main.core.dao;
import java.io.Serializable;
import java.util.Collection;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.hibernate.Criteria;
import org.hibernate.Query;
import org.hibernate.criterion.Criterion;
import org.hibernate.criterion.Order;
import org.springframework.dao.DataAccessException;
import com.test.main.core.web.Page;
public interface BaseDao {
/**
* 모든 대상 캐 시 지우 기
*/
public void clear() throws DataAccessException;
/**
* 여러 개의 실 체 를 지속 화 합 니 다.
*
* @ param entities: 임시 상태 에 있 는 실체의 집합.
* @throws DataAccessException
*/
void create(Collection entities) throws DataAccessException;
/**
* 실 체 를 영구적 으로 유지 합 니 다.
*
* @ param entity: 임시 상태 에 있 는 실체.
* @throws DataAccessException
*/
void create(T entity) throws DataAccessException;
/**
* 여러 개의 실 체 를 지속 하거나 업데이트 합 니 다.
*
* @ param entities: 임시 또는 지구 화 상태 에 있 는 실체의 집합.
* @throws DataAccessException
*/
void createOrUpdate(Collection entities) throws DataAccessException;
/**
* 실 체 를 지속 하거나 업데이트 합 니 다.
*
* @ param entity: 임시 또는 지구 화 상태 에 있 는 실체 입 니 다.
* @throws DataAccessException
*/
void createOrUpdate(T entity) throws DataAccessException;
/**
* 여러 개의 영구적 인 실 체 를 삭제 합 니 다.
*
* @ param entities: 지구 화 된 상태 에 있 는 실체의 집합.
* @throws DataAccessException
*/
void delete(Collection entities) throws DataAccessException;
/**
* 영구적 인 실 체 를 삭제 합 니 다.
*
* @ param entity: 지구 화 된 상태 에 있 는 실체.
* @throws DataAccessException
*/
void delete(T entity) throws DataAccessException;
/**
* ID 에 따라 대상 을 제거 합 니 다.
*/
public void deleteById(PK id) throws DataAccessException;
/**
* 하 이 버 네 이 트 세 션 과 의 연관 성 제거
*/
public void evit(T entity) throws DataAccessException;
/**
* 로 컬 sql 문 구 를 실행 하여 스칼라 수치 목록 을 가 져 와 Object 배열 로 되 돌려 줍 니 다.
*/
@SuppressWarnings("unchecked")
public List executeNativeSql(String sql) throws DataAccessException;
/**
* hql 문장 실행
*
* @param hql
* @throws DataAccessException
*/
public void executeUpdate(String hql) throws DataAccessException;
/**
* 로 컬 sql 문 구 를 실행 하여 스칼라 수치 목록 을 가 져 와 실체 대상 으로 되 돌려 줍 니 다.
*/
public List executeNativeSqlToClass(String sql) throws DataAccessException;
/**
* hql 조회 에 따라 HibernateTemplate 의 find 함 수 를 직접 사용 합 니 다.
*/
@SuppressWarnings("unchecked")
public List find(String hql, Object... values) throws DataAccessException;
public void flush();
/**
* ID 에 따라 대상 을 가 져 오고 대상 이 존재 하지 않 으 면 null 로 되 돌려 줍 니 다.
*/
public T get(PK id) throws DataAccessException;
/**
* 모든 대상 가 져 오기
*/
public List getAll() throws DataAccessException;
/**
* 모든 대상 을 가 져 오고 정렬 필드 와 승강 순서 파 라미 터 를 가 져 옵 니 다.
*/
public List getAll(String orderBy, boolean isAsc) throws DataAccessException;
/**
* ID 에 따라 대상 을 가 져 오고 대상 이 존재 하지 않 으 면 이상 을 던 집 니 다.
*/
public T load(PK id) throws DataAccessException;
/**
* 조회 HQL 과 매개 변수 목록 에 따라 Query 대상 을 만 듭 니 다. find () 함수 와 함께 더욱 유연 하 게 작업 할 수 있 습 니 다.
*
* @ param values 이름 의 매개 변 수 는 이름 에 따라 연 결 됩 니 다.
*/
public Query createQuery(final String queryString, final Map values);
/**
* 조회 HQL 과 매개 변수 목록 에 따라 Query 대상 을 만 듭 니 다. find () 함수 와 함께 더욱 유연 하 게 작업 할 수 있 습 니 다.
*
* @ param values 수량 가 변 적 인 매개 변 수 를 순서대로 연결 합 니 다.
*/
public Query createQuery(final String queryString, final Object... values);
/**
* Criterion 조건 에 따라 Criteria 를 만 들 고 find () 함수 와 더욱 유연 한 조작 을 할 수 있 습 니 다.
*
* @ param criterions 수량 가 변 적 인 Criterion.
*/
public Criteria createCriteria(final Criterion... criterions);
/**
* 유리 상태 에 있 는 여러 개의 실 체 를 저장 하고 업 데 이 트 된 후에 도 실체 대상 은 유리 상태 에 있 습 니 다.
*
* @ param entities: 유리 상태 에 있 는 실체의 집합.
* @throws DataAccessException
*/
void merge(Collection entities) throws DataAccessException;
/**
* 유리 상태 에 있 는 실 체 를 업데이트 하고 업데이트 후 실체 대상 은 유리 상태 에 있 습 니 다.
*
* @ param entity: 유리 상태 에 있 는 실체.
* @throws DataAccessException
*/
void merge(T entity) throws DataAccessException;
/**
* 페이지 별 조회
*
* @ param page: 페이지 대상
* @ param hql: hql 문장
* @ param values: 매개 변수 값
* @ return page: 대상
* @throws DataAccessException
*/
Page findPage(Page page, String hql, Object... values) throws DataAccessException;
Page findPage(Page page, String hql, Map paramMap) throws DataAccessException;
/**
* 페이지 별 조회
*
* @ param page: 페이지 대상
* @ param sql: hql 문장
* @ param values: 매개 변수 값
* @ return page: 대상
* @throws DataAccessException
*/
Page findPageBySQL(Page page, String sql, Object... values) throws DataAccessException;
/**
* 여러 개의 실 체 를 업데이트 합 니 다.
*
* @ param entities: 지구 화 된 상태 에 있 는 실체의 집합.
* @throws DataAccessException
*/
void update(Collection entities) throws DataAccessException;
/**
* 실체 업데이트.
*
* @ param entity: 지구 화 된 상태 에 있 는 실체.
* @throws DataAccessException
*/
void update(T entity) throws DataAccessException;
/**
* Criteria 를 누 르 면 대상 목록 을 조회 합 니 다.
*
* @ param criterions 수량 가 변 적 인 Criterion.
*/
List find(final Criterion... criterions);
/**
* 속성 필터 조건 목록 에 따라 대상 목록 을 찾 습 니 다.
*/
List find(List filters);
List find(List filters,List orders);
List find(HashMap aliasMap, List filters);
/**
* count 조 회 를 실행 하면 이번 Criteria 조회 에서 얻 을 수 있 는 대상 의 총 수 를 얻 을 수 있 습 니 다.
*/
long countCriteriaResult(final Criteria c);
/**
* Criteria 페이지 별로 조회.
*
* @ param page 페이지 매개 변수.
* @ param criterions 수량 가 변 적 인 Criterion.
*
* @ return 페이지 조회 결과. 결과 목록 및 모든 조회 입력 파 라미 터 를 첨부 합 니 다.
*/
@SuppressWarnings("unchecked")
public Page findPage(final Page page, final Criterion... criterions);
/**
* 속성 필터 조건 목록 에 따라 페이지 별로 대상 을 찾 습 니 다.
*/
Page findPage(final Page page, final List filters);
} package com.test.main.core.dao;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import javax.annotation.Resource;
import org.apache.commons.lang.StringUtils;
import org.apache.log4j.LogManager;
import org.apache.log4j.Logger;
import org.hibernate.Criteria;
import org.hibernate.Query;
import org.hibernate.SessionFactory;
import org.hibernate.criterion.CriteriaSpecification;
import org.hibernate.criterion.Criterion;
import org.hibernate.criterion.DetachedCriteria;
import org.hibernate.criterion.Disjunction;
import org.hibernate.criterion.MatchMode;
import org.hibernate.criterion.Order;
import org.hibernate.criterion.Projection;
import org.hibernate.criterion.Projections;
import org.hibernate.criterion.Restrictions;
import org.hibernate.impl.CriteriaImpl;
import org.hibernate.transform.ResultTransformer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Scope;
import org.springframework.dao.DataAccessException;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;
import org.springframework.util.Assert;
import com.test.main.core.dao.PropertyFilter.MatchType;
import com.test.main.core.web.Page;
import com.test.main.util.ReflectionUtils;
@Scope("prototype")
public class BaseDaoHibernate<T, PK extends Serializable> extends HibernateDaoSupport implements BaseDao<T, PK> {
@Autowired
private HibernateGenericDao<T> hibernateGenericDao;
protected final Logger logger = LogManager.getLogger(BaseDaoHibernate.class);
protected Class<T> entityClass;
public BaseDaoHibernate() {
}
public BaseDaoHibernate(Class<T> entityClass) {
this.entityClass = entityClass;
}
public void clear() throws DataAccessException {
getHibernateTemplate().clear();
}
public void create(Collection<T> entities) throws DataAccessException {
if (entities != null && entities.size() > 0) {
Iterator<T> it = entities.iterator();
for (T e = null; it.hasNext();) {
e = it.next();
create(e);
}
}
}
public void create(T entity) throws DataAccessException {
getHibernateTemplate().save(entity);
}
public void createOrUpdate(Collection<T> entities) throws DataAccessException {
if (entities != null && entities.size() > 0) {
Iterator<T> it = entities.iterator();
for (T e = null; it.hasNext();) {
e = it.next();
createOrUpdate(e);
}
}
}
public void createOrUpdate(T entity) throws DataAccessException {
getHibernateTemplate().saveOrUpdate(entity);
}
public void delete(Collection<T> entities) throws DataAccessException {
if (entities != null && entities.size() > 0) {
Iterator<T> it = entities.iterator();
for (T e = null; it.hasNext();) {
e = it.next();
delete(e);
}
}
}
public void delete(T entity) throws DataAccessException {
super.getHibernateTemplate().delete(entity);
}
public void deleteById(PK id) throws DataAccessException {
delete(get(id));
}
public void evit(T entity) throws DataAccessException {
getHibernateTemplate().evict(entity);
}
/**
* sql Object
*/
@SuppressWarnings("unchecked")
public List executeNativeSql(String sql) throws DataAccessException {
return getSession().createSQLQuery(sql).list();
}
@SuppressWarnings("unchecked")
public void executeUpdate(String hql) throws DataAccessException {
getSession().createQuery(hql).executeUpdate();
}
/**
* sql
*/
@SuppressWarnings("unchecked")
public List<T> executeNativeSqlToClass(String sql) throws DataAccessException {
return getSession().createSQLQuery(sql).addEntity(this.entityClass).list();
}
@SuppressWarnings("unchecked")
public List<T> find(String hql, Object... values) throws DataAccessException {
return hibernateGenericDao.find(hql, values);
}
/**
* HQL Query . find() .
*
* @param values , .
*/
public Query createQuery(final String queryString, final Map<String, ?> values) {
Assert.hasText(queryString, "queryString ");
Query query = hibernateGenericDao.createQuery(queryString,values);
return query;
}
/**
* HQL Query . find() .
*
* @param values , .
*/
public Query createQuery(final String queryString, final Object... values) {
Assert.hasText(queryString, "queryString ");
Query query = getSession().createQuery(queryString);
if (values != null) {
for (int i = 0; i < values.length; i++) {
query.setParameter(i, values[i]);
}
}
return query;
}
/**
* Criterion Criteria. find() .
*
* @param criterions Criterion.
*/
public Criteria createCriteria(final Criterion... criterions) {
Criteria criteria = getSession().createCriteria(entityClass);
for (Criterion c : criterions) {
criteria.add(c);
}
return criteria;
}
public void flush() throws DataAccessException {
getHibernateTemplate().flush();
}
public T get(PK id) throws DataAccessException {
return (T) getHibernateTemplate().get(entityClass, id);
}
public List<T> getAll() throws DataAccessException {
return (List<T>) (getHibernateTemplate().loadAll(entityClass));
}
@SuppressWarnings("unchecked")
public List<T> getAll(String orderBy, boolean isAsc) throws DataAccessException {
Assert.hasText(orderBy);
if (isAsc)
return getHibernateTemplate().findByCriteria(
DetachedCriteria.forClass(entityClass).addOrder(Order.asc(orderBy)));
else
return getHibernateTemplate().findByCriteria(
DetachedCriteria.forClass(entityClass).addOrder(Order.desc(orderBy)));
}
public T load(PK id) throws DataAccessException {
return (T) getHibernateTemplate().load(entityClass, id);
}
public void merge(Collection<T> entities) throws DataAccessException {
if (entities != null && entities.size() > 0) {
Iterator<T> it = entities.iterator();
for (T e = null; it.hasNext();) {
e = it.next();
merge(e);
}
}
}
public void merge(T entity) throws DataAccessException {
super.getHibernateTemplate().merge(entity);
}
public Page<T> findPage(Page<T> page, String hql, Object... values) throws DataAccessException {
return hibernateGenericDao.findPage(page, hql, values);
}
public Page<T> findPage(Page<T> page, String hql, Map<String,Object> paramMap) throws DataAccessException {
return hibernateGenericDao.findPage(page, hql, paramMap);
}
@Resource(name = "sessionFactory")
public void setSuperSessionFactory(SessionFactory sessionFactory) {
super.setSessionFactory(sessionFactory);
}
public void update(Collection<T> entities) throws DataAccessException {
if (entities != null && entities.size() > 0) {
Iterator<T> it = entities.iterator();
for (T e = null; it.hasNext();) {
e = it.next();
update(e);
}
}
}
public void update(T entity) throws DataAccessException {
getHibernateTemplate().update(entity);
}
/**
* Criteria .
*
* @param criterions Criterion.
*/
@SuppressWarnings("unchecked")
public List<T> find(final Criterion... criterions) {
DetachedCriteria criteria = DetachedCriteria.forClass(entityClass);
for (Criterion c : criterions) {
criteria.add(c);
}
return getHibernateTemplate().findByCriteria(criteria);
}
/**
* Criteria .
*
* @param criterions Criterion.
*/
@SuppressWarnings("unchecked")
public List<T> find(List<Order> orders,final Criterion... criterions) {
DetachedCriteria criteria = DetachedCriteria.forClass(entityClass);
for (Criterion c : criterions) {
criteria.add(c);
}
for (Order order : orders) {
criteria.addOrder(order);
}
return getHibernateTemplate().findByCriteria(criteria);
}
/**
* Criteria .
*
* @param criterions Criterion.
*/
@SuppressWarnings("unchecked")
public List<T> find(final HashMap<String, String> aliasMap, final Criterion... criterions) {
DetachedCriteria criteria = DetachedCriteria.forClass(entityClass);
if (aliasMap != null) {
Iterator<String> iterator = aliasMap.keySet().iterator();
while (iterator.hasNext()) {
String alias = (String) iterator.next();
criteria.createAlias(alias, aliasMap.get(alias));
}
}
for (Criterion c : criterions) {
criteria.add(c);
}
return getHibernateTemplate().findByCriteria(criteria);
}
/**
* .
*/
public List<T> find(List<PropertyFilter> filters) {
Criterion[] criterions = buildCriterionByPropertyFilter(filters);
return find(criterions);
}
/**
* .
*/
public List<T> find(List<PropertyFilter> filters,List<Order> orders) {
Criterion[] criterions = buildCriterionByPropertyFilter(filters);
return find(orders,criterions);
}
/**
* .
*/
public List<T> find(HashMap<String, String> aliasMap, List<PropertyFilter> filters) {
Criterion[] criterions = buildCriterionByPropertyFilter(filters);
return find(aliasMap, criterions);
}
/**
* Criterion, .
*/
protected Criterion buildCriterion(final String propertyName, final Object propertyValue, final MatchType matchType) {
Assert.hasText(propertyName, "propertyName ");
Criterion criterion = null;
// MatchType criterion
switch (matchType) {
case EQ:
criterion = Restrictions.eq(propertyName, propertyValue);
break;
case LIKE:
criterion = Restrictions.like(propertyName, (String) propertyValue, MatchMode.ANYWHERE);
break;
case LE:
criterion = Restrictions.le(propertyName, propertyValue);
break;
case LT:
criterion = Restrictions.lt(propertyName, propertyValue);
break;
case GE:
criterion = Restrictions.ge(propertyName, propertyValue);
break;
case GT:
criterion = Restrictions.gt(propertyName, propertyValue);
}
return criterion;
}
/**
* Criterion , .
*/
protected Criterion[] buildCriterionByPropertyFilter(final List<PropertyFilter> filters) {
List<Criterion> criterionList = new ArrayList<Criterion>();
for (PropertyFilter filter : filters) {
if (!filter.hasMultiProperties()) { // .
Criterion criterion = buildCriterion(filter.getPropertyName(), filter.getMatchValue(), filter
.getMatchType());
criterionList.add(criterion);
} else {// , or .
Disjunction disjunction = Restrictions.disjunction();
for (String param : filter.getPropertyNames()) {
Criterion criterion = buildCriterion(param, filter.getMatchValue(), filter.getMatchType());
disjunction.add(criterion);
}
criterionList.add(disjunction);
}
}
return criterionList.toArray(new Criterion[criterionList.size()]);
}
/**
* count Criteria .
*/
@SuppressWarnings("unchecked")
public long countCriteriaResult(final Criteria c) {
CriteriaImpl impl = (CriteriaImpl) c;
// Projection、ResultTransformer、OrderBy , Count
Projection projection = impl.getProjection();
ResultTransformer transformer = impl.getResultTransformer();
List<CriteriaImpl.OrderEntry> orderEntries = null;
try {
orderEntries = (List) ReflectionUtils.getFieldValue(impl, "orderEntries");
ReflectionUtils.setFieldValue(impl, "orderEntries", new ArrayList());
} catch (Exception e) {
logger.error(" :{}", e);
}
// Count
Long totalCountObject = (Long) c.setProjection(Projections.rowCount()).uniqueResult();
long totalCount = (totalCountObject != null) ? totalCountObject : 0;
// Projection,ResultTransformer OrderBy
c.setProjection(projection);
if (projection == null) {
c.setResultTransformer(CriteriaSpecification.ROOT_ENTITY);
}
if (transformer != null) {
c.setResultTransformer(transformer);
}
try {
ReflectionUtils.setFieldValue(impl, "orderEntries", orderEntries);
} catch (Exception e) {
logger.error(" :{}", e);
}
return totalCount;
}
/**
* Criteria .
*
* @param page .
* @param criterions Criterion.
*
* @return . .
*/
@SuppressWarnings("unchecked")
public Page<T> findPage(final Page<T> page, final Criterion... criterions) {
Assert.notNull(page, "page ");
Criteria c = createCriteria(criterions);
if (page.isAutoCount()) {
long totalCount = countCriteriaResult(c);
page.setTotalCount(totalCount);
}
setPageParameterToCriteria(c, page);
List result = c.list();
page.setResult(result);
return page;
}
/**
* Criteria , .
*/
protected Criteria setPageParameterToCriteria(final Criteria c, final Page<T> page) {
Assert.isTrue(page.getPageSize() > 0, "Page Size must larger than zero");
// hibernate firstResult 0
c.setFirstResult(page.getFirst() - 1);
c.setMaxResults(page.getPageSize());
if (page.isOrderBySetted()) {
String[] orderByArray = StringUtils.split(page.getOrderBy(), ',');
String[] orderArray = StringUtils.split(page.getOrder(), ',');
Assert.isTrue(orderByArray.length == orderArray.length, " , ");
for (int i = 0; i < orderByArray.length; i++) {
if (Page.ASC.equals(orderArray[i])) {
c.addOrder(Order.asc(orderByArray[i]));
} else {
c.addOrder(Order.desc(orderByArray[i]));
}
}
}
return c;
}
/**
* .
*/
public Page<T> findPage(final Page<T> page, final List<PropertyFilter> filters) {
Criterion[] criterions = buildCriterionByPropertyFilter(filters);
return findPage(page, criterions);
}
@SuppressWarnings("unchecked")
public Page<T> findPageBySQL(Page<T> page, String sql, Object... values) throws DataAccessException {
return hibernateGenericDao.findPageBySql(page, sql, values);
}
@SuppressWarnings("unchecked")
public Page<T> findPageBySQL(Page<T> page, String sql,boolean isReturnMap, Object... values) throws DataAccessException {
return hibernateGenericDao.findPageBySql(page, sql,isReturnMap, values);
}
}
응용 예:package com.test.crawler.initcrawler.dao;
import java.util.List;
import com.test.crawler.core.dao.BaseDao;
import com.test.crawler.core.dao.Page;
import com.test.crawler.initcrawler.entity.UrlFilter;
public interface UrlFilterDao extends BaseDao<UrlFilter, String> {
/**
* ， .
* @param note
* @param stauts
* @return
*/
public List<UrlFilter> findUrlFilterByNoteAndStruts(String note,String status);
/**
* ，
* @param note
* @param stauts
* @param type
* @return
*/
public List<UrlFilter> findFilterByType(String note,String stauts,String type);
package com.test.crawler.initcrawler.dao.imp;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;
import com.test.crawler.core.dao.BaseDaoHibernate;
import com.test.crawler.core.dao.Page;
import com.test.crawler.initcrawler.dao.UrlFilterDao;
import com.test.crawler.initcrawler.entity.UrlFilter;
@Repository("urlFilterDao")
public class UrlFilterDaoImp extends BaseDaoHibernate<UrlFilter,String> implements UrlFilterDao {
@Autowired
private JdbcTemplate jdbcTemplate;
public UrlFilterDaoImp() {
super(UrlFilter.class);
}
public List<UrlFilter> findUrlFilterByNoteAndStruts(String note,
String status) {
String hql = "FROM UrlFilter t WHERE t.node=? and t.status=?";
return this.find(hql, note,status);
}
public List<UrlFilter> findFilterByType(String note,String stauts,String type){
String hql = " FROM UrlFilter t WHERE t.node=? and t.status=? and t.type=?";
return this.find(hql, note, stauts, type);
}
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
다양한 언어의 JSONJSON은 Javascript 표기법을 사용하여 데이터 구조를 레이아웃하는 데이터 형식입니다. 그러나 Javascript가 코드에서 이러한 구조를 나타낼 수 있는 유일한 언어는 아닙니다. 저는 일반적으로 '객체'{}...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
