java - 具有 Oracle 分析窗口功能的 Hibernate Criteria

Question

尝试覆盖 Oracle10gDialect 并添加 over 和 partition 函数。我在 hibernate.org 上阅读关于如何覆盖方言。我正在使用 Hibernate 4.1.7.Final 并且无法升级。我按照指定的方式实现了它，但是我收到了这个错误。

     15:21:21,353  WARN SqlExceptionHelper:143 - SQL Error: 907, SQLState: 42000
[10/8/13 15:21:21:354 CDT] 00000021 SystemOut     O ORA-00907: missing right parenthesis

[10/8/13 15:21:21:354 CDT] 00000021 SystemOut     O 15:21:21,354 ERROR SqlExceptionHelper:144 - ORA-00907: missing right parenthesis

这是我构建的类:

package com.edmann.util;

import org.apache.log4j.Logger;
import org.hibernate.dialect.Oracle10gDialect;
import org.hibernate.dialect.function.StandardSQLFunction;

/**
 * Because i need some analytic functions i am going to extend the
 * oracle10gDialect so i can register my functions i want to use.
 * 
 * @author Edward Mann
 * 
 */
public class Oracle10gDialectExtended extends Oracle10gDialect {
    // get log4j handler
    private static final Logger LOG = Logger
            .getLogger(Oracle10gDialectExtended.class);

    /**
     * Override registerFunctions so that we can register the ones we want to
     * use, then we will call the registerFunctions from the parent class.
     * 
     */
    @Override
    protected void registerFunctions() {
        LOG.info("Trying to register custom functions");
        registerFunction("over", new StandardSQLFunction("over"));
        registerFunction("partition", new StandardSQLFunction("partition"));
        super.registerFunctions();
    }
}

这是我在 hbm.xml 文件中的条目:

<property name="rank" type="integer" formula="(ROW_NUMBER() over(partition by ENTRY_NUMBER ORDER BY ENTRY_DATE DESC))"/>

我面临的挑战是防止 hibernate 添加 this_。到分区。在我链接到的 hibernate 论坛线程中，最后一个条目是一个有同样问题的人。我不确定 Hibernate Criteria 是否可以做到这一点。

感谢您的帮助。

更新:我找到了我添加的答案

registerKeyword("partition");

我的 Oracle10gDialectExtended 类在 registerFunctions 方法中，它现在按预期工作。

Answer 1

关于我如何让它工作的长篇回答。这是我如何在 hibernate 中使用我的 ROW_NUMBER() 窗口函数。

我不知道是否还有其他人想要做类似的事情，我得到的答案只是部分的。我提供的更新允许在对数据库的查询中正确调用分区依据，但我无法使用等级值来限制结果。我所做的以下代码更改允许我在查询中使用排名值。

已知限制

1. Rank 编码为 1，除了在代码中更改它并重新编译 src 之外，我没有提供更改数字的方法。
2. 这只适用于 setMaxResults。因为不能在同一查询的 WHERE 部分使用排名值，所以需要将其包装起来并在另一个查询中使用。我需要限制我正在运行的查询，所以这对我来说很好。
3. 您只能使用一个分区。我不知道为什么有人会使用多个，但我想我会把它放在那里。
4. 分区必须全部小写。如果不是，则不会匹配。
5. 命名别名的“as”全部小写。不确定它是否会是大写字母。如果它是 indexOf 将不会捕获它。

在上面提到的Oracle10gDialectExtended类中还需要增加两个方法

/**
 * I need to override the getLimitString so that i can append the partition
 * by column on the end. If partition is not found in the string then it
 * will not be added.
 */
@Override
public String getLimitString(String sql, boolean hasOffset) {
    // LOG.info("Using our getLimitString value");
    sql = sql.trim();
    String forUpdateClause = null;
    boolean isForUpdate = false;
    final int forUpdateIndex = sql.toLowerCase().lastIndexOf( "for update") ;
    if ( forUpdateIndex > -1 ) {
        // save 'for update ...' and then remove it
        forUpdateClause = sql.substring( forUpdateIndex );
        sql = sql.substring( 0, forUpdateIndex-1 );
        isForUpdate = true;
    }
    String rank = "";
    if (sql.contains("partition")) {
        rank = findRank(sql);

    }
    StringBuilder pagingSelect = new StringBuilder( sql.length() + 100 );
    if (hasOffset) {
        pagingSelect.append("select * from ( select row_.*, rownum rownum_ from ( ");
    }
    else {
        pagingSelect.append("select * from ( ");
    }
    pagingSelect.append(sql);
    if (hasOffset) {
        pagingSelect.append(" ) row_ where rownum <= ? ");
        pagingSelect.append(rank);
        pagingSelect.append(") where rownum_ > ?");
    }
    else {
        pagingSelect.append(" ) where rownum <= ?");
        pagingSelect.append(rank);
    }

    if ( isForUpdate ) {
        pagingSelect.append( " " );
        pagingSelect.append( forUpdateClause );
    }

    return pagingSelect.toString();
}

/**
 * Take our sql query find the partition line and pull off the hibernate
 * generated alias name.
 * 
 * @param sql
 * @return String - sql with rank limit
 */
private String addRank(String sql) {
    int partition = sql.indexOf("partition");
    String rank = "";
    if (partition != -1) {
        int start = partition;
        int end = sql.indexOf(',', start);
        String aliasName = end == -1 ? sql.substring(start) : sql
                .substring(start, end);
        int last = aliasName.indexOf("as");
        if (last != -1) {
           rank = " AND "+aliasName.substring(last + 2)+ " = 1";
        }
    }
    return rank;
}

通过这些更改，我能够使用我的排名值，而无需更改我的 Criteria 查询中的任何其他内容。输出查询类似于:

SELECT * FROM (SELECT ...
    ROW_NUMBER() over(partition BY this_.ENTRY_NUMBER ORDER BY this_.ENTRY_DATE DESC) AS formula1_22_,
... ) 
WHERE rownum <= 250 AND formula1_22_ =1

更新: 进行更改是因为我没有测试偏移量查询。排名被添加到查询的错误部分。采用原始 getLimitString 查询并在适当的地方添加 rank =1 值会更容易。