从具有复杂输入和输出类型的JDBC调用Oracle存储过程

Question

我在解决这个问题上非常接近,但我显然错过了一些东西.我的要求是从JDBC调用Oracle中的存储过程.存储过程将1个用户定义的Oracle对象作为INput,将另一个用户定义的Oracle对象作为OUTput.INput和OUTput对象混合了原始Oracle数据类型和另一组用户定义对象的集合.只要我为INput和OUTput对象中的集合类型设置NULL,我就能成功调用存储过程并返回结果.如果我尝试为Oracle对象列表创建ArrayDescriptor以将其发送到存储过程,我会不断遇到障碍.所以我需要帮助弄清楚如何将Array设置为INput对象并将其设置为CallableStatement.请注意,我知道如何将原始类型和数组作为直接输入发送到存储过程.但我不想这样做,因为我们以后必须向程序发送10个额外的字段,我不想将它们添加到方法签名中.这是课程列表.此外,下面的代码没有编译错误.

在oracle中打包:

CREATE OR REPLACE PACKAGE testPkg AS 
PROCEDURE spGetTestData (
TESTDATA_IN              IN            TESTDATA_IN_OBJ,
TESTDATA_OUT     OUT             TESTDATA_OUT_OBJ
);
END;

存储过程的输入对象:

CREATE OR REPLACE TYPE TESTDATA_IN_OBJ AS OBJECT(
testStr1            VARCHAR2(5),
arrObj1             ARR_OBJ_1_NT);

Array对象作为INput对象的一部分:

create or replace TYPE      ARR_OBJ_1_NT AS TABLE OF ARR_OBJ_1_OBJ;

INput对象的UserDefined对象部分:

CREATE OR REPLACE TYPE ARR_OBJ_1_OBJ AS OBJECT
(
teststr         VARCHAR2(14),
testNumber   NUMBER(4),
);

TestDataINObj.java:

    import java.sql.Array;
    import java.sql.SQLData;
    import java.sql.SQLException;
    import java.sql.SQLInput;
    import java.sql.SQLOutput;

    public class TestDataINObj implements SQLData
    {
 private String sql_type = "TESTDATA_IN_OBJ";

protected String testStr1;
protected Array arrObj1;

@Override
public String getSQLTypeName() throws SQLException
{
    return this.sql_type;
}


    // getter and setter for fields

@Override
public void readSQL(SQLInput stream, String typeName) throws SQLException
{
this.sql_type=typeName;
    this.testStr1 = stream.readString();
    this.arrObj1 = stream.readArray();
}

@Override
public void writeSQL(SQLOutput stream) throws SQLException
{
    stream.writeString(this.testStr1);
    stream.writeArray(this.arrObj1);
}
    }

TestDataINObjConverter.java:

    public class TestDataINObjConverter
    {
    public static TestDataINObj convertPOJOToDBInObj(Connection connection)
        throws SQLException
    {
    TestDataINObj testDataINObj = new TestDataINObj();
        testDataINObj.setTestStr1("some string");
        ArrObj1NT[] ArrObj1NTList = ArrObj1NTConverter.convertPOJOToDBObj(); // this will return Java array of ArrObj1NT class
        testDataINObj.setArrObj1(getOracleArray("ARR_OBJ_1_NT",connection, ArrObj1NTList));
    return testDataINObj;
}


private static Array getOracleArray(final String typeName, Connection connection, ArrObj1NT[] ArrObj1NTList) throws SQLException
{
    if (typeName == null)
    {
        return null;
    }
    Array oracleArray = new ARRAY(new ArrayDescriptor(typeName, connection), connection, ArrObj1NTList);
    return oracleArray;
}

实际执行对存储过程的调用的代码:

    ... //code to get connection
    ..// connection is of type T4CConnection
    Map typeMap = connection.getTypeMap();
        typeMap.put("TESTDATA_IN_OBJ", TestDataINObj.class);
        typeMap.put("TESTDATA_OUT_OBJ", TestDataOUTObj.class);
        typeMap.put("ARR_OBJ_1_NT", ArrObj1NT.class);

        TestDataINObj testDataINObj = TestDataINObjConverter.convertPOJOToDBInObj(connection);

        getMetaDataCallableStatement = connection.prepareCall("begin " + "testPkg" + ".spGetTestData (?,?);"+ " end;");
        getMetaDataCallableStatement.setObject(1, testDataINObj);
        getMetaDataCallableStatement.registerOutParameter(2, Types.STRUCT, "TESTDATA_OUT_OBJ");
        rs = getMetaDataCallableStatement.executeQuery();

        TestDataOUTObj testDataOUTObj = (TestDataOUTObj) getMetaDataCallableStatement.getObject(2, typeMap);

其他:1.对象在Schema级别声明,可供db用户访问.2.我没有在这里包含所有相应的Java对象,因为它将占用更多空间.它们实现SQLData接口,其类型名称与DB名称匹配.read和writeSQL方法使用getString,getArray和相应的setter方法.

Answer 1

这是一个非常古老的方法，为什么你不使用“Oradata”和“Oradatum”接口？这会节省很多精力。

您的方法留下了很多错误的范围，您必须以正确的方式读取流并自己检查字段的顺序，这可能很棘手。Oradata 方法将为您做到这一点。

就您的方法而言，您的代码不是很清楚。但只是为了给出一个概述，StructDescriptor 将映射到 oracle 记录类型，ArrayDescriptor 将映射到 oracle 表类型，从你的代码中我对你想要实现的目标感到困惑。

如果你能说得更清楚的话我可以帮忙。