Como chamar o procedimento armazenado oracle que inclui o tipo definido pelo usuário em java?

No Oracle DB:

Eu tenho o seguinte procedimento armazenado:

procedure getInfo ( p_ids IN IDS_TABLE, p_details OUT cursor ) 

O tipo IDS_TABLE é:

 create or replace type IDS_TABLE as table of IDS create or replace type IDS as object ( id1 NUMBER, id2 NUMBER, id3 NUMBER ) 

Como posso chamar o getInfo em Java?

Configurar um link entre objects Oracle SQL e objects java manualmente não é uma tarefa trivial. Em particular, arrays (ou tabelas aninhadas) de objects definidos pelo usuário são mais complexos para passar de java para Oracle do que arrays de tipos de dados padrão. Em outras palavras, é mais fácil chamar um procedimento com assinatura:

 (TABLE OF NUMBER, TABLE OF NUMBER, TABLE OF NUMBER)` 

do que um procedimento cuja assinatura é:

 (TABLE OF (NUMBER, NUMBER, NUMBER)) < - your case 

Você pode escrever um wrapper em torno de seu procedimento para transformar o segundo caso no primeiro caso.


Dito isto, não é de longe impossível mapear o seu procedimento. O exemplo a seguir é amplamente inspirado em um post de Tom Kyte . Tom descreve como mapear uma TABLE OF NUMBER usando oracle.sql.ARRAY . No seu caso, também teremos que usar oracle.sql.STRUCT para mapear o object SQL do IDS .

Você também pode querer procurar o documento do Oracle JDBC, em particular o capítulo Trabalhando com os Tipos de Objetos do Oracle .

Primeiro é uma configuração semelhante à sua:

 SQL> CREATE OR REPLACE TYPE IDS AS OBJECT ( id1 NUMBER, id2 NUMBER, id3 NUMBER ); 2 / Type created SQL> CREATE OR REPLACE TYPE IDS_TABLE AS TABLE OF IDS; 2 / Type created SQL> CREATE OR REPLACE PROCEDURE getInfo(p_ids IN IDS_TABLE) IS 2 BEGIN 3 FOR i IN 1 .. p_ids.COUNT LOOP 4 dbms_output.put_line(p_ids(i).id1 5 || ',' || p_ids(i).id2 6 || ',' || p_ids(i).id3); 7 END LOOP; 8 END getInfo; 9 / Procedure created 

Este é o procedimento java:

 SQL> CREATE OR REPLACE 2 AND COMPILE JAVA SOURCE NAMED "ArrayDemo" 3 as 4 import java.io.*; 5 import java.sql.*; 6 import oracle.sql.*; 7 import oracle.jdbc.driver.*; 8 9 public class ArrayDemo { 10 11 public static void passArray() throws SQLException { 12 13 Connection conn = 14 new OracleDriver().defaultConnection(); 15 16 17 StructDescriptor itemDescriptor = 18 StructDescriptor.createDescriptor("IDS",conn); 19 20 Object[] itemAtributes = new Object[] {new Integer(1), 21 new Integer(2), 22 new Integer(3)}; 23 STRUCT itemObject1 = new STRUCT(itemDescriptor,conn,itemAtributes); 24 25 itemAtributes = new Object[] {new Integer(4), 26 new Integer(5), 27 new Integer(6)}; 28 STRUCT itemObject2 = new STRUCT(itemDescriptor,conn,itemAtributes); 29 30 STRUCT[] idsArray = {itemObject1,itemObject2}; 31 32 ArrayDescriptor descriptor = 33 ArrayDescriptor.createDescriptor( "IDS_TABLE", conn ); 34 35 ARRAY array_to_pass = 36 new ARRAY( descriptor, conn, idsArray ); 37 38 OraclePreparedStatement ps = 39 (OraclePreparedStatement)conn.prepareStatement 40 ( "begin getInfo(:x); end;" ); 41 42 ps.setARRAY( 1, array_to_pass ); 43 ps.execute(); 44 45 } 46 } 47 / Java created 

Vamos chamá-lo:

 SQL> CREATE OR REPLACE 2 PROCEDURE show_java_calling_plsql 3 AS LANGUAGE JAVA 4 NAME 'ArrayDemo.passArray()'; 5 / Procedure created SQL> exec show_java_calling_plsql ; 1,2,3 4,5,6 PL/SQL procedure successfully completed 

Este é um bom exemplo. se você vir java.sql.SQLException: padrão de nome inválido: ainda. Verifique o escopo do tipo que você declarou no Oracle. Eu estou usando o Oracle 11g e tive que declarar o object de seqüência de caracteres e tabela de objects do meu tipo no nível de esquema. Passou cerca de 3 horas e descobriu isso.

 oracle.sql.StructDescriptor docObjDescriptor = StructDescriptor.createDescriptor("SSIADM.DOCUMENT_OBJECT",conn); String[] strArray = new String[] {"doc1","file1"}; oracle.sql.STRUCT DocObject1 = new STRUCT(docObjDescriptor,conn,strArray); strArray = new String[] {"doc2","file2"}; oracle.sql.STRUCT DocObject2 = new STRUCT(docObjDescriptor,conn,strArray); oracle.sql.STRUCT[] docObjArray = {DocObject1,DocObject2}; arrDesc = ArrayDescriptor.createDescriptor("DOCUMENT_TABLE", conn); oracle.sql.ARRAY array = new ARRAY(arrDesc, conn, docObjArray); 

A solução que usei permite que o Spring analise o object em vez de precisar criar manualmente os arrays STRUCT. Infelizmente, ainda não é independente do ambiente.

Stored Proc DAO:

 package ****.dao.storedProcedures; import java.sql.Array; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; import java.sql.Types; import java.util.Date; import java.util.HashMap; import java.util.Map; import org.apache.commons.lang3.Validate; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.springframework.beans.factory.InitializingBean; import org.springframework.jdbc.core.SqlOutParameter; import org.springframework.jdbc.core.SqlParameter; import org.springframework.jdbc.core.SqlTypeValue; import org.springframework.jdbc.object.StoredProcedure; import ****.persistent.ComplexTypeObj; import ****.persistent.InnerType; import oracle.sql.ARRAY; import oracle.sql.ArrayDescriptor; public class SaveStoredProc extends StoredProcedure implements InitializingBean { public static final String IT_COMPLEX_TYPE = "it_complex_type"; public SaveStoredProc() { } @Override public void afterPropertiesSet() { Validate.notNull(getJdbcTemplate()); super.setFunction(true); super.declareParameter(new SqlOutParameter(RESULT, Types.NUMERIC)); super.declareParameter(new SqlParameter(IT_COMPLEX_TYPE, Types.OTHER, ComplexTypeObj.ORACLE_OBJECT_NAME)); compile(); } public long execute(final ComplexTypeObj complexTypeObj) { Map inParameters = new HashMap(); inParameters.put(IT_COMPLEX_TYPE, new ComplexSqlTypeValue(complexTypeObj)); @SuppressWarnings("unchecked") Map resp = super.execute(inParameters); return ((Number)resp.get(RESULT)).longValue(); } private static final class ComplexSqlTypeValue implements SqlTypeValue { private final Log logger = LogFactory.getLog(getClass()); private final ComplexTypeObj complexTypeObj; public ComplexSqlTypeValue(ComplexTypeObj complexTypeObj) { this.complexTypeObj = complexTypeObj; } @Override public void setTypeValue(PreparedStatement ps, int paramIndex, int sqlType, String typeName) throws SQLException { Connection conn = ps.getConnection(); try { conn = conn.unwrap(oracle.jdbc.OracleConnection.class); } catch (Exception e) { logger.debug("Could not unrap connection"); } Map> typeMap = conn.getTypeMap(); typeMap.put(typeName, ComplexTypeObj.class); //The name of the outer object type. typeMap.put(InnerType.ORACLE_OBJECT_NAME, InnerType.class); //The name of the inner object type. ArrayDescriptor des = ArrayDescriptor.createDescriptor(InnerType.ORACLE_LIST_NAME, conn); //The name of the inner list type. Array objArray = new ARRAY(des, conn, complexTypeObj.getInnerList().toArray()); complexTypeObj.setInnerArray(objArray); ps.setObject(paramIndex, complexTypeObj); } } } 

Tipo exterior:

 import java.sql.*; import java.util.*; public class OuterType extends BaseSQLData implements SQLData { public static final String ORACLE_OBJECT_NAME = "T_OUTER_TYPE"; private List innerList; private Array innerArray; public OuterType() { this.innerList = new ArrayList(); } public String getSQLTypeName() throws SQLException { return ORACLE_OBJECT_NAME; } @Override public void writeSQL(SQLOutput stream) throws SQLException { stream.writeArray(innerArray); } 

Tipo interno:

 public final class InnerType extends BaseSQLData { public static final String ORACLE_OBJECT_NAME = "T_INNER_TYPE"; public static final String ORACLE_LIST_NAME = "T_INNER_TYPE_LIST"; private String valueA; private Long valueB = 0; public String getSQLTypeName() throws SQLException { return ORACLE_OBJECT_NAME; } @Override public void readSQL(SQLInput stream, String typeName) throws SQLException { throw new UnsupportedOperationException("This class doesn't support read opperations."); } @Override public void writeSQL(SQLOutput stream) throws SQLException { stream.writeString(valueA); stream.writeBigDecimal(valueB == null ? null : new BigDecimal(valueB.toString())); } 

Se você estiver usando o Spring , você pode querer olhar para Spring Data JDBC Extensions , que fornece um tipo SqlArrayValue .

Capítulo 7.2.1 Definir valores ARRAY usando SqlArrayValue para um parâmetro IN explica como chamar procedimentos com parâmetros de matriz.