sql >> Database >  >> RDS >> Oracle

Groovy Oracle Stored Proc - ongeldige kolomindex

De volgende code kan u helpen om een ​​variabele van SYS_REFCURSOR . te krijgen van Oracle anoniem blok.

We moeten ons concentreren op een paar belangrijke details:

  1. Klasse groovy.sql.Sql heeft geen corresponderende OutParameter en we maken het handmatig als CURSOR_PARAMETER en geef het door aan sql.call methode
  2. Bedenk dat het blok begint met {call DECLARE en eindigt met END } zonder puntkomma na END. Anders krijgen we een slecht herkenbare SQLException in het gezicht.
  3. De vraagtekens ? binnen de sqlString zijn plaatsen voor parameterbindingen. Bindingen worden gemaakt in de natuurlijke volgorde en nemen waarden uit parametersList .
    • In dit voorbeeld hebben we de enige binding, dus de ? bindt met CURSOR_PARAMETER en behandelt de waarde als OUT parameter van doorgegeven type;
  4. Er is slechts één enter in afsluiting na sql.call en ResultSet rs geef rijen met cursor my_cur gedeclareerd in anoniem blok.
  5. We kunnen sqlString vereenvoudigen door een functie te gebruiken die SYS_REFCURSOR . retourneert in plaats van een procedure met OUT parameter. Het zou er dus zo uit kunnen zien "{call BEGIN ? := MY_FUNC(); END}" of zelfs "{? = 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 En bedankt voor de vraag.




  1. PHP-array vult zich niet met mysql-gegevens

  2. Zoekwaarde in alle tabellen van database

  3. mysql_fetch_array slaat eerste rij over

  4. Stappen om MySQL8 op CentOS te installeren