轻量级作业：

也称为持久性轻量级作业，如果当我们的数据库每秒钟需要创建、删除或修改数十个或数百个作业时，使用轻量级作业是降低开销的最佳方法

常规作业：

是由oracle 11g Scheduler 所支持的作业，常规作业需要很多的系统开销，因为他们必须由Scheduler创建且每次执行完由Scheduler删除，常规作业提供了使用诸如其它用户程序的优点，并且提供了对运行此作业的权限细粒度控制

轻量级作业有别于常规作业的特征如下：

1.轻量级作业不是数据库对象，不会产生创建或删除轻量级作业时多引起的开销

2.与普通作业相比，创建和删除轻量级作业的时间少的很多；

3.轻量级作业的作业元数据和运行时数据占用的磁盘空间很少；

4.由于占用的磁盘空间少，可以再RAC环境中平衡轻量级作业的负载；

轻量级作业有几个缺点：

1.无法设置轻量级作业的权限，作业的权限从模板的计划继承而来

2.由于轻量级作业使用模板，无法创建完全独立的轻量级作业，我们必须使用PL/SQL命令创建轻量级作业，而无法用过EM创建

创建轻量级作业：

我们可以使用DBMS_SCHEDULER.CREATE_PROGRAM创建与轻量级作业一起使用的模板，供轻量级作业的模板存储为PLSQL_BLOCK或STORED_PROCEDURE类型的计划，创建轻量级作业时，指定LIGHEWERGHT的JOB_STYLE。JOB_STYLE的默认值是REGULAR

例：

grant execute on dbms_scheduler to scott;

create table d as select * from dept;

创建一个调度MY_SCHED：

BEGIN

　　dbms_scheduler.create_schedule(

　　　　repeat_interval => 'FREQ=MINUTELY',

　　　　start_date => systimestamp at time zone 'Asia/Shanghai',

　　　　schedule_name => '"SCOTT"."MY_SCHED"'

　　);

END;

/

创建一个程序MY_PROG：

BEGIN

　　dbms_scheduler.create_program(

　　　　program_name=>'"SCOTT"."MY_PROG"',

　　　　program_action=>'begin

　　　　　　insert into d select * from d;

　　　　　　commit;

　　　　end;',

　　　　program_type=>'PLSQL_BLOCK',

　　　　number_of_arguments=>0,

　　　　comments=>'',

　　　　enabled=>TRUE

　　);

END;

/

创建一个轻量级作业my_lightweight_job2：

BEGIN

　　dbms_scheduler.create_job(

　　　　job_name => 'my_lightweight_job2',

　　　　program_name => 'MY_PROG',

　　　　schedule_name => 'MY_SCHED',

　　　　enabled=>true,

　　　　job_style => 'LIGHTWEIGHT'

　　);

END;

/

select * from d;

删除一个轻量级作业：

BEGIN

　　dbms_scheduler.drop_job(

　　　　job_name => 'my_lightweight_job2'

　　);

END;

/

基于时间的调度

conn hr/hr

create table job_test(sdate date);

创建程序

BEGIN

　　dbms_scheduler.create_program(

　　　　program_name=>'HR.insert_sysdate',

　　　　program_action=>'insert into job_test values(sysdate);',

　　　　program_type=>'PLSQL_BLOCK',

　　　　number_of_arguments=>0,

　　　　comments=>'',

　　　　enabled=>TRUE

　　);

END;

创建调度

BEGIN

　　dbms_scheduler.create_schedule(

　　　　repeat_interval => 'FREQ=SECONDLY',

　　　　start_date => systimestamp at time zone '+8:00',

　　　　schedule_name => '"HR"."INSERT_SCHE"'

　　);

END;

创建作业

BEGIN

　　dbms_scheduler.create_job(

　　　　job_name => '"HR"."INSERT_JOB"',

　　　　program_name => 'HR.INSERT_SYSDATE',

　　　　schedule_name => 'HR.INSERT_SCHE',

　　　　job_class => 'DEFAULT_JOB_CLASS',

　　　　auto_drop => FALSE,

　　　　enabled => TRUE

　　);

END;

查看结果

conn hr/hr

select * from job_test;

监视作业

select job_name, status, error#, run_duration from user_scheduler_job_run_details

删除作业

begin

　　dbms_scheduler.drop_job(job_name => '"HR"."INSERT_JOB"', force => true);

end;

基于事件的调度

创建测试用表

conn hr/hr

create table event_job_test(id number, createdatae date);

alter table event_job_test add constraint pk_event_job_test primary key(id);

create sequence seq_event_job_test;

创建一个类型：

create or replace type t_event_queue as object(object_owner varchar2(50), event_name varchar2(50));

创建一个队列表，该队列包含的字段就是我们刚才创建的类型t_event_queue所包含的属性。

conn /as sysdba

grant execute on dbms_aqadm to hr;

conn hr/hr

begin

　　dbms_aqadm.create_queue_table(

　　　　queue_table=>'event_queue_tab',

　　　　queue_payload_type=>'t_event_queue',

　　　　multiple_consumers=>true

　　);

end;

/

创建一个队列，并将该队列与前面创建的队列表关联

begin

　　dbms_aqadm.create_queue(

　　　　queue_name=>'event_queue',

　　　　queue_table=>'event_queue_tab'

　　);

end;

/

启动队列

begin

　　dbms_aqadm.start_queue(queue_name=>'event_queue');

end;

/

创建一个基于事件的任务

conn /as sysdba

BEGIN

　　dbms_scheduler.create_job(

　　　　job_name => '"HR"."EVENT_BASE_JOB"',

　　　　job_type => 'PLSQL_BLOCK',

　　　　job_action => 'begin

　　　　　　insert into hr.event_job_test values(seq_event_job_test.nextval, sysdate);

　　　　　　commit;

　　　　end;',

　　　　event_condition => 'tab.user_data.object_owner=''HR'' and 　　　　　　　tab.user_data.event_name=''give_me_an_event''',

　　　　queue_spec => 'HR.EVENT_QUEUE',

　　　　start_date => systimestamp at time zone '+8:00',

　　　　job_class => 'DEFAULT_JOB_CLASS',

　　　　auto_drop => FALSE,

　　　　enabled => TRUE

　　);

END;

向队列中插入消息

没插入之前，查询表，发现没数据。

conn hr/hr

select * from event_job_test;

向队列里插入消息

conn /as sysdba

grant execute on dbms_aq to hr;

conn hr/hr

declare

　　l_enqueue_options dbms_aq.enqueue_options_t;

　　l_message_properties dbms_aq.message_properties_t;

　　l_message_handle raw(16);

　　l_queue_msg t_event_queue;

begin

　　l_queue_msg := t_event_queue('HR','give_me_an_event');

　　dbms_aq.enqueue(

　　　　queue_name=>'event_queue',

　　　　enqueue_options=>l_enqueue_options,

　　　　message_properties=>l_message_properties,

　　　　payload=>l_queue_msg,

　　　　msgid=>l_message_handle

　　);

　　commit;

end;

select * from event_job_test;

删除作业：

begin

　　dbms_scheduler.drop_job(job_name => '"HR"."EVENT_BASE_JOB"',  force => true);

end;

---------------------------------------------------------------------------------------------------------------------------------------------

创建基于事件的调度加载数据

创建测试用表

conn scott/tiger

create table t as select * from emp where 1=2;

vi /u01/load.ctl

load data

infile '/u01/data.txt'

badfile '/u01/bad.emp'

discardfile '/u01/discadr.emp'

truncate

into table t

fields terminated by ','

trailing nullcols

(EMPNO,

ENAME,

JOB,

MGR,

HIREDATE,

SAL,

COMM,

DEPTNO)

vi /u01/load.sh

#!/bin/bash

export ORACLE_BASE=/u01/app/oracle

export ORACLE_HOME=$ORACLE_BASE/product/11.2/db_1

export ORACLE_SID=orcl

$ORACLE_HOME/bin/sqlldr scott/tiger control=/u01/load.ctl log=/u01/load.log

保存退出

chmod +x /u01/load.sh

将emp中的数据转储到/u01/data.txt中：

set trims on

spool /u01/data.txt

select

EMPNO||','||

ENAME||','||

JOB||','||

MGR||','||

HIREDATE||','||

SAL||','||

COMM||','||

DEPTNO from emp;

spool off

创建一个类型：

sqlplus scott/tiger

create or replace type t_event_queue as object

(

object_owner varchar2(10),

object_name varchar2(20),

event_type varchar2(20),

event_timestamp number(2)

);

/

创建一个队列表，该队列包含的字段就是我们刚才创建的类型t_event_queue所包含的属性。

conn /as sysdba

grant execute on dbms_aqadm to scott;

conn scott/tiger

begin

dbms_aqadm.create_queue_table(

queue_table=>'event_queue_tab',

queue_payload_type=>'t_event_queue',

multiple_consumers=>true);

end;

/

创建一个队列，并将该队列与前面创建的队列表关联

begin

dbms_aqadm.create_queue(

queue_name=>'event_queue',

queue_table=>'event_queue_tab');

end;

/

启动队列

begin

dbms_aqadm.start_queue(queue_name=>'event_queue');

end;

/

创建一个基于事件的任务

conn /as sysdba

BEGIN

sys.dbms_scheduler.create_job(job_name => '"SYS"."PERFORM_DATA_LOAD"', --属主必须是sys

job_type => 'EXECUTABLE',

job_action => '/u01/load.sh',

event_condition => 'tab.user_data.object_owner = ''SCOTT''

and tab.user_data.object_name = ''DATA.TXT''

and tab.user_data.event_type = ''FILE_ARRIVAL''

and tab.user_data.event_timestamp < 9',--创建一个作业，如果成批装入的数据文件在上午 9:00 之前到达文件系统，则运行此作业

queue_spec => 'SCOTT.EVENT_QUEUE',

start_date => systimestamp at time zone

'+8:00',

job_class => 'DEFAULT_JOB_CLASS',

auto_drop => FALSE,

enabled => TRUE);

END;

/

向队列中插入消息

conn scott/tiger

select * from t;

向队列里插入消息

conn /as sysdba

grant execute on dbms_aq to scott;

conn scott/tiger

declare

l_enqueue_options dbms_aq.enqueue_options_t;

l_message_properties dbms_aq.message_properties_t;

l_message_handle raw(16);

l_queue_msg t_event_queue;

begin

l_queue_msg := t_event_queue('SCOTT', 'DATA.TXT', 'FILE_ARRIVAL',8);

dbms_aq.enqueue(queue_name => 'event_queue',

enqueue_options => l_enqueue_options,

message_properties => l_message_properties,

payload => l_queue_msg,

msgid => l_message_handle);

commit;

end;

/

select * from t;

删除作业：

conn /as sysdba

begin

dbms_scheduler.drop_job(job_name => '"SYS"."PERFORM_DATA_LOAD"', force => true);

end;

/

总结一下oracle db里用job调度shell的注意点：

1、shell脚本里开头要加#!/bin/bash等指定使用的shell类型

2、所有相关环境变量都得在shell里明确指定

3、如果要写入文件必需使用绝对路径

4、使用sys用户建立job