6

我非常接近解决这个问题，但我显然错过了一些东西。我的要求是从 JDBC 调用 Oracle 中的存储过程。存储过程将 1 个用户定义的 Oracle 对象作为输入，另一个用户定义的 Oracle 对象作为输出。输入和输出对象混合了原始 Oracle 数据类型和另一组用户定义对象的集合。只要我为 INput 和 OUTput 对象中的集合类型设置 NULL，我就能够成功地调用存储过程并取回结果。如果我尝试为 Oracle 对象列表创建 ArrayDescriptor 以将其发送到存储过程，我会一直遇到障碍。所以我需要帮助弄清楚如何将数组设置为输入对象并将其设置为 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 Object 作为 IInput Object 的一部分：

create or replace TYPE      ARR_OBJ_1_NT AS TABLE OF ARR_OBJ_1_OBJ;

输入对象的用户定义对象部分：

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 方法。

4

1 回答 1

1

这是一种非常古老的方法，为什么不使用“Oradata”和“Oradatum”界面？会省很多力气。

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

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

如果你能说得更清楚，我可以提供帮助。

于 2013-01-21T15:11:25.137 回答