JDBC-调用-Oracle-Collections

jiezi

5 年前

使用 Java 通过数据库连接（JDBC）访问和操作 Oracle 自定义类型.
大致就是这个网页中说的. https://docs.oracle.com/cd/E1…

Oracle 中支持在数据库中定义数据格式.(嵌套数据格式)
在 JAVA 中调用时, 传入相应格式的数据即可.
找了下没找到对应资料, 记录下.
只是找到了一种简单的可行方案, 因为有人专门写 PLSQL 来处理逻辑, 所以将逻辑全部放在数据库中处理,JAVA 这边弄点简单代码传数据就行.

CREATE TYPE TDC_SUPPLIER_ADDR AS OBJECT
            (ADDRESS VARCHAR2(240),ADDRESS_ID NUMBER);
            
CREATE TYPE TDC_SUPPLIER_ADDR_L AS TABLE OF TDC_SUPPLIER_ADDR;
 
CREATE TYPE TDC_SUPPLIER AS OBJECT
            (NAME VARCHAR2(50),SUPPLIER_ID NUMBER, ADDR TDC_SUPPLIER_ADDR_L);
            
CREATE TABLE TDC_TEST (TEXT VARCHAR2(2000));
 
CREATE OR REPLACE PACKAGE TDC_TEST_PKG IS
 
  PROCEDURE CREATE_SUPPLIER (SUP_OBJ IN TDC_SUPPLIER);
END TDC_TEST_PKG;
 
CREATE OR REPLACE PACKAGE BODY TDC_TEST_PKG IS
 
  PROCEDURE CREATE_SUPPLIER (SUP_OBJ IN TDC_SUPPLIER) IS 
    
    
  BEGIN
    INSERT INTO TDC_TEST VALUES (SUP_OBJ.NAME);
    
    COMMIT;
  END CREATE_SUPPLIER;
END TDC_TEST_PKG;

上面的 SQL 是个简单的例子.
声明了一个数据类型 TDC_SUPPLIER, 在 call CREATE_SUPPLIER 时需要传入 TDC_SUPPLIER 类型数据作为参数.
其中将 TDC_SUPPLIER 转换为 json, 大致是下面的格式

{
"NAME":"","SUPPLIER_ID":0,"ADDR": [
  {"ADDRESS": "","ADDRESS_ID": 0},
  {"ADDRESS": "","ADDRESS_ID": 0}
]
}

其中定义了一个 TDC_SUPPLIER_ADDR 数据类型. 里面有 ADDRESS 和 ADDRESS_ID 属性.
定义了一个 TDC_SUPPLIER_ADDR_L 数组, 里面包含多项 TDC_SUPPLIER_ADDR
在将 TDC_SUPPLIER_ADDR_L 作为 TDC_SUPPLIER 的一个属性.

参考该链接实现代码

package com.hktdc.po.api.approval.test;

import oracle.sql.STRUCT;
import oracle.sql.StructDescriptor;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class Test2 {private final Logger logger = LoggerFactory.getLogger(Test1.class);

    public static void main(String[] args)
            throws ClassNotFoundException, SQLException {DriverManager.registerDriver(new oracle.jdbc.OracleDriver());
        // 打开数据库连接
        String url = "jdbc:oracle:thin:@//127.0.0.1:1521/DB";
        Connection conn = DriverManager.getConnection(url, "apps", "apps");
        conn.setAutoCommit(false);

        // StructDescriptor.createDescriptor 表示要在 JAVA 中创建与数据库对应的对象. 第一个参数是数据库中的类型名称
        StructDescriptor addDesc = StructDescriptor.createDescriptor("TDC_SUPPLIER_ADDR", conn);
        /*
        通过 new STRUCT 方法, 将 JAVA 中的参数转换为数据库中的对象.
        第一个参数为数据库类型名称对象
        第二个参数为数据库连接
        第三个参数为 object 数组, 表示对象中的值. 注意: 对象中值的类型, 应该与数据库中对应参数类型一致.
         */
        Object[] addArr = {"南山区", 10001};
        STRUCT addRecord = new STRUCT(addDesc, conn, addArr);
        Object[] addArr2 = {"龙岗区", 10001};
        STRUCT addRecord2 = new STRUCT(addDesc, conn, addArr2);

        /*
        构建嵌套对象.
        StructDescriptor 只需要定义数据库中 CREATE TYPE ** AS OBJECT 的类型即可.
        TDC_SUPPLIER_ADDR_L 在数据库中代表多个 TDC_SUPPLIER_ADDR, 不需要在 JAVA 中定义, 只需要将多个 TDC_SUPPLIER_ADDR 转换成 Object 数组即可
         */
        StructDescriptor supDesc = StructDescriptor.createDescriptor("TDC_SUPPLIER", conn);
        Object[] addLData = {addRecord, addRecord2};
        Object[] data = {"张三", 302, addLData};
        STRUCT supplier = new STRUCT(supDesc, conn, data);

        // 创建一个调用语句
        CallableStatement stmt = conn.prepareCall("{ call TDC_TEST_PKG.CREATE_SUPPLIER(?) }");

        // 绑定输入记录, 设置第一个 ? 代表的参数
        stmt.setObject(1, supplier);
        // 执行 SQL
        stmt.execute();}
}