java 批量入库oracle_java操作Oracle数据库——ARRAY、TABLE类型批量入库
首先是我的數據庫表(PLSQL操作)
create?table?TEST_TABLE
(
yid??????NUMBER,
ytel?????VARCHAR2(50),
yanumber?VARCHAR2(50)
);
這里記錄兩種方式：不管哪種方式、一定要記得導入orai18n.jar否則一遇到字符串就亂碼、添加不到數據
第一種：
在數據庫中建立相應的java對象(Oracle中的類型)和數組.
CREATE?OR?REPLACE?TYPE?yOracleObject(類型名稱)?AS?OBJECT(
yid?number,ytel?varchar2(50),yanumber?varchar2(50)
);
數組：
CREATE?OR?REPLACE?TYPE?y_Oracle_LIST(數組名稱)?AS?VARRAY(5000)?OF?yOracleObject(類型名稱);
創建完畢后在Types下面可以看到創建好的類型。
存儲過程：
CREATE?OR?REPLACE?PROCEDURE?proc_test_new(y_Array?IN?y_oracle_list,
p_out???OUT?NUMBER)?AS
v_yID?????number;
v_yTel????varchar(50);
v_anumber?varchar(50);
v_type????yoracleobject;
begin
FOR?I?IN?1?..?y_Array.COUNT?LOOP
v_type????:=?y_Array(i);
v_yID?????:=?v_type.yid;
v_yTel????:=?v_type.ytel;
v_anumber?:=?v_type.yanumber;
insert?into?test_table?values?(v_yID,?v_yTel,?v_anumber);
end?loop;
commit;
p_out?:=?0;
EXCEPTION
WHEN?OTHERS?THEN
p_out?:=?-1;
ROLLBACK;
END;
java代碼：
import?java.sql.CallableStatement;
import?java.sql.Connection;
import?java.sql.SQLException;
import?java.util.ArrayList;
import?com.chinaboxun.ordermanager.core.util.DbUtil;
import?oracle.jdbc.driver.OracleCallableStatement;
import?oracle.sql.ARRAY;
import?oracle.sql.ArrayDescriptor;
import?oracle.sql.STRUCT;
import?oracle.sql.StructDescriptor;
@SuppressWarnings("unchecked")
public?class?TestProc?{
public?static?void?main(String[]?args)?{
ArrayList?arrayL?=?new?ArrayList();
TestBean?t?=?new?TestBean();
t.setYid(1);
t.setYtel("1236");
t.setYanumber("騷年");
arrayL.add(t);
TestBean?t1?=?new?TestBean();
t1.setYid(2);
t1.setYtel("1236");
t1.setYanumber("騷年");
arrayL.add(t1);
TestBean?t2?=?new?TestBean();
t2.setYid(3);
t2.setYtel("1236");
t2.setYanumber("騷年");
arrayL.add(t2);
TestBean?t3?=?new?TestBean();
t3.setYid(4);
t3.setYtel("1236");
t3.setYanumber("騷年");
arrayL.add(t3);
TestBean?t4?=?new?TestBean();
t4.setYid(5);
t4.setYtel("1236");
t4.setYanumber("騷年");
arrayL.add(t4);
try?{
/*
*?記得判斷一下list集合的大小、如果集合大于你在數據設置的數組大小了、那么就要分批次提交
*?我的是y_Oracle_LIST?AS?VARRAY(5000)
*?那么當list集合的值等于5000的時候就入庫了、
*?然后剩下的數據又從新用一個list來裝、在繼續判斷......
*?這里只是簡單的演示、就不具體操作判斷了
*/
int?backVal?=?newTest(arrayL);
System.out.println(backVal==0?"成功!":"失敗!");
}?catch?(SQLException?e)?{
e.printStackTrace();
}
}
/**
*?將java中的arrayList轉化
*?@param?con?數據庫連接對象
*?@param?Oraclelist?數據數組類型名稱
*?@param?objlist?要存儲的list對象
*?@return?oracle.sql.ARRAY
*?@throws?Exception
*/
private?static?ARRAY?getOracleArray(Connection?con,?String?Oraclelist,
ArrayList?objlist)?throws?Exception?{
ARRAY?list?=?null;
if?(objlist?!=?null?&&?objlist.size()?>?0)?{
/**
*?必須大寫類型名稱
*?否則會報錯：java.sql.SQLException:?無效的名稱模式:?M_ORDER.yoracleobject
*/
StructDescriptor?structdesc?=?new?StructDescriptor(
"YORACLEOBJECT",?con);
STRUCT[]?structs?=?new?STRUCT[objlist.size()];
Object[]?result?=?new?Object[0];
for?(int?i?=?0;?i?
result?=?new?Object[3];
TestBean?t?=?(TestBean)(objlist.get(i));
result[0]?=?t.getYid();
result[1]?=?t.getYtel();
result[2]?=?t.getYanumber();
/*
*?一定要記得導入orai18n.jar
*?否則一遇到字符串就亂碼、添加不到數據
*/
structs[i]?=?new?STRUCT(structdesc,?con,?result);
}
ArrayDescriptor?desc?=?ArrayDescriptor.createDescriptor(Oraclelist,
con);
list?=?new?ARRAY(desc,?con,?structs);
}?else?{
ArrayDescriptor?desc?=?ArrayDescriptor.createDescriptor(Oraclelist,
con);
STRUCT[]?structs?=?new?STRUCT[0];
list?=?new?ARRAY(desc,?con,?structs);
}
return?list;
}
/**
*?入庫
*?@param?peoleList?要存儲的list對象
*?@return
*?@throws?SQLException
*/
public?static?int?newTest(ArrayList?peoleList)?throws?SQLException{
Connection?con?=?null;
CallableStatement?stmt?=?null;
int?backVal?=?-1;
try?{
DbUtil?d?=?new?DbUtil();
con?=?d.getCon();
if?(con?!=?null)?{
stmt?=?con.prepareCall("{call?proc_test_new(?,?)}");
ARRAY?adArray?=?getOracleArray(con,?"Y_ORACLE_LIST",peoleList);
((OracleCallableStatement)?stmt).setARRAY(1,?adArray);
stmt.registerOutParameter(2,?java.sql.Types.INTEGER);
stmt.execute();
backVal?=?stmt.getInt(2);
}
}?catch?(Exception?e)?{
e.printStackTrace();
}?finally?{
if(stmt!=null){
stmt.close();
}
if(con!=null){
con.close();
}
}
return?backVal;
}
}
第二種：不用判斷list集合大小、不用考慮數組長度的做法就是用table。
使用的類型：你要新增的數據有多少字段就添加相應個數的類型
create?or?replace?type?i_table?is?table?of?number;
create?or?replace?type?t_table?is?table?of?varchar2(30);
create?or?replace?type?a_table?is?table?of?varchar2(30);
存儲過程:
create?or?replace?procedure?pro_forall_insert(v_1?i_table,
v_2?t_table,
v_3?a_table)?as
begin
forall?i?in?1?..?v_1.count
insert?into?test_table?values?(v_1(i),?v_2(i),?v_3(i));
END;
java代碼：
import?java.sql.CallableStatement;
import?java.sql.Connection;
import?java.sql.SQLException;
import?java.util.ArrayList;
import?com.chinaboxun.ordermanager.core.util.DbUtil;
import?oracle.jdbc.driver.OracleCallableStatement;
import?oracle.sql.ARRAY;
import?oracle.sql.ArrayDescriptor;
import?oracle.sql.STRUCT;
import?oracle.sql.StructDescriptor;
@SuppressWarnings("unchecked")
public?class?TestProc?{
public?static?void?main(String[]?args)?{
Connection?con?=?null;
CallableStatement?cstmt?=?null;
oracle.sql.ArrayDescriptor?a?=?null;
oracle.sql.ArrayDescriptor?b?=?null;
oracle.sql.ArrayDescriptor?c?=?null;
DbUtil?d?=?new?DbUtil();
con?=?d.getCon();
if?(1?==?1?)
{
Object[]?s1?=?new?Object[10000];
Object[]?s2?=?new?Object[10000];
Object[]?s3?=?new?Object[10000];
for?(int?i?=?0;?i?
s1[i]?=?new?Integer(i);
s2[i]?=?"ttt"+i;
s3[i]?=?"aaa"+i;
}
try?{
a?=?oracle.sql.ArrayDescriptor.createDescriptor("I_TABLE",?con);
b?=?oracle.sql.ArrayDescriptor.createDescriptor("T_TABLE",?con);
c?=?oracle.sql.ArrayDescriptor.createDescriptor("A_TABLE",?con);
ARRAY?a_test?=?new?ARRAY(a,?con,?s1);
ARRAY?b_test?=?new?ARRAY(b,?con,?s2);
ARRAY?c_test?=?new?ARRAY(c,?con,?s3);
cstmt?=?con.prepareCall("{?call?pro_forall_insert(?,?,?)?}");
cstmt.setObject(1,?a_test);
cstmt.setObject(2,?b_test);
cstmt.setObject(3,?c_test);
cstmt.execute();
con.commit();
}?catch?(Exception?e)?{
e.printStackTrace();
}
}
}
}
DbUtil工具類：
import?java.io.IOException;
import?java.io.InputStream;
import?java.sql.Connection;
import?java.sql.DriverManager;
import?java.util.Properties;
public?class?DbUtil?{
static?Properties?properties?=?null;
public?DbUtil()?{
//?讀取.properties文件的信息
properties?=?new?Properties();
InputStream?in?=?getClass().getResourceAsStream("/com/chinaboxun/ordermanager/config/ordermanager.properties");
try?{
properties.load(in);
}?catch?(IOException?ex)?{
System.out.println(ex.getMessage());
ex.printStackTrace();
}
}
/**
*?
獲取連接對象*
*?@return
*/
public?Connection?getCon()?{
Connection?connection?=?null;
try?{
String?url=properties.getProperty("jdbc.url");
String?user=properties.getProperty("jdbc.username");
String?pwd=properties.getProperty("jdbc.password");
String?driver=properties.getProperty("jdbc.driverClassName");
Class.forName(driver);
connection?=?DriverManager.getConnection(url,?user,?pwd);
}?catch?(Exception?err)?{
System.out.println("錯誤：ConDB-->getCon()____JDBC連接失敗!");
err.printStackTrace();
return?null;
}
return?connection;
}
}
ordermanager.properties屬性文件：
jdbc.driverClassName=oracle.jdbc.OracleDriver
jdbc.url=jdbc:oracle:thin:@172.16.0.162:1521:ORCL
jdbc.username=m_order
jdbc.password=morder
最后：一定要記得導入orai18n.jar否則一遇到字符串就亂碼、添加不到數據！
----------------編輯：20140110---------------
一些加上jar繼續報錯如下錯誤的朋友可以考慮以下解決方案：
ERROR1：Non supported character set: oracle-character-set-852
ERROR2：oracle/i18n/text/converter/CharacterConverterOGS.getInstance(I)Loracle/i18n/text/converter/CharacterConverter;
以上兩個錯誤可以采取一個方案，就是把type的數據類型改成：nVARCHAR2
如果堅持使用該jar的童鞋請將 nls_charset12.jar 加入到 classpath 中。在加上orai18n.jar
----------------編輯：20140110---------------
我被這個可整慘了！
尼瑪、老子這牙齒疼死我了！！！
總結
以上是生活随笔為你收集整理的java 批量入库oracle_java操作Oracle数据库——ARRAY、TABLE类型批量入库的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： hive - 解析 json
- 下一篇： linux cmake编译源码,linu