以下方法在WINNT,LINUX下的oracle9i上測試通過，java過程調用系統命令

首先給使用java存儲過程的用戶授予一定的權限

<>表示所有文件，也可以單獨指定文件。

r w e d表示四種操作

Code:

Dbms_Java.Grant_Permission('HR',

'java.io.FilePermission', '<>',

'read ,write, execute, delete');

Dbms_Java.Grant_Permission('HR',

'java.io.FilePermission', 'd:aa.bat',

'read ,write, execute, delete');

dbms_java.grant_permission

('HR',

'java.lang.RuntimePermission',

'*',

'writeFileDescriptor' );

end;

/

PL/SQL procedure successfully completed.

See

... timePermission.html

... rityPermission.html

s/api/java/io/FilePermission.html

and

... 53/perf.htm#1001971

From the “Java Developer’s Guide”, Part No. A81353-01, Chapter 5:

Table 5?1 Permission Types

n java.util.PropertyPermission

n java.io.SerializablePermission

n java.io.FilePermission

n java.net.NetPermission

n java.net.SocketPermission

n java.lang.RuntimePermission

n java.lang.reflect.ReflectPermission

n java.security.SecurityPermission

n oracle.aurora.rdbms.security.PolicyTablePermission

n oracle.aurora.security.JServerPermission

相關的java類如下

SQL> connect hr/hr@ts

已連接。

create or replace and compile

java source named "Util"

as

import java.io.*;

import java.lang.*;

public class Util extends Object

{

public static int RunThis(String args)

{

Runtime rt = Runtime.getRuntime();

int　　　　rc = -1;

try

{

Process p = rt.exec(args);

int bufSize = 4096;

BufferedInputStream bis =

new BufferedInputStream(p.getInputStream(), bufSize);

int len;

byte buffer[] = new byte[bufSize];

// Echo back what the program spit out

while ((len = bis.read(buffer, 0, bufSize)) != -1)

System.out.write(buffer, 0, len);

rc = p.waitFor();

}

catch (Exception e)

{

e.printStackTrace();

rc = -1;

}

finally

{

return rc;

}

}

}

/

Java created.

建立函數

create or replace

function RUN_CMD(p_cmd in varchar2) return number

as

language java

name 'Util.RunThis(java.lang.String) return integer';

/

Function created.

建立一過程調用函數

create or replace procedure RC(p_cmd in varchar2)

as

x number;

begin

x := run_cmd(p_cmd);

end;

/

Procedure created.

SQL> variable x number;

SQL>　set serveroutput on

SQL> exec dbms_java.set_output(100000);

PL/SQL procedure successfully completed.

可以執行相應的命令和bat文件

SQL>　exec :x := RUN_CMD('ipconfig');

Windows 2000 IP Configuration

Ethernet adapter 本地連接

:

Connection-specific DNS Suffix　. :

IP Address. . . . . . . . . . . . : 172.18.25.102

Subnet Mask . . . . . . .

. . . . : 255.255.255.0

Default Gateway . . . . . . . . . : 172.18.25.1

PL/SQL 過程已成功完成。

也可以執行服務器上的bat文件

SQL>　 exec :x := RUN_CMD('c:aa.bat');

c:oracleora92DATABASE>cmd /c

c:oracleora92DATABASE>dir

Volume in drive C is 本地磁盤

Volume Serial Number is 5CE1-2622

Directory of c:oracleora92DATABASE

2004-05-15　15:47　　　 .

2004-05-15　15:47　　　 ..

2002-12-24　20:13　　　 archive

1998-09-09　18:31　　　　　　　 31,744 oradba.exe

2004-05-08　11:48　　　　　　　　　568 OraDim.Log

2004-03-17　11:53　　　　　　　　1,536 PWDweblish.ora

2004-05-15　15:47　　　　　　1,871,872 SNCFWEBLISH.ORA

2003-12-29　13:24　　　　　　　　2,560 SPFILEWEBLISH.ORA

2004-05-08　11:48　　　　　　　 12,852 sqlnet.log

6 File(s)　　　1,921,132 bytes

3 Dir(s)　 7,141,621,760 bytes free

－－－－－－－－－－－－－－－－－

c:aa.bat如下：

cmd /c

dir

以下是利用proc實現：

在Oracle 8i中,往往會出現要在存儲過程中運行操作系統命令的情況.一般來說,利用Oracle Enterprise Manager設定作業時可以達到這個目的.但是由于OEM在設定作業缺乏靈活性,設定的作業的參數是固定的.在實際應用當中往往需要在SQL語句當中運行需要隨時運行操作系統命令.Oracle 8i沒有直接運行OS命令的語句,我們可以利用DBMS_PIPE程序包實現這一要求.

DBMS_PIPE通過創建管道,可以讓至少兩個進程進行通信.Oracle的管道與操作系統的管道在概念上有相同的地方,但是在實現機制不同.

下面介紹實現具體步驟:

1 創建一個程序包,姑且起名叫DAEMON,SQL語句如下:

/*創建daemon程序包*/CREATEORREPLACEPACKAGE BODY daemonAS/*execute_system是實現運行os命令的函數*/FUNCTIONexecute_system(commandVARCHAR2,

timeoutNUMBERDEFAULT10)RETURNNUMBERISstatusNUMBER;

resultVARCHAR2(20);

command_codeNUMBER;

pipe_nameVARCHAR2(30);BEGINpipe_name :=DBMS_PIPE.UNIQUE_SESSION_NAME;

DBMS_PIPE.PACK_MESSAGE('SYSTEM');

DBMS_PIPE.PACK_MESSAGE(pipe_name);

DBMS_PIPE.PACK_MESSAGE(command);/*向daemon管道發送表示命令的字符*/status :=DBMS_PIPE.SEND_MESSAGE('daemon', timeout);IFstatus<>0THENRAISE_APPLICATION_ERROR(-20010,'Execute_system: Error while sending. Status ='||status);ENDIF;

status :=DBMS_PIPE.RECEIVE_MESSAGE(pipe_name, timeout);IFstatus<>0THENRAISE_APPLICATION_ERROR(-20011,'Execute_system: Error while receiving.

Status ='||status);ENDIF;/*獲取返回結果*/DBMS_PIPE.UNPACK_MESSAGE(result);IFresult<>'done'THENRAISE_APPLICATION_ERROR(-20012,'Execute_system: Done not received.');ENDIF;

DBMS_PIPE.UNPACK_MESSAGE(command_code);

DBMS_OUTPUT.PUT_LINE('System command executed. result ='||command_code);RETURNcommand_code;ENDexecute_system;/*stop是讓daemon停止*/PROCEDUREstop(timeoutNUMBERDEFAULT10)ISstatusNUMBER;BEGINDBMS_PIPE.PACK_MESSAGE('STOP');

status :=DBMS_PIPE.SEND_MESSAGE('daemon', timeout);IFstatus<>0THENRAISE_APPLICATION_ERROR(-20030,'stop: error while sending. status ='||status);ENDIF;ENDstop;ENDdaemon;

通過Sql*Plus運行以上語句,將為當前用戶創建daemon程序包.

2 創建在OS上運行的守護進程,監聽由上面的daemon程序包發來的要求執行os命令的語句.以下Pro*C的代碼,必須由pro*c先進行預編譯.

#include

#include

EXECSQL INCLUDE SQLCA;

EXECSQLBEGINDECLARESECTION;char*uid="scott/tiger";/*在這個地方改為你自己訪問的用戶,密碼,服務名*/intstatus;

VARCHARcommand[20];

VARCHARvalue[2000];

VARCHARreturn_name[30];

EXECSQLENDDECLARESECTION;

void

connect_error()

{

charmsg_buffer[512];

intmsg_length;

intbuffer_size=512;

EXECSQL WHENEVER SQLERRORCONTINUE;

sqlglm(msg_buffer,&buffer_size,&msg_length);

printf("Daemon errorwhileconnecting:n");

printf("%.*sn", msg_length, msg_buffer);

printf("Daemon quitting.n");

exit(1);

}

void

sql_error()

{

charmsg_buffer[512];

intmsg_length;

intbuffer_size=512;

EXECSQL WHENEVER SQLERRORCONTINUE;

sqlglm(msg_buffer,&buffer_size,&msg_length);

printf("Daemon errorwhileexecuting:n");

printf("%.*sn", msg_length, msg_buffer);

printf("Daemon continuing.n");

}

main()

{

EXECSQL WHENEVER SQLERROR DO connect_error();

EXECSQL CONNECT :uid;

printf("Daemon connected.n");

EXECSQL WHENEVER SQLERROR DO sql_error();

printf("Daemon waiting...n");

while(1) {

EXECSQLEXECUTEBEGIN/*接收deamon發來的字符*/:status :=DBMS_PIPE.RECEIVE_MESSAGE('daemon');

IF:status=0THEN/*取出字符*/DBMS_PIPE.UNPACK_MESSAGE(:command);

ENDIF;

END;

END-EXEC;

IF(status==0)

{

command.arr[command.len]='';/*如果是stop,該進程就退出*/IF(!strcmp((char*) command.arr, "STOP"))

{

printf("Daemon exiting.n");

break;

}

ELSEIF(!strcmp((char*) command.arr, "SYSTEM"))

{

EXECSQLEXECUTEBEGINDBMS_PIPE.UNPACK_MESSAGE(:return_name);

DBMS_PIPE.UNPACK_MESSAGE(:value);

END;

END-EXEC;

value.arr[value.len]='';

printf("Willexecutesystem command'%s'n", value.arr);/*運行os命令*/status=system(value.arr);

EXECSQLEXECUTEBEGINDBMS_PIPE.PACK_MESSAGE('done');

DBMS_PIPE.PACK_MESSAGE(:status);

:status :=DBMS_PIPE.SEND_MESSAGE(:return_name);

END;

END-EXEC;

IF(status)

{

printf

("Daemon errorwhilerespondingtosystem command.");

printf(" status:%dn", status);

}

}

ELSE{

printf

("Daemon error: invalid command'%s'received.n",

command.arr);

}

}

ELSE{

printf("Daemon errorwhilewaitingforsignal.");

printf(" status=%dn", status);

}

}

EXECSQLCOMMITWORKRELEASE;

exit(0);

}

以上代碼起名為daemon.pc,用proc預編譯:

proc iname=daemon.pc userid=用戶名/密碼@服務名 sqlcheck=semantics

得到daemon.c,在用c進行編譯,注意在NT上要把orasql8.lib加上,否則編譯通過,連接沒法通過.

3 在服務器上運行daemon.exe

4 在sqlplus運行測試語句:

SQL>variable rvnumberSQL>execute:rv :=DAEMON.EXECUTE_SYSTEM('ls -la');

PL/SQL 過程已成功完成。

SQL>execute:rv :=DAEMON.EXECUTE_SYSTEM('dir');

PL/SQL 過程已成功完成。

DBMS_PIPE的用法見oracle的文檔.

總結

以上是生活随笔為你收集整理的利用oracle执行系统命令,利用oracle存储过程执行操作系统命令(转)的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。