Java操作Oracle数据库——ARRAY TABLE类型批量数据处理区别比较

朱雀 2022-04-01 14:24 271阅读 0赞

[https://bijian1013.iteye.com/blog/2262435][https_bijian1013.iteye.com_blog_2262435]

### [java操作Oracle数据库——ARRAY、TABLE类型批量入库][https_bijian1013.iteye.com_blog_2262435] ###

*  **博客分类：** 
 *  [java基础][java]

[oracle][][java][java 1][ARRAY、TABLE类型批量入库][ARRAY_TABLE]

首先是我的数据库表(PLSQL操作)

Sql代码

![收藏代码][icon_star.png]

1.  \--建表  
2.  create table TEST\_TABLE    
3.  (    
4.    yid      NUMBER,      
5.    ytel     VARCHAR2(50),     
6.    yanumber VARCHAR2(50)      
7.  );

这里记录两种方式：不管哪种方式、一定要记得导入orai18n.jar，否则一遇到字符串就乱码或添加不到数据库中。

**一.ARRAY类型批量入库**

在数据库中建立相应的java对象(Oracle中的类型)和数组。

Sql代码

![收藏代码][icon_star.png]

1.  \--类型  
2.  CREATE OR REPLACE TYPE yOracleObject AS OBJECT(    
3.         yid number,ytel varchar2(50),yanumber varchar2(50)    
4.  );

Sql代码

![收藏代码][icon_star.png]

1.  \--数组  
2.  CREATE OR REPLACE TYPE y\_Oracle\_LIST AS VARRAY(5000)  OF yOracleObject;

创建完毕后在Types下面可以看到创建好的类型。

存储过程：

Sql代码

![收藏代码][icon_star.png]

1.  \--存储过程  
2.  CREATE OR REPLACE PROCEDURE proc\_test\_new(y\_Array IN y\_oracle\_list,    
3.                                            p\_out   OUT NUMBER) AS    
4.    v\_yID     number;    
5.    v\_yTel    varchar(50);    
6.    v\_anumber varchar(50);    
7.    v\_type    yoracleobject;    
8.  begin    
9.    FOR I IN 1 .. y\_Array.COUNT LOOP    
10.     v\_type    := y\_Array(i);    
11.     v\_yID     := v\_type.yid;    
12.     v\_yTel    := v\_type.ytel;    
13.     v\_anumber := v\_type.yanumber;    
14.     insert into test\_table values (v\_yID, v\_yTel, v\_anumber);    
15.   end loop;    
16.   commit;    
17.   p\_out := 0;    
18. EXCEPTION    
19.   WHEN OTHERS THEN    
20.     p\_out := -1;    
21.     ROLLBACK;    
22. END;

java代码：

ArrayTestProc.java

Java代码

![收藏代码][icon_star.png]

1.  package com.bijian.study;  
2.    
3.  import java.sql.CallableStatement;  
4.  import java.sql.Connection;  
5.  import java.sql.SQLException;  
6.  import java.util.ArrayList;  
7.    
8.  import oracle.jdbc.OracleCallableStatement;  
9.  import oracle.sql.ARRAY;  
10. import oracle.sql.ArrayDescriptor;  
11. import oracle.sql.STRUCT;  
12. import oracle.sql.StructDescriptor;  
13.   
14. @SuppressWarnings("unchecked")    
15. public class ArrayTestProc \{    
16.     
17.     public static void main(String\[\] args) \{  
18.           
19.         ArrayList arrayL = new ArrayList();    
20.         TestBean t = new TestBean();    
21.         t.setYid(1);    
22.         t.setYtel("1236");    
23.         t.setYanumber("骚年");    
24.         arrayL.add(t);    
25.         TestBean t1 = new TestBean();    
26.         t1.setYid(2);    
27.         t1.setYtel("1236");    
28.         t1.setYanumber("骚年");    
29.         arrayL.add(t1);      
30.         TestBean t2 = new TestBean();      
31.         t2.setYid(3);    
32.         t2.setYtel("1236");    
33.         t2.setYanumber("骚年");    
34.         arrayL.add(t2);    
35.         TestBean t3 = new TestBean();    
36.         t3.setYid(4);    
37.         t3.setYtel("1236");    
38.         t3.setYanumber("骚年");    
39.         arrayL.add(t3);    
40.         TestBean t4 = new TestBean();    
41.         t4.setYid(5);    
42.         t4.setYtel("1236");    
43.         t4.setYanumber("骚年");    
44.         arrayL.add(t4);    
45.         try \{    
46.             /\*  
47.              \* 记得判断一下list集合的大小、如果集合大于你在数据设置的数组大小了、那么就要分批次提交  
48.              \* 我的是y\_Oracle\_LIST AS VARRAY(5000)   
49.              \* 那么当list集合的值等于5000的时候就入库了、  
50.              \* 然后剩下的数据又从新用一个list来装、在继续判断......  
51.              \* 这里只是简单的演示、就不具体操作判断了  
52.              \*/    
53.             int backVal = newTest(arrayL);    
54.             System.out.println(backVal==0?"成功!":"失败!");    
55.         \} catch (SQLException e) \{    
56.             e.printStackTrace();    
57.         \}    
58.     \}    
59.     /\*\*  
60.      \* 将java中的arrayList转化  
61.      \* @param con 数据库连接对象  
62.      \* @param Oraclelist 数据数组类型名称  
63.      \* @param objlist 要存储的list对象  
64.      \* @return oracle.sql.ARRAY  
65.      \* @throws Exception  
66.      \*/    
67.     private static ARRAY getOracleArray(Connection con, String Oraclelist,    
68.             ArrayList objlist) throws Exception \{    
69.         ARRAY list = null;    
70.         if (objlist != null && objlist.size() > 0) \{    
71.             /\*\*  
72.              \* 必须大写类型名称  
73.              \* 否则会报错：java.sql.SQLException: 无效的名称模式: M\_ORDER.yoracleobject  
74.              \*/    
75.             StructDescriptor structdesc = new StructDescriptor(    
76.                     "YORACLEOBJECT", con);    
77.             STRUCT\[\] structs = new STRUCT\[objlist.size()\];    
78.             Object\[\] result = new Object\[0\];    
79.             for (int i = 0; i < objlist.size(); i++) \{    
80.                 result = new Object\[3\];     
81.                 TestBean t = (TestBean)(objlist.get(i));    
82.                 result\[0\] = t.getYid();    
83.                 result\[1\] = t.getYtel();      
84.                 result\[2\] = t.getYanumber();     
85.                 /\*  
86.                  \* 一定要记得导入orai18n.jar  
87.                  \* 否则一遇到字符串就乱码、添加不到数据  
88.                  \*/    
89.                 structs\[i\] = new STRUCT(structdesc, con, result);    
90.             \}    
91.             ArrayDescriptor desc = ArrayDescriptor.createDescriptor(Oraclelist,    
92.                     con);    
93.             list = new ARRAY(desc, con, structs);    
94.         \} else \{    
95.             ArrayDescriptor desc = ArrayDescriptor.createDescriptor(Oraclelist,    
96.                     con);    
97.             STRUCT\[\] structs = new STRUCT\[0\];    
98.             list = new ARRAY(desc, con, structs);    
99.         \}    
100.         return list;    
101.     \}     
102.         
103.     /\*\*  
104.      \* 入库  
105.      \* @param peoleList 要存储的list对象  
106.      \* @return  
107.      \* @throws SQLException  
108.      \*/    
109.     public static int newTest(ArrayList peoleList) throws SQLException\{    
110.         Connection con = null;    
111.         CallableStatement stmt = null;    
112.         int backVal = -1;     
113.         try \{    
114.             DbUtil d = new DbUtil();    
115.             con = d.getCon();    
116.             if (con != null) \{    
117.                 stmt = con.prepareCall("\{call proc\_test\_new(?,?)\}");    
118.                 ARRAY adArray = getOracleArray(con, "Y\_ORACLE\_LIST",peoleList);    
119.                 ((OracleCallableStatement) stmt).setARRAY(1, adArray);    
120.                 stmt.registerOutParameter(2, java.sql.Types.INTEGER);    
121.                 stmt.execute();     
122.                 backVal = stmt.getInt(2);    
123.             \}    
124.         \} catch (Exception e) \{    
125.             e.printStackTrace();     
126.         \} finally \{    
127.             if(stmt!=null)\{    
128.                 stmt.close();    
129.             \}    
130.             if(con!=null)\{    
131.                 con.close();    
132.             \}    
133.         \}    
134.         return backVal;    
135.     \}    
136. \}

DbUtil.java

Java代码

![收藏代码][icon_star.png]

1.  package com.bijian.study;  
2.    
3.  import java.io.IOException;    
4.  import java.io.InputStream;    
5.  import java.sql.Connection;    
6.  import java.sql.DriverManager;    
7.  import java.util.Properties;    
8.      
9.  public class DbUtil \{  
10.       
11.     static Properties properties = null;    
12.     
13.     public DbUtil() \{    
14.         // 读取.properties文件的信息    
15.         properties = new Properties();    
16.         InputStream in = getClass().getResourceAsStream("ordermanager.properties");    
17.         try \{    
18.             properties.load(in);      
19.         \} catch (IOException ex) \{    
20.             System.out.println(ex.getMessage());    
21.             ex.printStackTrace();    
22.         \}    
23.     \}    
24.         
25.     /\*\*  
26.      \* <LI>获取连接对象</LI>  
27.      \*   
28.      \* @return  
29.      \*/    
30.      public Connection getCon() \{    
31.             Connection connection = null;      
32.             try \{    
33.                 String url=properties.getProperty("jdbc.url");    
34.                 String user=properties.getProperty("jdbc.username");    
35.                 String pwd=properties.getProperty("jdbc.password");    
36.                 String driver=properties.getProperty("jdbc.driverClassName");    
37.                 Class.forName(driver);                     
38.                 connection = DriverManager.getConnection(url, user, pwd);    
39.             \} catch (Exception err) \{    
40.                   System.out.println("错误：ConDB-->getCon()\_\_\_\_JDBC连接失败!");    
41.                 err.printStackTrace();    
42.                 return null;    
43.             \}    
44.             return connection;    
45.     \}      
46. \}

TestBean.java

Java代码

![收藏代码][icon_star.png]

1.  package com.bijian.study;  
2.    
3.  public class TestBean \{  
4.    
5.      private int yid;  
6.      private String ytel;  
7.      private String yanumber;  
8.        
9.      public int getYid() \{  
10.         return yid;  
11.     \}  
12.     public void setYid(int yid) \{  
13.         this.yid = yid;  
14.     \}  
15.     public String getYtel() \{  
16.         return ytel;  
17.     \}  
18.     public void setYtel(String ytel) \{  
19.         this.ytel = ytel;  
20.     \}  
21.     public String getYanumber() \{  
22.         return yanumber;  
23.     \}  
24.     public void setYanumber(String yanumber) \{  
25.         this.yanumber = yanumber;  
26.     \}  
27. \}

ordermanager.properties

Properties代码

![收藏代码][icon_star.png]

1.  jdbc.driverClassName=oracle.jdbc.driver.OracleDriver  
2.  jdbc.url=jdbc:oracle:thin:@10.20.128.18:1521:orcl  
3.  jdbc.username=test  
4.  jdbc.password=root

运行结果：

![8d790cbd-4b8c-3c1a-863f-b56e062cbfbd.png][]

**二.TABLE类型批量入库**

不用判断list集合大小、不用考虑数组长度的做法就是用table。

使用的类型：你要新增的数据有多少字段就添加相应个数的类型

Sql代码

![收藏代码][icon_star.png]

1.  \--类型  
2.  create or replace type i\_table is table of number;    
3.  create or replace type t\_table is table of varchar2(30);    
4.  create or replace type a\_table is table of varchar2(30);

存储过程：

Sql代码

![收藏代码][icon_star.png]

1.  \--存储过程  
2.  create or replace procedure pro\_forall\_insert(v\_1 i\_table,    
3.                                                v\_2 t\_table,    
4.                                                v\_3 a\_table) as    
5.  begin    
6.    forall i in 1 .. v\_1.count   
7.       insert into test\_table values (v\_1(i), v\_2(i), v\_3(i));   
8.  END;

java代码：

Java代码

![收藏代码][icon_star.png]

1.  package com.bijian.study;  
2.    
3.  import java.sql.CallableStatement;  
4.  import java.sql.Connection;  
5.    
6.  import oracle.sql.ARRAY;  
7.    
8.  @SuppressWarnings("unchecked")    
9.  public class TableTestProc \{    
10.     
11.     public static void main(String\[\] args) \{    
12.         Connection con = null;    
13.         CallableStatement cstmt = null;    
14.         oracle.sql.ArrayDescriptor a = null;    
15.         oracle.sql.ArrayDescriptor b = null;    
16.         oracle.sql.ArrayDescriptor c = null;    
17.         DbUtil d = new DbUtil();    
18.         con = d.getCon();    
19.             
20.         Object\[\] s1 = new Object\[10000\];    
21.         Object\[\] s2 = new Object\[10000\];    
22.         Object\[\] s3 = new Object\[10000\];    
23.     
24.         for (int i = 0; i < 10000; i++) \{    
25.             s1\[i\] = new Integer(i);    
26.             s2\[i\] = "ttt"+i;    
27.             s3\[i\] = "aaa"+i;    
28.         \}  
29.         try \{    
30.             a = oracle.sql.ArrayDescriptor.createDescriptor("I\_TABLE", con);    
31.             b = oracle.sql.ArrayDescriptor.createDescriptor("T\_TABLE", con);    
32.             c = oracle.sql.ArrayDescriptor.createDescriptor("A\_TABLE", con);    
33.             ARRAY a\_test = new ARRAY(a, con, s1);    
34.             ARRAY b\_test = new ARRAY(b, con, s2);    
35.             ARRAY c\_test = new ARRAY(c, con, s3);    
36.             cstmt = con.prepareCall("\{ call pro\_forall\_insert(?,?,?) \}");    
37.             cstmt.setObject(1, a\_test);    
38.             cstmt.setObject(2, b\_test);    
39.             cstmt.setObject(3, c\_test);      
40.             cstmt.execute();    
41.             con.commit();    
42.         \} catch (Exception e) \{  
43.             e.printStackTrace();    
44.         \}    
45.     \}    
46. \}

运行结果：

![f66ac7b3-736a-337e-ad4b-de249429347e.png][]  
        最后：Java在操作数据库存储过程时如果需要用到array或者table数据类型的话，需要导入orai18n.jar包，否则一遇到字符串就乱码、添加不到数据！

文章来源：[http://blog.csdn.net/hzw2312/article/details/8444462][http_blog.csdn.net_hzw2312_article_details_8444462]

*  [orai18n.jar][] (1.6 MB)
 *  下载次数: 2

*  [OracleArrayTable.rar][] (3.2 MB)
 *  下载次数: 2

*  [sql.rar][] (912 Bytes)
 *  下载次数: 2

*  [查看图片附件][Link 1]

[https://bijian1013.iteye.com/blog/2262435][https_bijian1013.iteye.com_blog_2262435]

[https_bijian1013.iteye.com_blog_2262435]: https://bijian1013.iteye.com/blog/2262435
[java]: https://bijian1013.iteye.com/category/263237
[oracle]: http://www.iteye.com/blogs/tag/oracle
[java 1]: http://www.iteye.com/blogs/tag/java
[ARRAY_TABLE]: http://www.iteye.com/blogs/tag/ARRAY%E3%80%81TABLE%E7%B1%BB%E5%9E%8B%E6%89%B9%E9%87%8F%E5%85%A5%E5%BA%93
[icon_star.png]: /images/20220401/e33d0a529c19452cb8fa11d30d1f2ac3.png
[8d790cbd-4b8c-3c1a-863f-b56e062cbfbd.png]: /images/20220401/a602260d724f443ab94ecda0e56fa46e.png
[f66ac7b3-736a-337e-ad4b-de249429347e.png]: /images/20220401/6b53b70ee3574aee887021de21d4f223.png
[http_blog.csdn.net_hzw2312_article_details_8444462]: http://blog.csdn.net/hzw2312/article/details/8444462
[orai18n.jar]: http://dl.iteye.com/topics/download/256d1834-c494-376d-856a-699c47bd48c2
[OracleArrayTable.rar]: http://dl.iteye.com/topics/download/dbf1f4d0-9dc8-3466-ac73-96bca01112ca
[sql.rar]: http://dl.iteye.com/topics/download/3c0f77b5-6999-3ea6-aeb5-032e98069112
[Link 1]: https://bijian1013.iteye.com/blog/2262435#