DM8 jdbc調用存儲過程傳參list<實體類>

一、前提

jdbc的連接串參數prepareOptimize，表示是否對預編譯SQL做優化，取值true/false，默認false不開啟優化。

開啟prepare優化可繞過該問題，jdbc url添加參數prepareOptimize=true，服務器和jdbc都需升級到最新版本。數據庫版本最低需要V8.1.2.73

二、建表語句

-- 第一步：創建一個對象類型create or replace type STUDENT as object(id number(4),name varchar2(50),age number(3));-- 第二步：創建一個數組類型 (任意選擇下面的一句執行)-- 方式1：用table來盛放對象 create or replace type STU_LIST as table of STUDENT; / -- 方式2：用數組來盛放對象，同時可指定數組的大小[用as varray(100)也是可以滴] create or replace type STU_LIST as array(100) of STUDENT;-- 第三步：創建一個過程引用集合類型的參數create or replace procedure test_in_list( -- 參數區域studentlist in STU_LIST,message out varchar2 ) is -- 變量區域 begin -- 執行區域for i in 1 .. studentlist.count loopmessage:=message||'{id:'||studentlist(i).id||', name:'||studentlist(i).name||', age'||studentlist(i).age||'},';end loop; end test_in_list;

三、java代碼

package com.dameng.dm;import com.dameng.domain.Student; import dm.jdbc.desc.ArrayDescriptor; import dm.jdbc.desc.StructDescriptor; import dm.jdbc.driver.DmdbArray; import dm.jdbc.driver.DmdbConnection; import dm.jdbc.driver.DmdbStruct;import java.sql.CallableStatement; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.util.ArrayList;/*** SQl語句** -- 1. 創建一個對象類型* create or replace type STUDENT as object(* id number(4),* name varchar2(50),* age number(3)* );* -- 2. 創建一個數組類型 (任意選擇下面的一句執行)* -- 方式1：用table來盛放對象* create or replace type STU_LIST as table of STUDENT;** -- 方式2：用數組來盛放對象，同時可指定數組的大小[用as varray(100)也是可以滴]* create or replace type STU_LIST as array(100) of STUDENT;** -- 3. 創建一個過程引用集合類型的參數* create or replace procedure test_in_list(* -- 參數區域* studentlist in STU_LIST,* message out varchar2* )* is* -- 變量區域* begin* -- 執行區域* for i in 1 .. studentlist.count loop* message:=message||'{id:'||studentlist(i).id||', name:'||studentlist(i).name||', age'||studentlist(i).age||'},';* end loop;* end test_in_list;*/public class TestList_Dm {// 測試mainpublic static void main(String[] args) {testProInList();}// 調用存儲過程并返回執行結果public static void testProInList() {try {String url = "jdbc:dm://192.168.60.167?prepareOptimize=true";String user = "SYSDBA";String password = "SYSDBA";Class.forName("dm.jdbc.driver.DmDriver");Connection connection = null;connection = DriverManager.getConnection(url,user,password);String sql = "{call TEST_IN_LIST(?,?)}";// 創建CallableStatement接口CallableStatement callableStatement = connection.prepareCall(sql);DmdbConnection dmcon = connection.unwrap(DmdbConnection.class);// 給in?賦值ArrayList<Student> list = new ArrayList<Student>() {{this.add(new Student(1, "ZhangSan", 23));this.add(new Student(2, "LiSi", 22));this.add(new Student(3, "WangWu", 21));}};DmdbArray array = getArray(dmcon, "STUDENT", "STU_LIST", list);// 設置入參`callableStatement.setArray(1, array);// 注冊出參callableStatement.registerOutParameter(2, java.sql.Types.VARCHAR);// callableStatement.registerOutParameter(2, oracle.jdbc.OracleTypes.VARCHAR);// 執行callableStatement.execute();// 獲取返回結果String message = callableStatement.getString(2);System.out.println(message);// 打印結果：// {id:1, name:ZhangSan, age23},{id:2, name:LiSi, age22},{id:3,// name:WangWu, age21},} catch (Exception e) {e.printStackTrace();} finally {}}private static DmdbArray getArray(DmdbConnection con, String DmObjType, String DmArrType, ArrayList<Student> stuList)throws Exception {DmdbArray list = null;if (stuList != null && stuList.size() > 0) {DmdbStruct[] structs = new DmdbStruct[stuList.size()];StructDescriptor structdesc = new StructDescriptor(DmObjType, con);// 遍歷stuList,將每個Student對象轉換為 可識別的模板對象for (int i = 0; i < stuList.size(); i++) {// java對象Student student = stuList.get(i);// 數組大小應和你定義的數據庫對象(STUDENT)的屬性的個數Object[] oneRow = new Object[3];oneRow[0] = student.getId(); // 將Student對象的每個屬性按順序設置到oneRow數組中oneRow[1] = student.getName();oneRow[2] = student.getAge();structs[i] = new DmdbStruct(structdesc, con, oneRow);}// 匹配listArrayDescriptor desc = new ArrayDescriptor(DmArrType, con);list = new DmdbArray(desc, con, structs);}return list;}}

總結

以上是生活随笔為你收集整理的DM8 jdbc调用存储过程传参list＜实体类＞的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。