如何通过JAVA让DB2调用操作系统命令

284354749

　　引言：我们在工作中常用操作系统命令和DB2命令对数据库做数据的导入、导出等操作，但是DB2不支持复合SQL 语句调用操作系统命令，因此我们需要利用 UDF 来执行SQL 中不可用的操作（例如：执行一些SHELL或者BAT文件）。因为 UDF可以用外部语言（即，SQL 以外的其它语言，如JAVA，C）编写，并可以通过使用 CREATE 语句向数据库注册，这样我们就可以编写JAVA应用程序来调用操作系统命令和DB2的常用命令。
　　步骤（windows XP环境）：
　　1、  编写JAVA程序：
　　public class os_cmdUDF {
　　public static int os_cmd(String cmd) {
　　Runtime rt = Runtime.getRuntime();
　　Process p=null;
　　int success = 0;
　　try {
　　p = rt.exec(cmd);
　　}
　　catch (Exception e) {
　　success = -1;
　　}
　　return (success);
　　}
　　}
　　2、编译我们的java源文件，并制作jar包：
　　首先，需要明确一个问题，java虚拟机（JVM）无法执行高于自身版本的.class文件。这里建议您使用DB2自带的JDK对JAVA源文件进行编译。
　　为了方便编译，将我们写完的JAVA文件保存到例如：C:\Program Files\IBM\SQLLIB\java\jdk\bin下。进入cmd命令行，转到路径C:\Program Files\IBM\SQLLIB\java\jdk\bin下，运行命令： javac os_cmdUDF.java 对源文件进行编译。然后将编译后的.class文件打成jar包：jar cf os_cmdUDF.jar os_cmdUDF.class 这样，jar包制作完成。
　　3、运行安装jar包到数据库：
　　首先我们需要连接到DB2数据库，建立连接之后使用如下SQL语句将jar包安装到数据库里：
　　call sqlj.install_jar(’file:///C:/Program Files/IBM/SQLLIB/java/jdk/bin/os_cmdUDF.jar’,’os_cmdUDF’)
　　其中file:///C:/Program Files/IBM/SQLLIB/java/jdk/bin/os_cmdUDF.jar为jar包的全路径，os_cmdUDF为指定路径下的jar包在DB2里的名称（声明到DB2下的jar包名可以自定义）。
　　4、运行create 建立函数：
　　CREATE os_cmd( IN  VARCHAR(1000))
　　RETURNS INTEGER
　　EXTERNAL NAME 'os_cmdUDF:os_cmdUDF!os_cmd'
　　LANGUAGE JAVA
　　PARAMETER STYLE JAVA
　　NOT DETERMINISTIC
　　NO SQL
　　EXTERNAL ACTION
　　其中'os_cmdUDF:os_cmdUDF!os_cmd'第一个os_cmdUDF 为jar包名（即安装到DB2下jar包的名称），第二个os_cmdUDF为该os_cmdUDF jar包里名为os_cmdUDF的类名，os_cmd为该类里一个名为os_cmd的方法名。
　　5、测试函数是否可用：
　　values os_cmd('ipconfig')
　　返回结果，
　　1
　　-----------
　　0
　　1 条记录已选择。
　　函数可以用。
　　说明：因为在cmd下ipconfig命令为正确命令，命令执行成功返回0。同理，这里可以执行我们事先编写好的SHELL或者BAT文件，执行时需要注意路径的书写。例：在D盘下有一个文件名为a.bat批处理文件。调用函数： values os_cmd(‘d:///a.bat’)
　　6、创建存储过程，调用函数：
　　至此，我们可以方便的在存储过程里调用我们写好的函数。下面为一个简单的存储过程实例：
　　CREATE PROCEDURE P_OS_CMD(IN CMD VARCHAR(1000))
　　LANGUAGE SQL
　　BEGIN
　　RETURN os_cmd(CMD);
　　END
　　7、测试存储过程是否可用：
　　call p_os_cmd('a')
　　返回状态 = -1
　　说明：因为”a”不是cmd下的命令，所以执行失败，java执行后返回-1，所以返回状态为-1。
　　备注：
　　1、若要移除我们安装到db2里的jar包，使用：call sqlj.remove_jar(‘jar包名’) 移除。但需要注意的是，若有函数或存储过程在使用要被移除的jar包，需要将相应的函数和存储过程drop掉后再做移除操作。
　　2、再次强调，建议使用DB2的JDK编译java源文件。原理上低版本jdk编译的文件在高版本的jvm中可以运行，但不保证在DB2中是这样的。
　　3、file:///C:/Program Files/IBM/SQLLIB/java/jdk/bin/os_cmdUDF.jar中file:///与后面的C:/之间没有空格。直接copy该文档的代码会出现空格。
　　4、在DB2中调用系统命令是隐式的执行，比如使用命令行“notepad”新建记事本，是不会有反应的，但是使用命令删除文件，是可执行的。
　　附：UNIX环境下的JAVA源代码。第二个方法为检测所指文件是否存在。此外将命令行执行的结果通过IO流打印到控制台。
　　import COM.ibm.db2.app.UDF;
　　import java.io.*;
　　public class os_cmdUDF extends UDF{
　　public static int jfun_ExcCmd(String cmd) {
　　Runtime rt = Runtime.getRuntime();
　　String[] args= new String[] {"/bin/sh", "-c", cmd};
　　Process p=null;
　　int success = -1;
　　try{
　　p = rt.exec(args);
　　success = 0;
　　InputStreamReader reader =
　　new InputStreamReader(p.getInputStream());
　　BufferedReader br = new BufferedReader(reader);
　　while ((line = br.readLine()) != null) {
　　System.out.println(line);
　　//在控制台上打印出执行结果。
　　}
　　br.close();
　　reader.close();
　　}catch (Exception e) {
　　e.printStackTrace();
　　success = -1;
　　}
　　return success;
　　}
　　public static int jfun_IsFileExists(String url){
　　int i = -1;
　　File file = null;
　　try{
　　file = new File(url);
　　if(file.exists()){
　　//测试此抽象路径名表示的文件或目录是否存在。
　　i=0;
　　if(file.isFile()){
　　//测试此抽象路径名表示的文件是否是一个标准文件。
　　i=1;
　　}
　　}
　　}catch(Exception e){
　　return -1;
　　}
　　return i;
　　}
　　public static void main(String args[]){
　　StringBuffer buff = new StringBuffer();
　　if(null!=args){
　　for(int i=0;i<args.length;i++){
　　buff.append(args);
　　if(i<args.length-1){
　　buff.append(" ");
　　}
　　}
　　}
　　}
　　}