Oracle
 sql >> Datenbank >  >> RDS >> Oracle

Groovy Oracle Stored Proc - ungültiger Spaltenindex

Der folgende Code kann Ihnen helfen, die Variable SYS_REFCURSOR zu erhalten vom anonymen Oracle-Block.

Wir sollten uns auf einige wichtige Details konzentrieren:

  1. Klasse groovy.sql.Sql hat keinen entsprechenden OutParameter und wir machen es manuell als CURSOR_PARAMETER und übergeben Sie es an sql.call Methode
  2. Beachten Sie, dass der Block mit {call DECLARE beginnt und endet mit END } ohne Semikolon nach ENDE. Andernfalls können wir eine schlecht erkennbare SQLException erhalten ins Gesicht.
  3. Die Fragezeichen ? innerhalb des sqlString sind Orte für Parameterbindungen. Bindungen werden in der natürlichen Reihenfolge vorgenommen, indem Werte aus parametersList genommen werden .
    • In diesem Beispiel haben wir die einzige Bindung, also ? bindet mit CURSOR_PARAMETER und behandelt den Wert als OUT Parameter des übergebenen Typs;
  4. Es gibt nur einen Abschluss nach sql.call und ResultSet rs Zeilen des Cursors my_cur bereitstellen im anonymen Block deklariert.
  5. Wir können sqlString vereinfachen durch Verwendung einer Funktion, die SYS_REFCURSOR zurückgibt statt einer Prozedur mit OUT Parameter. 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.