当前位置: 首页 > 图文教程 > 数据库 > Oracle > Oracle中如何直接运行OS命令(上)

Oracle
Excel VBA连接并操作Oracle
Oracle 外连接实现代码
oracle 存储过程和函数例子
Oracle 数据库操作类
ORACLE 分区表的设计
Oracle 用户权限管理方法
Oracle In和exists not in和not exists的比较分析
利用windows任务计划实现oracle的定期备份
ORACLE11g随RHEL5系统自动启动与关闭的设置方法
在oracle 数据库查询的select 查询字段中关联其他表的方法
plsql和tsql常用函数比对
plsql与tsql的语法不同
ASP.NET调用oracle存储过程实现快速分页
执行drop表操作后数据库无法起动
分析Oracle有时会用索引来查找数据的原因
数据从MySQL迁移到 Oracle的注意事项
快速理解Oracle归档模式的命令及参数
在Oracle里加快SQL执行的三种方法
几条常见的数据库分页 SQL 语句
Oracle9I OCP认证过程

Oracle中如何直接运行OS命令(上)


出处:互联网   整理: 软晨网(RuanChen.com)   发布: 2009-10-31   浏览: 123 ::
收藏到网摘: n/a

  在Oracle 8i中,往往会出现要在存储过程中运行操作系统命令的情况。一般来说,利用Oracle Enterprise Manager设定作业时可以达到这个目的。但是由于OEM在设定作业缺 乏灵活性,设定的作业的参数是固定的。在实际应用当中往往需要在SQL语句当中运行需要随时运行操作系统命令。Oracle 8i没有直接运行OS命令的语句,我们可以利用DBMS_PIPE程序包实现这一要求。 

  DBMS_PIPE通过创建管道,可以让至少两个进程进行通信。Oracle的管道与操作系统的管道在概念上有相同的地方,但是在实现机制不同。

  下面介绍实现具体步骤: 

  1、创建一个程序包,姑且起名叫DAEMON,SQL语句如下: 

  /*创建daemon程序包*/ 
  CREATE OR REPLACE PACKAGE BODY daemon AS 
  /*execute_system是实现运行os命令的函数*/ 
  FUNCTION execute_system(command VARCHAR2, 
  timeout NUMBER DEFAULT 10) 
  RETURN NUMBER IS 

  status NUMBER;
  result VARCHAR2(20);
  command_code NUMBER;
  pipe_name VARCHAR2(30);
  BEGIN 
  pipe_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);
  IF status <> 0 THEN 
  RAISE_APPLICATION_ERROR(-20010, 
  'Execute_system: Error while sending. Status = ' || status);
  END IF;

  status := DBMS_PIPE.RECEIVE_MESSAGE(pipe_name, timeout);
  IF status <> 0 THEN 
  RAISE_APPLICATION_ERROR(-20011, 
  'Execute_system: Error while receiving. 
  Status = ' || status);
  END IF;
  /*获取返回结果*/ 
  DBMS_PIPE.UNPACK_MESSAGE(result);
  IF result <> 'done' THEN 
  RAISE_APPLICATION_ERROR(-20012, 
  'Execute_system: Done not received.');
  END IF;

  DBMS_PIPE.UNPACK_MESSAGE(command_code);
  DBMS_OUTPUT.PUT_LINE('System command executed. result = ' || 
  command_code);
  RETURN command_code;
  END execute_system;
  /*stop是让daemon停止*/ 
  PROCEDURE stop(timeout NUMBER DEFAULT 10) IS 
  status NUMBER;
  BEGIN 
  DBMS_PIPE.PACK_MESSAGE('STOP');
  status := DBMS_PIPE.SEND_MESSAGE('daemon', timeout);
  IF status <> 0 THEN 
  RAISE_APPLICATION_ERROR(-20030, 
  'stop: error while sending. status = ' || status);
  END IF;
  END stop;
  END daemon;

  通过Sql*Plus运行以上语句,将为当前用户创建daemon程序包。 

  2、创建在OS上运行的守护进程,监听由上面的daemon程序包发来的要求执行os命令的语句。以下Pro*C的代码,必须由pro*c先进行预编译。 

  #include 
  #include 

  EXEC SQL INCLUDE SQLCA;

  EXEC SQL BEGIN DECLARE SECTION;
  char *uid = "scott/tiger";/*在这个地方改为你自己访问的用户,密码,服务名*/ 
  int status;
  VARCHAR command;
  VARCHAR value[2000];
  VARCHAR return_name[30];
  EXEC SQL END DECLARE SECTION;

  void 
  connect_error() 
  { 
  char msg_buffer[512];
  int msg_length;
  int buffer_size = 512;