如何用JAVA调用DB2的export

sue

在DB2 V8.17中，如何用JAVA调用DB2的export

安哥网络

需要用代码备份db2的表,java不能直接执行，google发现要用ADMIN_CMD这个存储过程执行export，db2v8.1要打到补丁9以上才会有 ADMIN_CMD，高版本不用打补丁.db2v8.1不打补丁会报(COM.ibm.db2.jdbc.DB2Exception: [IBM][CLI Driver][DB2/NT] SQL0444N  例程 "ADMIN_CMD"（特定名称 "SQL100224161758450"）是用库或路径 "\SYSPROC.ADMIN_CMD" 中的代码以及不能存取的函数 "SYSPROC.ADMIN_CMD" 来实现的。原因代码："4"。  SQLSTATE=42724)错误

以下是官网例子

1. import java.io.*;     
   
2. import java.lang.*;
   
3. import java.util.*;
   
4. import java.sql.*;
   
5. 
   
6. class AdmCmdExport
   
7. {
   
8. 
   
9.   public static void main(String argv[])
   
10.   {
    
11.     Connection con = null;
    
12.    
    
13.     int rows_exported;
    
14.     String msg_retrieval = null;
    
15.     String msg_removal = null;
    
16.     String sqlcode = null;
    
17.     String msg = null;
    
18.    
    
19.     CallableStatement callStmt1 = null;
    
20.     ResultSet rs1 = null;
    
21.     PreparedStatement stmt1 = null;
    
22.     ResultSet rs2 = null;
    
23.     CallableStatement callStmt2 = null;
    
24. 
    
25.     if (argv.length < 1)
    
26.     {
    
27.       System.out.println("\n Usage : java AdmCmdExport <path for export>");
    
28.     }
    
29.     else
    
30.     {            
    
31.       try
    
32.       {
    
33.         // initialize DB2Driver and establish database connection.
    
34.         COM.ibm.db2.jdbc.app.DB2Driver db2Driver =
    
35.           (COM.ibm.db2.jdbc.app.DB2Driver)
    
36.             Class.forName("COM.ibm.db2.jdbc.app.DB2Driver").newInstance();
    
37.         con = DriverManager.getConnection("jdbc:db2:SAMPLE");
    
38. 
    
39.         System.out.println("HOW TO PERFORM EXPORT USING ADMIN_CMD.\n");
    
40.         // prepare the CALL statement for OUT_LANGUAGE
    
41.         String sql = "CALL SYSPROC.ADMIN_CMD(?)";
    
42.         callStmt1 = con.prepareCall(sql);
    
43. 
    
44.         String param = "export to "+ argv[0] + "org_ex.ixf ";
    
45.         param = param + "of ixf messages on server select * from org" ;
    
46. 
    
47.         // set the imput parameter
    
48.         callStmt1.setString(1, param);
    
49.         System.out.println("CALL ADMIN_CMD('" + param + "')");
    
50.       
    
51.         // execute export by calling ADMIN_CMD
    
52.         callStmt1.execute();
    
53.         rs1 = callStmt1.getResultSet();
    
54.         // retrieve the resultset  
    
55.         if( rs1.next())
    
56.         {
    
57.           // the numbers of rows exported
    
58.           rows_exported = rs1.getInt(1);
    
59. 
    
60.           // retrieve the select stmt for message retrival
    
61.           // containing SYSPROC.ADMIN_GET_MSGS
    
62.           msg_retrieval = rs1.getString(2);
    
63.   
    
64.           // retrive the stmt for message cleanup
    
65.           // containing CALL of SYSPROC.ADMIN_REMOVE_MSGS
    
66.           msg_removal = rs1.getString(3);
    
67.       
    
68.           // display the output
    
69.           System.out.println("Total number of rows exported  : " + rows_exported);
    
70.           System.out.println("SQL for retrieving the messages: " + msg_retrieval);
    
71.           System.out.println("SQL for removing the messages  : " + msg_removal);
    
72.         }
    
73.       
    
74.         stmt1 = con.prepareStatement(msg_retrieval);
    
75.         System.out.println("\n" + "Executing " + msg_retrieval);  
    
76. 
    
77.         // message retrivel
    
78.         rs2 = stmt1.executeQuery();
    
79. 
    
80.         // retrieve the resultset
    
81.         while(rs2.next())
    
82.         {
    
83.           // retrieve the sqlcode
    
84.     sqlcode = rs2.getString(1);
    
85.       
    
86.           // retrieve the error message
    
87.           msg = rs2.getString(2);
    
88.           System.out.println("Sqlcode : " +sqlcode);
    
89.           System.out.println("Msg     : " +msg);
    
90.         }
    
91. 
    
92.         System.out.println("\nExecuting " + msg_removal);
    
93.         callStmt2 = con.prepareCall(msg_removal);
    
94. 
    
95.         // executing the message retrivel
    
96.         callStmt2.execute();      
    
97.       }
    
98.       catch(Exception e)
    
99.       {
    
100.         JdbcException jdbcExc = new JdbcException(e);
     
101.         jdbcExc.handle();
     
102.       }
     
103.       finally
     
104.       {
     
105.         try
     
106.         {
     
107.           // close the statements
     
108.           callStmt1.close();
     
109.           callStmt2.close();
     
110.           stmt1.close();
     
111. 
     
112.           // close the resultsets
     
113.           rs1.close();
     
114.           rs2.close();
     
115.      
     
116.           // roll back any changes to the database made by this sample
     
117.           con.rollback();
     
118. 
     
119.           // close the connection                                   
     
120.           con.close();
     
121.         }
     
122.         catch (Exception x)
     
123.         {
     
124.           System.out.print("\n Unable to Rollback/Disconnect ");
     
125.           System.out.println("from 'sample' database");
     
126.         }
     
127.       }
     
128.     }
     
129.   } // main
     
130. } // AdmCmdExport

复制代码

官网例子地址[http://publib.boulder.ibm.com/in ... mCmdExport-java.htm]

lmy

能否详细说明一下如何实现，谢谢。

lmy

能否详细描述，或提供实现例子，谢谢。