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

作者: 问笑
发布时间:2015-07-15 10:31:03

引言:我们在工作中常用操作系统命令和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[i]);

if(i<args.length-1){

buff.append(" ");

}

}

}

}

}

来源:http://www.cnblogs.com/sideny/p/3335142.html

推荐: