如何使用Groovy從Oracle獲取遊標？

Question

我在Mule ESB中使用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 

錯誤：

---

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從CURSOR_TEST返回1和2。

Oracle服務器版本：Oracle Database 11g Enterprise Edition Release 11.2.0.3.0 - 64bit Production。

Mule版本：3.5.0。

我正在使用jdbc\lib\ojdbc6.jar從oracle客戶端版本11.1.0.7.0。

我在做什麼錯？

Answer 1

以下代碼可以幫助您從Oracle匿名塊獲取變量SYS_REFCURSOR。

我們應該關注幾個關鍵細節：

1. 類groovy.sql.Sql沒有相應OutParameter，我們手動進行它CURSOR_PARAMETER並把它傳遞給sql.call方法
2. 認爲阻滯{call DECLARE開始END結束後以END }結束，不含分號。否則，我們可能會得到一個難以辨認的SQLException。
3. sqlString內的問號?是參數綁定的地方。綁定按自然順序進行。在這個例子中：
   • 第一?與第一元件結合在parametersList：​​，治療值作爲IN參數;
   • 第二個?與CURSOR_PARAMETER綁定處理值爲OUT傳遞類型的參數;
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") 
    } 
};