Oracle存储过程的数组参数

　　功能：采用存储过程、type组合来实现批量入库，以节省系统开销，提高效率。

sql脚本：

　　1)

CREATE OR REPLACE TYPE WANGCHY.t_cableLine_point AS OBJECT
(
  ID NUMBER(10),
  CABLELINEID NUMBER(10),
  ROADPOINTID NUMBER(10),
  ORDERNUM NUMBER(10),
  REMARK NUMBER(10)
)

      2)

CREATE OR REPLACE TYPE WANGCHY.ARRAY_cableLine_point AS table OF t_cableLine_point

    
　　3)

CREATE TABLE WANGCHY.RSC_CABLELINE_POINT
(
  ID           NUMBER(10)                       NOT NULL,
  CABLELINEID  NUMBER(10)                       NOT NULL,
  ROADPOINTID  NUMBER(10)                       NOT NULL,
  ORDERNUM     NUMBER(10),
  REMARK       NUMBER(10)
)

     

      4)

CREATE OR REPLACE procedure WANGCHY.batch_cableline_point(i_object in ARRAY_cableLine_point)is 
    begin 
        insert into RSC_CABLELINE_POINT(ID,CABLELINEID,ROADPOINTID,ORDERNUM,REMARK)select ID,CABLELINEID,ROADPOINTID,ORDERNUM,REMARK from the(select cast(i_object as ARRAY_cableLine_point)from dual); 
        
    end batch_cableline_point;

java代码实现:

　　

package com.test.oracle;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

public class Test {

    public static void main(String[] args) {

        try {

            Class.forName("oracle.jdbc.driver.OracleDriver");

            String url = "jdbc:oracle:thin:@10.10.71.24:1521:orcl";

            Connection con = DriverManager.getConnection(url, "wangchy", "wangchy");

            PreparedStatement pstmt = null;

            String sql = "{call batch_cableline_point(?)}";

            pstmt = con.prepareCall(sql);

            Object[][] object1 = new Object[10][5];

            int max = 3615142;// 由于表有索引

            for (int i = 0; i < 10; i++) {

                object1[i][0] = ++max;

                object1[i][1] = 158870593;

                object1[i][2] = 333;

                object1[i][3] = 444;

                object1[i][4] = 555;

            }

            oracle.sql.ArrayDescriptor desc = oracle.sql.ArrayDescriptor

            .createDescriptor("ARRAY_CABLELINE_POINT", con);

            oracle.sql.ARRAY array = new oracle.sql.ARRAY(desc, con, object1);

            pstmt.setArray(1, array);

            pstmt.executeUpdate();

        } catch (Exception e) {

            e.printStackTrace();

        }

    }
}