Kode berikut dapat membantu Anda mendapatkan variabel SYS_REFCURSOR dari blok anonim Oracle.
Kita harus fokus pada beberapa detail utama:
- Kelas
groovy.sql.Sqltidak memilikiOutParameteryang sesuai dan kita buat secara manual sebagaiCURSOR_PARAMETERdan berikan kesql.callmetode - Pertimbangkan bahwa blok dimulai dengan
{call DECLAREdan diakhiri denganEND }tanpa titik koma setelah END. Kalau tidak, kita bisa mendapatkanSQLExceptionyang tidak dapat dikenali dengan baik di wajah. - Tanda tanya
?di dalamsqlStringadalah tempat untuk pengikatan parameter. Binding dibuat dalam urutan alami dengan mengambil nilai dariparametersList.- Dalam contoh ini kita memiliki satu-satunya pengikatan, jadi
?mengikat dengan CURSOR_PARAMETER memperlakukan nilai sebagaiOUTparameter tipe yang diteruskan;
- Dalam contoh ini kita memiliki satu-satunya pengikatan, jadi
- Hanya ada satu masuk ke penutupan setelah
sql.calldanResultSet rsberikan baris kursormy_curdideklarasikan dalam blok anonim. - Kita dapat menyederhanakan
sqlStringdengan menggunakan fungsi yang mengembalikanSYS_REFCURSORalih-alih prosedur denganOUTparameter. Jadi bisa terlihat seperti ini"{call BEGIN ? := MY_FUNC(); END}"atau bahkan"{? = 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. Dan terima kasih atas pertanyaannya.