大部分情況下衣式，我們通過Projections和Restrictions摇幻、Example即可實現(xiàn),如果想要使用Criteria實現(xiàn)復(fù)雜的查詢對Hibernate Criteria相關(guān)接口不熟悉不行，下面介紹幾個關(guān)鍵接口：
Projection接口：封裝分組和投影轉(zhuǎn)化sql操作
Criterion接口：封裝操作轉(zhuǎn)化sql操作
如果需要實現(xiàn)特別的分組或投影可以實現(xiàn)這接口Projection帆谍，或繼承實現(xiàn)該接口類的子類允睹。實現(xiàn)以某個日期屬性中的月份分組。
//使用方式：Projections.projectionList().add(new ByGroupPropertyProjection("屬性名", StaticsType.天)))
public class ByGroupPropertyProjection extends PropertyProjection {
private static final long serialVersionUID = 1L;
private StaticsType dateType; // 分組時間類型
private String propertyName;
/*
* 作者：lzq 時間:2016年7月8日 修改記錄 修改者 時間 版本 說明
*/
/**
* @param prop
* @param grouped
*/
public ByGroupPropertyProjection(String prop, StaticsType dateType) {
super(prop, true);
// TODO Auto-generated constructor stub
this.dateType = dateType;
this.propertyName = prop;
}
/*
* （非 Javadoc） 作者：lzq 時間：2016年7月8日 修改記錄修改者 時間 版本 說明
*
* @see
* org.hibernate.criterion.PropertyProjection#toGroupSqlString(org.hibernate
* .Criteria, org.hibernate.criterion.CriteriaQuery)
*/
@Override
public String toGroupSqlString(Criteria criteria,
CriteriaQuery criteriaQuery) throws HibernateException {
// TODO Auto-generated method stub
return groupSqlString(criteria, criteriaQuery);
}
/*
* 作者：lzq 時間:2016年7月8日 修改記錄 修改者 時間 版本 說明
*/
/**
* 分組sql
*
* @param criteria
* @param criteriaQuery
* @return
*/
private String groupSqlString(Criteria criteria, CriteriaQuery criteriaQuery) {
String columns = StringHelper.join(", ",
criteriaQuery.getColumns(propertyName, criteria));
String result[] = columns.split(",");
for (int i = 0; i < result.length; ++i) {
result[i] = this.builderByGroups(result[i]);
}
return StringHelper.join(", ", result);
}
/*
* 作者：lzq 時間:2016年7月8日 修改記錄 修改者 時間 版本 說明
*/
/**
* 根據(jù)時間分組
*
* @param columns
* 列名
* @return
*/
private String builderByGroups(String columns) {
String groupSql = null;
switch (dateType) {
case 年:
groupSql = "year(" + columns + ")";
break;
case 月:
groupSql = "month(" + columns + ")";
break;
case 天:
groupSql = "day(" + columns + ")";
break;
case 小時:
groupSql = "hour(" + columns + ")";
break;
}
return groupSql;
}
}
public enum StaticsType {小時,天,月,年}
在投影中是用month函數(shù)涩堤，例子如下：
//使用方式：Projections.projectionList().add(new MonthDateExtractPropertyProjection("屬性名"))
public class MonthDateExtractPropertyProjection extends
AbstractDateExtractPropertyProjection {
private static final long serialVersionUID = 1L;
public MonthDateExtractPropertyProjection(String prop) {
super(prop);
// TODO Auto-generated constructor stub
}
protected String builderFunction(String columnName) {
// TODO Auto-generated method stub
return "MONTH(" + columnName + ")";
}}
//抽象日期抽取類
public abstract class AbstractDateExtractPropertyProjection extends
PropertyProjection {
private static final long serialVersionUID = 1L;
private String propertyName; // 屬性名
protected AbstractDateExtractPropertyProjection(String prop) {
super(prop);
// TODO Auto-generated constructor stub
this.propertyName = prop;
}
public String toSqlString(Criteria criteria, int position,
CriteriaQuery criteriaQuery) throws HibernateException {
// TODO Auto-generated method stub
StringBuilder buf = new StringBuilder();
String[] cols = criteriaQuery.getColumns(propertyName, criteria); // 根據(jù)屬性名獲取對應(yīng)字段名
for (int i = 0; i < cols.length; i++) {
buf.append(builderFunction(cols[i])).append(" as y")
.append(position + i).append('_');
if (i < cols.length - 1)
buf.append(", ");
}
return buf.toString();
}
public Type[] getTypes(Criteria criteria, CriteriaQuery criteriaQuery)
throws HibernateException {
// TODO Auto-generated method stub
return new Type[] { StandardBasicTypes.INTEGER };
}
/*
* 作者：lzq 時間:2016年7月9日 修改記錄 修改者 時間 版本 說明
*/
/**
* 構(gòu)建方法
*
* @param columnName
* 列名
* @return 包含方法參數(shù)的方法sql
*/
protected abstract String builderFunction(String columnName);
}
投影SUM中使用IFNULL函數(shù)，例子如下：
/**
* 創(chuàng)建時間：2016年7月9日
* 作者：lzq
*/
package cn.webapp.youjifen.staticbasic.projection;
import org.hibernate.Criteria;
import org.hibernate.HibernateException;
import org.hibernate.criterion.AggregateProjection;
import org.hibernate.criterion.CriteriaQuery;
/*
修改記錄
修改者 時間 版本 說明
*/
/**
* 重寫AggregateProjection類分瘾，使其支持IFNULL函數(shù)
*
* @author lzq
* @version v1.0
*
*/
public class AggregateProjectionSuportIfNull extends AggregateProjection {
/**
*
*/
private static final long serialVersionUID = 1L;
/*
* 作者：lzq 時間:2016年7月9日 修改記錄 修改者 時間 版本 說明
*/
/**
* @param functionName
* @param propertyName
*/
protected AggregateProjectionSuportIfNull(String functionName,
String propertyName) {
super(functionName, propertyName);
// TODO Auto-generated constructor stub
}
/*
* （非 Javadoc） 作者：lzq 時間：2016年7月9日 修改記錄修改者 時間 版本 說明
*
* @see
* org.hibernate.criterion.AggregateProjection#toSqlString(org.hibernate
* .Criteria, int, org.hibernate.criterion.CriteriaQuery)
*/
@Override
public String toSqlString(Criteria criteria, int loc,
CriteriaQuery criteriaQuery) throws HibernateException {
// TODO Auto-generated method stub
final String functionFragment = getFunction(criteriaQuery).render(
criteriaQuery.getType(criteria, getPropertyName()),
buildFunctionParameterList(criteria, criteriaQuery),
criteriaQuery.getFactory());
return "IFNULL(" + functionFragment + ",0) as y" + loc + '_';
}
}
//使用方式
//Projections.projectionList().add(new SumAggregateProjectionSuportIfNull("屬性名"))
public class SumAggregateProjectionSuportIfNull extends
AggregateProjectionSuportIfNull {
/**
*
*/
private static final long serialVersionUID = 1L;
/*
* 作者：lzq 時間:2016年7月9日 修改記錄 修改者 時間 版本 說明
*/
/**
* @param functionName
* @param propertyName
*/
public SumAggregateProjectionSuportIfNull(String propertyName) {
super("sum", propertyName);
// TODO Auto-generated constructor stub
}
} 