2. 程式人生 > >Oracle儲存過程傳入List引數

    Oracle儲存過程傳入List引數
    阿新 • • 發佈：2019-02-17 
    --第一步，建立資料庫物件
CREATE OR REPLACE TYPE param_object is object(
  configId nvarchar2(64),
  evaluateScore number(18,2),
  evaluateLevel nvarchar2(64)
); 


--第二步，建立資料庫list並且與資料庫物件掛關係
create type param_array as table of param_object;


--第三步，建立儲存過程將list<object>
create or replace procedure PRO_UPDATE_EVALUATE_SCORE(paramList in param_array,
                                                      result_id out varchar2) is
begin
  for i in 1 .. paramList.count loop
    update SCM_TEST
       set CONFIGID      = paramList(i).configId,
           EVALUATESCORE = paramList(i).evaluateScore where
           EVALUATELEVEL = paramList(i).evaluateLevel;
           result_id := i;
  end loop;
  commit;
end PRO_UPDATE_EVALUATE_SCORE;

     
    package com.atguigu.springdata.test;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Types;
import java.util.ArrayList;
import java.util.Date;
import com.sun.org.apache.xerces.internal.impl.dtd.models.DFAContentModel;

import oracle.jdbc.OracleCallableStatement;
import oracle.sql.ARRAY;
import oracle.sql.ArrayDescriptor;
import oracle.sql.STRUCT;
import oracle.sql.StructDescriptor;

public class Tesst {
	// 資料庫連線
	private static final String connectionURL = "jdbc:oracle:thin:@127.0.0.1:1521/oracle11g";
	private static final String userID = "oracle11g";
	private static final String userPassword = "oracle11g";
	private static final String driver_class = "oracle.jdbc.driver.OracleDriver";

	public void runTest() {
		//組裝需要的引數List<String[]> String[] length 要和資料庫的自定物件PARAM_OBJECT個數一樣
		String chars = "abcdefghijklmnopqrstuvwxyz";
		ArrayList list = new ArrayList<>();
		for(int i=0;i<2000;i++){
			String c = chars.charAt((int)(Math.random() * 26))+"";
			String[] values = { i + 1 + "", i + 1 + "",c.toUpperCase()};
			list.add(values);
		}
		   
		   
		Connection con = null;
		OracleCallableStatement stmt = null;
		try {
			Class.forName(driver_class).newInstance();
			con = DriverManager.getConnection(connectionURL, userID,
					userPassword);
			
			ARRAY aArray = getArray(con, "PARAM_OBJECT","PARAM_ARRAY", list,11);
			
			System.out.println("開始時間："+  new Date());
			stmt = (OracleCallableStatement) con.prepareCall("{call PRO_UPDATE_EVALUATE_SCORE(?,?)}");
			
			stmt.setARRAY(1, aArray);
//			stmt.setArray(1, aArray);
			stmt.registerOutParameter(2, Types.VARCHAR);
			
			stmt.execute();
			String string = stmt.getString(2);
			System.out.println("結束時間："+  new Date());
			System.out.println("輸出引數："+string);
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			if (stmt != null) {
				try {
					stmt.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}
			if (con != null) {
				try {
					con.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}
		}
	}

	/**
	 * 將java陣列轉換成資料庫陣列
	 * @param con			原生jdbc連結，連結池的連結不行
	 * @param OracleObj		資料庫自定義物件
	 * @param Oraclelist	資料庫自定義陣列
	 * @param objlist		需要的引數
	 * @param paramNum		自定義物件的個數
	 * @return	
	 * @throws Exception
	 */
	private ARRAY getArray(Connection con, String OracleObj,

	String Oraclelist, ArrayList objlist,int paramNum) throws Exception {

		ARRAY list = null;


		if (objlist != null && objlist.size() > 0) {

			StructDescriptor structdesc = StructDescriptor.createDescriptor(OracleObj,con);
			
			STRUCT[] structs = new STRUCT[objlist.size()];

			Object[] result = new Object[0];

			for (int i = 0; i < objlist.size(); i++) {
				Object[] object = (Object[]) objlist.get(i);
				String[] str = (String[]) objlist.get(i);
				
				result = new Object[paramNum];

				// 陣列大小應和你定義的資料庫物件(AOBJECT)的屬性的個數
				for(int j=0;j<paramNum;j++){
					result[j] = str[j];
				}

				// 將list中元素的資料傳入result陣列 result[1] = new Integer(..); //
				structs[i] = new STRUCT(structdesc, con, result);
			}

			ArrayDescriptor desc = ArrayDescriptor.createDescriptor(Oraclelist,
					con);

			list = new ARRAY(desc, con, structs);
		}


		return list;

	}

	public static void main(String[] args) {
		Tesst testListToProcedure = new Tesst();
		testListToProcedure.runTest();
	}

}

    注：自定義物件裡面的字元必須要使用nvarchar2，不然java程式碼將字串的格式封裝不進去。連結要使用jdbc原生連結（Connection）才能對自定義物件和陣列的轉換，使用連結池轉換不過來。如果誰使用了連線池成功了麻煩您評論下如何操作的，謝謝！

    相關推薦

    Oracle儲存過程傳入List<object>引數

    --第一步，建立資料庫物件 CREATE OR REPLACE TYPE param_object is object( configId nvarchar2(64), evaluateScore number(18,2), evaluateLevel nvarc

    oracle儲存過程傳入in引數，返回結果集

    create or replace procedure proc_report_TEST(zhxshss in varchar2, pcursor out sys_refcursor) as begi

    Sql Server 2008中儲存過程傳入表值引數

    分享一下我老師大神的人工智慧教程！零基礎，通俗易懂！http://blog.csdn.net/jiangjunshow 也歡迎大家轉載本篇文章。分享知識，造福人民，實現我們中華民族偉大復興！        

    ORACLE儲存過程傳入引數值無法使用

    CREATE OR REPLACE PROCEDURE UpdateBankAccount ( ID number, USERCODE varchar2, DOCTYPE varchar2, CARDNAME varchar2, FL

    Oracle儲存過程實現通過動態引數複製表

    （作者：陳玓玏） 上一篇記錄的是通過自定義函式複製表的筆記，但是覺得過程還是有些麻煩。覺得還是用儲存過程更簡潔些，今天就把儲存過程的寫法整理出來了。下面程式碼用的時候記得把相應位置變數替換成你自己的。 --使用儲存過程複製表，使用儲存過程來複製表比使用自定義函式

    使用mybatis給Oracle儲存過程傳List,陣列型別.

    0.不廢話.直接上過程 1.因為Oracle本身是有陣列概念的.我們直接使用Oracle中的陣列,但需要先建立型別,varray也就是Oracle的陣列,100指定長度,of後面指定型別, CREATE OR REPLACE TYPE tables_array AS VA

    Oracle 儲存過程 in、out、in out 引數的使用方法

    1. in 引數 用於接收引數，在子程式內部，不能進行修改。預設的引數模式：in 案例: -- 宣告儲存過程 create or replace procedure pro_in(p_num in number) is begin dbms_output.put_line(p_n

    java傳list到Oracle儲存過程執行慢

    儲存過程功能是迴圈對list遍歷，對錶進行插入操作，插入異常則進行修改操作。 可能為update語句執行慢，可是表裡有主鍵，update時主鍵為條件，走主鍵應該不會慢。 單獨把update語句拿出執行，不慢。 最終找出原因，list中物件用的為nvarchar而表裡主鍵為varchar2，執行語句時Or

    使用c#呼叫oracle儲存過程獲取儲存過程引數資訊

    本文介紹如何獲取儲存過程的引數資訊，並介紹如何在c#程式碼中使用ODP.NET呼叫oracle儲存過程返回結果集：1：建立包：SQL> create or replace package FORP_PROC_INFO is  2    3    -- Author  :

    oracle 儲存過程 引數（in | out | in out）的使用

    儲存過程傳參方式 1.in 傳參 create or replace procedure p_name( param_name  in param_type) is --聲明瞭一個呼叫時傳進來的引數 和 它的型別  驗證： create or replace p

    Oracle儲存過程in、out、in out 模式引數

    1、in模式引數 輸入模式的引數，用於接收引數，在子程式內部，不能進行修改。預設的引數模式：in。 --定義列印的儲存過程 CREATE OR REPLACE PROCEDURE println (

    Oracle儲存過程及引數理解 引數預設值 引數順序

    Oracle儲存過程及引數理解 (2010-11-12 11:23:34)  轉自：http://blog.sina.com.cn/s/blog_45daee4a0100n9ar.html 一、過程 (儲存過程)     過程是一個能執行某個特定操作的子程式。使用CRE

    mybatis呼叫oracle儲存過程返回遊標 讀取到java的List

    mapper： <select id="testP" statementType="CALLABLE" > {call P_TEST(#{v_cursor, mode=OUT, jdbcType=CURSOR})} </select> ja

    Oracle儲存過程的簡單舉例

    一、建立測試資料 --建立測試資料: create table person(編號 number(10),姓名 varchar2(20),密碼 varchar2(20)); insert into person values(1,'xzw','888'); select * from p

    Oracle儲存過程例項分析總結（程式碼）

    1.儲存過程結構 1.1 第一個儲存過程 ? 1 2 3 4

    Oracle儲存過程語法及編譯過程講解

    語法 ? 1 2 3 4 5

    java面試問題：oracle儲存過程（procedure)和函式(function)的區別

    oracle儲存過程（procedure)和函式(function)的區別 儲存過程 函式 用於在資料庫中完成特定的操作或者任務（如插入、刪除等） 用於特定的資料（如選擇）

    Oracle儲存過程基礎內容

    1 基本語法 1.1 無參無變數 create or replace procedure firstPro as begin dbms_output.put_line('hello word, my name is stored procedure'); end;

    oracle 儲存過程 例項 迴圈 給查詢賦值 遊標取值

    CREATE OR REPLACE PROCEDURE p_updete_gs is     --僅供參考   i_jdid varchar(32);   i_ryid varchar(32);   cursor cur is --

    C#呼叫ORACLE儲存過程返回結果集

    Oracle中scott使用者下建立儲存過程： (注：從9i開始有了sys_refcursor這種型別，在以前的Oracle版本中需要使用REF CURSOR,並且還需放在一個程式包中) create or replace procedure sp_getdept (result