5

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 Criteria でも可能かどうかはわかりません。

助けてくれてありがとう。

更新： 追加した答えが見つかりました

registerKeyword("partition");

registerFunctions メソッドの Oracle10gDialectExtended クラスに対して、期待どおりに動作するようになりました。

4

1 に答える 1

1

だから、私がこれをどのように機能させたかについての長い答えのために。これが、休止状態で ROW_NUMBER() ウィンドウ関数を使用する方法です。

他の誰かが同様のことをしようとしているかどうかはわかりませんが、私が持っている答えは部分的なものです. 私が行った更新により、データベースへのクエリでパーティションを正しく呼び出すことができましたが、ランク値を使用して結果を制限することはできませんでした。以下のコード変更により、クエリでランク値を使用できるようになりました。

既知の制限

  1. ランクは 1 としてコード化されています。コード内で数値を変更して src を再コンパイルする以外に数値を変更する方法は提供していません。
  2. これは setMaxResults でのみ機能します。同じクエリの WHERE 部分ではランク値を使用できないため、ラップして別のクエリで使用する必要があります。実行中のクエリに制限が必要だったので、これでうまくいきました。
  3. 使用できるパーティションは 1 つだけです。なぜ誰かが複数を使用するのかわかりませんが、私はそれをそこに置くだけだと思いました.
  4. パーティションはすべて小文字にする必要があります。そうでない場合は一致しません。
  5. 別名の「as」はすべて小文字です。大文字になるかどうかはわかりません。それが indexOf である場合、それはキャッチされません。

上記の Oracle10gDialectExtended クラスでは、さらに 2 つのメソッドを追加する必要があります。

/**
 * 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;
}

これらの変更により、基準クエリで他に何も変更せずにランク値を使用できました。出力クエリは次のようになります。

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 クエリを使用して、適切な場所にランク =1 の値を追加する方が簡単でした。

于 2013-10-10T14:29:48.227 に答える