2013-11-27 7 views
12

私はMule ESBのスクリプトを使用して、Oracleストアドプロシージャ(カーソルを含む)から出力パラメータを取得し、例外を取得しています。Groovyを使用してOracleからカーソルを取得する方法は?

最小例:

import groovy.sql.Sql 
import oracle.jdbc.pool.OracleDataSource 
import oracle.jdbc.driver.OracleTypes 

def ds = new OracleDataSource() 
// setting data source parameters here 

def sql = new Sql(ds) 
def data = [] 

sql.call("""declare 
result_table sys_refcursor; 
begin 

open result_table for select 1 as a from dual; 

insert into CURSOR_TEST (ID) values (1); 
commit; 

${Sql.resultSet OracleTypes.CURSOR} := result_table; 

insert into CURSOR_TEST (ID) values (2); 
commit; 

end; 
""" 
){ table -> 

    throw new RuntimeException("Never getting this exception.") 

    table.eachRow { 
    data << it.toRowResult() 
    } 
} 

sql.close() 

return data 

エラー:CURSOR_TEST戻り12から


Message    : java.sql.SQLException: Closed Statement (javax.script.ScriptException) 
Code     : MULE_ERROR--2 
-------------------------------------------------------------------------------- 
Exception stack is: 
1. Closed Statement(SQL Code: 17009, SQL State: + 99999) (java.sql.SQLException) 
    oracle.jdbc.driver.SQLStateMapping:70 (null) 
2. java.sql.SQLException: Closed Statement (javax.script.ScriptException) 
    org.codehaus.groovy.jsr223.GroovyScriptEngineImpl:323 (http://java.sun.com/j2ee/sdk_1.3/techdocs/api/javax/script/ScriptException.html) 
3. java.sql.SQLException: Closed Statement (javax.script.ScriptException) 

(org.mule.api.transformer.TransformerException) org.mule.module.scripting.transformer.ScriptTransformer:39 (http://www.mulesoft.org/docs/site/current3/apidocs/org/mule/api/transformer/TransformerException.html) -------------------------------------------------------------------------------- Root Exception stack trace: java.sql.SQLException: Closed Statement at oracle.jdbc.driver.SQLStateMapping.newSQLException(SQLStateMapping.java:70) at oracle.jdbc.driver.DatabaseError.newSQLException(DatabaseError.java:133) at oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:199) + 3 more (set debug level logging or '-Dmule.verbose.exceptions=true' for everything) ********************************************************************************

Select

Oracleサーバーのバージョン:Oracle Database 11g Enterprise Edition Release 11.2.0.3.0 - 64bit Production

ミュールバージョン:3.5.0

私は、oracleクライアントのバージョン11.1.0.7.0からjdbc\lib\ojdbc6.jarを使用しています。

私は間違っていますか?

+1

あなたはミュール外のGroovyスクリプト内でそのコードを実行しようとしましたか? –

+0

@senia削除されたコメントの中で、あなたはJava実装を代わりに使用してこの問題を解決したと述べました。あなたの質問への答えとしてこのJavaコードを投稿し、それを受け入れることができますか?また、このGroovyの実装に何が間違っていたかを知る機会も与えます。 –

+1

@DavidDossot:ここには[私の回避策の例](http://pastebin.com/XWAzXCU5)があります。私はこれが私の質問への良い答えだとは思わない、ちょっとした助けを借りて良い古いJava。 – senia

答えて

1

次のコードは、SYS_REFCURSORの変数をOracleの匿名ブロックから取得するのに役立ちます。

我々はいくつかの重要な詳細に焦点を当てるべきである

  1. クラスgroovy.sql.SqlOutParameter対応する必要がないと我々はCURSOR_PARAMETERとして手動でそれを作ると
  2. は、ブロックが{call DECLAREで始まることを考えてみましょうsql.callメソッドに渡しENDの後にセミコロンなしでEND }で終わります。さもなければ私達は顔のほとんど認識できないSQLExceptionを得ることができます。
  3. sqlStringの中の疑問符?は、パラメータバインディングの場所です。バインディングは自然順序で行われます。この例では:INパラメータとして値を処理し、​​;
    • 最初?parametersListの最初の要素と結合します
    • 第2の?は、渡された型のパラメータOUTとして値を扱うCURSOR_PARAMETERとバインドします。
  4. 一つだけsql.call後に閉鎖に入るとResultSet rsが匿名ブロック内で宣言したカーソルmy_curの行を提供があります。

import groovy.sql.OutParameter 
import groovy.sql.Sql 
import oracle.jdbc.OracleTypes 

import java.sql.ResultSet 

def driver = 'oracle.jdbc.driver.OracleDriver' 
def sql = Sql.newInstance('jdbc:oracle:thin:@MY-SERVER:1521:XXX', 'usr', 'psw', driver) 

// special OutParameter for cursor type 
OutParameter CURSOR_PARAMETER = new OutParameter() { 
    public int getType() { 
     return OracleTypes.CURSOR; 
    } 
}; 

// look at some ceremonial wrappers around anonymous block 
String sqlString = """{call 
    DECLARE 
     my_cur SYS_REFCURSOR; 
     x VARCHAR2(32767) := ?; 
    BEGIN 

     OPEN my_cur 
     FOR 
     SELECT x || level AS my_column FROM dual CONNECT BY level < 10; 

     ? := my_cur; 
    END 
} 
"""; 

// the order of elements matches the order of bindings 
def parametersList = ["abc", CURSOR_PARAMETER]; 


// rs contains the result set of cursor my_cur 
sql.call(sqlString, parametersList) { ResultSet rs -> 
    while (rs.next()) { 
     println rs.getString("my_column") 
    } 
}; 
+0

ここで文字列補間を使用できますか?文字列補間なしでは、[回避策](http://pastebin.com/XWAzXCU5)よりも優れていません。ところで、私はあなたのソリューションをテストすることはできません。 Oracle DBインスタンスへのアクセス権がありません。 – senia

+0

ここで重要なのは、カスタムの 'OutParameter'です。他の部分は、通常のGroovyのものです。あなたが求めた結果を得るための最短の方法しか示していませんでした。だから、文字列補間を使うことができます。また、質問に「oracle」というタグが付いていますが、Oracle DBインスタンスが不足していると聞いて非常に驚いています。あなたは私がそれについて何をすると思いますか? – diziaq

+0

何もありません。私は、テストせずにあなたの答えを受け入れることはできません。私は来週末に試してみよう。問題は時代遅れです。それは3歳以上です。 – senia

関連する問題