Poniższy kod może pomóc w uzyskaniu zmiennej SYS_REFCURSOR
z anonimowego bloku Oracle.
Powinniśmy skupić się na kilku kluczowych szczegółach:
- Klasa
groovy.sql.Sql
nie ma odpowiedniegoOutParameter
i robimy to ręcznie jakoCURSOR_PARAMETER
i przekaż go dosql.call
metoda - Uważ, że blok zaczyna się od
{call DECLARE
i kończy się naEND }
bez średnika po KONIEC. W przeciwnym razie możemy uzyskać słabo rozpoznawalnySQLException
w twarz. - Znaki zapytania
?
wewnątrzsqlString
to miejsca na powiązania parametrów. Wiązania są tworzone w naturalnej kolejności, przyjmując wartości zparametersList
.- W tym przykładzie mamy jedyne powiązanie, więc
?
wiąże się z CURSOR_PARAMETER traktując wartość jakoOUT
parametr przekazanego typu;
- W tym przykładzie mamy jedyne powiązanie, więc
- Jest tylko jeden wpis do zamknięcia po
sql.call
iResultSet rs
podaj wiersze kursoramy_cur
zadeklarowane w bloku anonimowym. - Możemy uprościć
sqlString
za pomocą funkcji zwracającejSYS_REFCURSOR
zamiast procedury zOUT
parametr. Może więc wyglądać tak"{call BEGIN ? := MY_FUNC(); END}"
lub nawet"{? = 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")
}
};
PS I dziękuję za pytanie.