DM8 jdbc調(diào)用存儲(chǔ)過(guò)程傳參list<實(shí)體類(lèi)>

一、前提

jdbc的連接串參數(shù)prepareOptimize，表示是否對(duì)預(yù)編譯SQL做優(yōu)化，取值true/false，默認(rèn)false不開(kāi)啟優(yōu)化。

開(kāi)啟prepare優(yōu)化可繞過(guò)該問(wèn)題，jdbc url添加參數(shù)prepareOptimize=true，服務(wù)器和jdbc都需升級(jí)到最新版本。數(shù)據(jù)庫(kù)版本最低需要V8.1.2.73

二、建表語(yǔ)句

-- 第一步：創(chuàng)建一個(gè)對(duì)象類(lèi)型create or replace type STUDENT as object(id number(4),name varchar2(50),age number(3));-- 第二步：創(chuàng)建一個(gè)數(shù)組類(lèi)型 (任意選擇下面的一句執(zhí)行)-- 方式1：用table來(lái)盛放對(duì)象 create or replace type STU_LIST as table of STUDENT; / -- 方式2：用數(shù)組來(lái)盛放對(duì)象，同時(shí)可指定數(shù)組的大小[用as varray(100)也是可以滴] create or replace type STU_LIST as array(100) of STUDENT;-- 第三步：創(chuàng)建一個(gè)過(guò)程引用集合類(lèi)型的參數(shù)create or replace procedure test_in_list( -- 參數(shù)區(qū)域studentlist in STU_LIST,message out varchar2 ) is -- 變量區(qū)域 begin -- 執(zhí)行區(qū)域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語(yǔ)句** -- 1. 創(chuàng)建一個(gè)對(duì)象類(lèi)型* create or replace type STUDENT as object(* id number(4),* name varchar2(50),* age number(3)* );* -- 2. 創(chuàng)建一個(gè)數(shù)組類(lèi)型 (任意選擇下面的一句執(zhí)行)* -- 方式1：用table來(lái)盛放對(duì)象* create or replace type STU_LIST as table of STUDENT;** -- 方式2：用數(shù)組來(lái)盛放對(duì)象，同時(shí)可指定數(shù)組的大小[用as varray(100)也是可以滴]* create or replace type STU_LIST as array(100) of STUDENT;** -- 3. 創(chuàng)建一個(gè)過(guò)程引用集合類(lèi)型的參數(shù)* create or replace procedure test_in_list(* -- 參數(shù)區(qū)域* studentlist in STU_LIST,* message out varchar2* )* is* -- 變量區(qū)域* begin* -- 執(zhí)行區(qū)域* 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 {// 測(cè)試mainpublic static void main(String[] args) {testProInList();}// 調(diào)用存儲(chǔ)過(guò)程并返回執(zhí)行結(jié)果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(?,?)}";// 創(chuàng)建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);// 設(shè)置入?yún)?#96;callableStatement.setArray(1, array);// 注冊(cè)出參callableStatement.registerOutParameter(2, java.sql.Types.VARCHAR);// callableStatement.registerOutParameter(2, oracle.jdbc.OracleTypes.VARCHAR);// 執(zhí)行callableStatement.execute();// 獲取返回結(jié)果String message = callableStatement.getString(2);System.out.println(message);// 打印結(jié)果：// {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,將每個(gè)Student對(duì)象轉(zhuǎn)換為 可識(shí)別的模板對(duì)象for (int i = 0; i < stuList.size(); i++) {// java對(duì)象Student student = stuList.get(i);// 數(shù)組大小應(yīng)和你定義的數(shù)據(jù)庫(kù)對(duì)象(STUDENT)的屬性的個(gè)數(shù)Object[] oneRow = new Object[3];oneRow[0] = student.getId(); // 將Student對(duì)象的每個(gè)屬性按順序設(shè)置到oneRow數(shù)組中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;}}

總結(jié)

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

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。