sql >> Database teknologi >  >> RDS >> Oracle

Sådan skriver du et java.sql.Array til et java.sql.SQLOutput i SQLData.writeSQL() for Oracle

Her er, hvad jeg gjorde for at løse dette problem. Det er ikke kønt, men det virker.

Jeg tilføjede en metode i min klasse, der implementerede SQLData der modtager en java.sql.Connection og opsætter den tilsvarende java.sql.ARRAY genstande.

Noget som dette:

public class MyObject01 implements SQLData {
   private String value;
   private MyObject02[] details; // do note that details is a java array
   // ... also added getters and setters for these two properties

   private Array detailsArray;

   public void setupArrays(oracle.jdbc.OracleConnection oconn)
      throws SQLException
   {
       detailsArrays = oconn.createARRAY(MyObject02.ORACLE_OBJECT_ARRAY_NAME, getDetails());
       // MyObject02.ORACLE_OBJECT_ARRAY_NAME must be the name of the oracle "table of" type name
       // Also note that in Oracle you can't use JDBC's default createArray
       // since it's not supported. That's why you need to get a OracleConnection
       // instance here. 
   }       

   @Override
   public void writeSQL(Stream stream) throws SQLException {
       stream.writeString(getValue());
       stream.writeArray(detailsArray); // that's it
   }

   @Override
   public void readSQL(Stream stream) throws SQLException {
       setValue(stream.readString());
       Array array = stream.readArray();
       if (array != null) {
           setDetails((MyObject02[])array.getArray());
       }
   }

Det er den første del.

Inden du bruger det objekt i et procedurekald, skal du derefter kalde setupArrays metode på det pågældende objekt. Eksempel:

public class DB {
    public static String executeProc(Connection conn, MyObject01 obj)
        throws SQLException
    {
        CalllableStatement cs = conn.prepareCall(" { ? = call sch.proc(?) }");
        cs.registerOutParameter(1, Types.VARCHAR);
        obj.setupArrays((oracle.jdbc.Connection)conn);
        cs.setObject(2, obj, Types.STRUCT);
        cs.executeUpdate();
        String ret = cs.getString(1);
        cs.close();
        return ret;
    }
}

Ved tilslutning skal du selvfølgelig registrere dine typer korrekt:

Connection conn = DriverManager.getConnection("jdbc:oracle://localhost:1521/XE", "scott", "tiger" );
conn.getTypeMap().put(MyObject01.ORACLE_OBJECT_NAME, MyObject01.class);
conn.getTypeMap().put(MyObject02.ORACLE_OBJECT_NAME, MyObject02.class);
conn.getTypeMap().put(MyObject02.ORACLE_OBJECT_ARRAY_NAME, MyObject02[].class);

Håber det hjælper.



  1. Mysql Tæller de på hinanden følgende rækker, der matcher

  2. Hvornår skal man bruge CSV-lagringsmotor til MySQL?

  3. Tilføj tidsstempelkolonne med standard NOW() kun for nye rækker

  4. Dublerede poster i DB