问 使用JDBC调用带有自定义类型输入参数的PL/SQL存储过程，所有字段都为空

EN

我使用JDBC与 createStruct() 一起调用Oracle数据库上的存储过程，该存储过程接受自定义类型作为参数。存储过程将自定义类型字段插入到表中，当我稍后从表中插入 SELECT 时，我会看到我试图插入的所有字段都是 NULL 。

自定义类型如下所示：

type record_rec as object (owner_id varchar2 (7),
                                        target_id VARCHAR2 (8),
                                        IP VARCHAR2 (15),
                                        PREFIX varchar2 (7),
                                        port varchar2 (4),
                                        description VARCHAR2 (35),
                                        cost_id varchar2(10))

存储过程如下所示：

package body            "PKG_RECORDS"
procedure P_ADD_RECORD (p_target_id in out VARCHAR2,
                      p_record_rec in record_rec)
  l_target_id   targets.target_id%TYPE;
BEGIN
  Insert into targets (target_id,
                      owner_id,
                      description,
                      prefix,
                      start_date,
                      end_date,
                      cost_id,
                      port,
                      server_name,
                      server_code)
       values (f_sequence ('TARGETS'),
               p_record_rec.owner_id,
               p_record_rec.ip,
               p_record_rec.description,
               p_record_rec.prefix,
               sysdate,
               to_date ('01-JAN-2050'),
               p_record_rec.cost_id,
               p_record_rec.port,
               'test-server',
               '51')
    returning target_id
         into p_target_id;
END PKG_RECORDS;

我的Java代码如下所示：

try (Connection con = m_dataSource.getConnection()) {
    ArrayList<String> ids = new ArrayList<>();
    CallableStatement call = con.prepareCall("{call PKG_RECORDS.P_ADD_RECORD(?,?)}");
    for (Record r : records) {
        call.registerOutParameter("p_target_id", Types.VARCHAR);
        call.setObject("p_record_rec", 
                con.createStruct("SCHEME_ADM.RECORD_REC", new Object[] {
                        r.getTarget_id(),
                        null, // will be populated by SP
                        t.getIp(),
                        t.getPrefix(),
                        t.getPort(),
                        t.getDescription(),
                        t.getCost_id()
                }), Types.STRUCT);
        call.execute();
        ids.add(call.getString("p_target_id"));
    return new QueryRunner().query(con, 
            "SELECT * from TARGETS_V WHERE TARGET_ID IN ("+
                    ids.stream().map(s -> "?").collect(Collectors.joining(",")) +
            new BeanListHandler<Record>(Record.class),
            ids.toArray(new Object[] {})
            ).stream()
            .collect(Collectors.toList());
} catch (SQLException e) {
    throw new DataAccessException(e.getMessage());
}

注意：*最后一部分是使用Apache utils-我喜欢它们的bean流操作。*连接使用的是C3P0连接池--这可能是相关的吗？*只是为了说明--并不是bean处理器将空值填充到 Record bean字段--如果我使用see直接加载表(或视图)，则可以看到数据库中的字段确实设置为 NULL 。

进程运行时不存在 SQLException ，或者任何其他注意事项都是错误的。

有什么好查的吗？

更新 在阅读了Objects和SQLData映射之后，重写了代码以使用 SQLData 。

Record 类现在实现了 SQLData ，它的 writeSQL() 方法如下所示：

@Override
public void writeSQL(SQLOutput stream) throws SQLException {
    stream.writeString(owner_id);
    stream.writeString(target_id);
    stream.writeString(Objects.isNull(ip) ? "0" : ip); // weird, but as specified
    stream.writeString(prefix);
    stream.writeString(String.valueOf(port));
    stream.writeString(description);
    stream.writeString(cost_id);
}

然后，在调用代码的开头，我添加了：

con.getTypeMap().put("SCHEME_ADM.RECORD_REC", Record.class);

而不是使用 createStruct() ， setObject() 调用现在看起来很简单：

call.setObject("p_record_rec", t, Types.STRUCT)

但是结果是相同的-没有错误，所有传递的值都被读取为 NULL 。我已经通过 writeSQL() 实现进行了跟踪，我可以看到它被调用了，所有的值都被正确地传递到了Oracle代码中。我尝试在 Types.JAVA_OBJECT 调用中使用 setObject() ，得到了一个错误： Invalid column type 。

更新2 濒临疯狂无助我已经实现了 模式

public class Record implements SQLData, OracleData, OracleDataFactory {
@Override
public Object toJDBCObject(Connection conn) throws SQLException {
    return conn.createStruct(getSQLTypeName(), new Object[] {
            Objects.isNull(owner_id) ? "" : owner_id,
            Objects.isNull(record_id) ? "" : record_id,
            Objects.isNull(ip) ? "0" : ip,
            Objects.isNull(prefix) ? "" : prefix,
            String.valueOf(port),
            Objects.isNull(description) ? "" : description,
            Objects.isNull(cost_id) ? "" : cost_id
@Override
public OracleData create(Object jdbcValue, int sqltype) throws SQLException {
    if (Objects.isNull(jdbcValue)) return null;
    LinkedList<Object> attr = new LinkedList<>(Arrays.asList(((OracleStruct)jdbcValue).getAttributes()));
    Record r = new Record();
    r.setOwner_id(attr.removeFirst().toString());
    r.setRecord_id(attr.removeFirst().toString());
    r.setIp(attr.removeFirst().toString());
    r.setPrefix(attr.removeFirst().toString());
    r.setPort(Integer.parseInt(attr.removeFirst().toString()));
    r.setDescription(attr.removeFirst().toString());
    r.setCost_id(attr.removeFirst().toString());
    return r;
public static OracleDataFactory getOracleDataFactory() {
    return new Record();
}

呼叫代码：

...
// unwrap the Oracle object from C3P0 (standard JDBCv4 API)
OracleCallableStatement ops = call.unwrap(OracleCallableStatement.class);
// I'm not sure why I even need to do this - it looks exactly like
// the standard JDBC code
for (Records r : records) {