Следният код може да ви помогне да получите променлива на SYS_REFCURSOR
от анонимен блок на Oracle.
Трябва да се съсредоточим върху няколко ключови подробности:
- Клас
groovy.sql.Sql
няма съответенOutParameter
и го правим ръчно катоCURSOR_PARAMETER
и го предайте наsql.call
метод - Вземете предвид, че блокът започва с
{call DECLARE
и завършва сEND }
без точка и запетая след END. В противен случай можем да получим лошо разпознаваемоSQLException
в лицето. - Въпросителните знаци
?
вътре вsqlString
са места за свързване на параметри. Свързванията се правят в естествен ред, като се вземат стойности отparametersList
.- В този пример имаме единственото обвързване, така че
?
се свързва с CURSOR_PARAMETER, третирайки стойността катоOUT
параметър от предаден тип;
- В този пример имаме единственото обвързване, така че
- Има само едно влизане в затварянето след
sql.call
иResultSet rs
осигурете редове на курсораmy_cur
деклариран в анонимен блок. - Можем да опростим
sqlString
чрез използване на функция, връщащаSYS_REFCURSOR
вместо процедура сOUT
параметър. Така че може да изглежда така"{call BEGIN ? := MY_FUNC(); END}"
или дори"{? = call MY_FUNC()}"
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;
BEGIN
STORED_PROCEDURE_NAME(my_cur);
? := my_cur;
END
}
""";
// the order of elements matches the order of bindings
def parametersList = [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")
}
};
P.S. И благодаря за въпроса.