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

标签 oracle stored-procedures jdbc plsql java-stored-procedures

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

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);

数组对象作为输入对象的一部分 :
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 接口(interface),并且它们的类型名称与 DB 名称匹配。 read 和 writeSQL 方法使用 getString、getArray 和相应的 setter 方法。

最佳答案

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

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

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

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

关于oracle - 从具有复杂输入和输出类型的 JDBC 调用 Oracle 存储过程,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/9221437/

相关文章:

sql - 有或没有不同的 oracle 交集

mysql - 使用 insert 和 select 语句的存储过程

SQL 存储过程 : If variable is not null, 更新语句

java - mysql 加载以前的查询数据来呈现查询

java - 在准备好的语句中获取列名而不是值

java - java webapp和oracle中的日语字符

oracle - 如何在 Docker Oracle 12 中执行 sql 文件?

postgresql - Postgres 提交是否可以存在于具有异常 block 的过程中?

java - 异常 : Can not read response from server. 预计读取 4 个字节,在连接意外丢失之前读取了 0 个字节

java - Oracle中以毫秒为单位存储时间戳