Der folgende Code kann Ihnen helfen, die Variable SYS_REFCURSOR zu erhalten vom anonymen Oracle-Block.
Wir sollten uns auf einige wichtige Details konzentrieren:
- Klasse
groovy.sql.Sqlhat keinen entsprechendenOutParameterund wir machen es manuell alsCURSOR_PARAMETERund übergeben Sie es ansql.callMethode - Beachten Sie, dass der Block mit
{call DECLAREbeginnt und endet mitEND }ohne Semikolon nach ENDE. Andernfalls können wir eine schlecht erkennbareSQLExceptionerhalten ins Gesicht. - Die Fragezeichen
?innerhalb dessqlStringsind Orte für Parameterbindungen. Bindungen werden in der natürlichen Reihenfolge vorgenommen, indem Werte ausparametersListgenommen werden .- In diesem Beispiel haben wir die einzige Bindung, also
?bindet mit CURSOR_PARAMETER und behandelt den Wert alsOUTParameter des übergebenen Typs;
- In diesem Beispiel haben wir die einzige Bindung, also
- Es gibt nur einen Abschluss nach
sql.callundResultSet rsZeilen des Cursorsmy_curbereitstellen im anonymen Block deklariert. - Wir können
sqlStringvereinfachen durch Verwendung einer Funktion, dieSYS_REFCURSORzurückgibt statt einer Prozedur mitOUTParameter. Es könnte also so aussehen"{call BEGIN ? := MY_FUNC(); END}"oder sogar"{? = 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. Und danke für die Frage.