美文网首页
使用Hibernate的Criteria解决复杂查询方案

使用Hibernate的Criteria解决复杂查询方案

作者: 罗正权 | 来源:发表于2016-07-10 18:00 被阅读635次

大部分情况下,我们通过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
    }
}  

相关文章

网友评论

      本文标题:使用Hibernate的Criteria解决复杂查询方案

      本文链接:https://www.haomeiwen.com/subject/foydjttx.html