大部分情况下，我们通过Projections和Restrictions、Example即可实现,如果想要使用Criteria实现复杂的查询对Hibernate Criteria相关接口不熟悉不行，下面介绍几个关键接口：
Projection接口：封装分组和投影转化sql操作
Criterion接口：封装操作转化sql操作
如果需要实现特别的分组或投影可以实现这接口Projection，或继承实现该接口类的子类。实现以某个日期属性中的月份分组。
//使用方式：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日 修改记录 修改者 时间 版本 说明
*/
/**
* 根据时间分组
*
* @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函数，例子如下：
//使用方式：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); // 根据属性名获取对应字段名
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日 修改记录 修改者 时间 版本 说明
*/
/**
* 构建方法
*
* @param columnName
* 列名
* @return 包含方法参数的方法sql
*/
protected abstract String builderFunction(String columnName);
}
投影SUM中使用IFNULL函数，例子如下：
/**
* 创建时间：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函数
*
* @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
}
} 