课程第7次

secoug

Notice: This blog is written by Bo Tang.

------job5

1. select  * from dba_scheduler_global_attribute;
   
2. 
   
3. select  * from dba_scheduler_notifications;
   
4. 
   
5. begin
   
6. DBMS_SCHEDULER.SET_SCHEDULER_ATTRIBUTE
   
7. ('email_server','192.168.0.79');
   
8. end;
   
9. 
   
10. begin
    
11.   DBMS_SCHEDULER.SET_SCHEDULER_ATTRIBUTE
    
12.   ('email_sender','oracle@example.com');
    
13. end;
    
14. 
    
15. 
    
16. begin
    
17.   DBMS_SCHEDULER.ADD_JOB_EMAIL_NOTIFICATION (
    
18.   job_name       =>'HR.JOB5',
    
19.     events   =>'job_succeeded,job_completed',
    
20.   recipients     =>'oracle@example.com');
    
21. end;
    
22. 
    
23. 
    
24. 
    
25. create or replace procedure hr.proc1
    
26. begin
    
27.   update t123456 set a=2;
    
28. end;
    
29. 
    
30. 
    
31. 
    
32. BEGIN
    
33. DBMS_SCHEDULER.add_job_email_notification (
    
34.   job_name         =>  'hr.job51',
    
35.   recipients       =>  'oracle@example.com',
    
36.   events           =>  'job_failed')
    
37. ;
    
38. END;
    
39. 
    
40. 
    
41. 
    
42. -
    

复制代码

Bug 16623661

---job6

1. select  * from hr.scheduler_test;
   
2. 
   
3. DROP TABLE hr.scheduler_test;
   
4. 
   
5. DROP SEQUENCE hr.scheduler_test_seq;
   
6. 
   
7. 
   
8. CREATE TABLE hr.scheduler_test (
   
9.   id            NUMBER(10)    NOT NULL,
   
10.   description   VARCHAR2(20)  NOT NULL,
    
11.   created_date  DATE          NOT NULL,
    
12.   CONSTRAINT scheduler_test_pk PRIMARY KEY (id)
    
13. );
    
14. 
    
15. CREATE SEQUENCE hr.scheduler_test_seq;
    
16. 
    
17. select  * from hr.scheduler_test;
    
18. 
    
19. 
    
20. DECLARE
    
21.   l_enqueue_options     DBMS_AQ.enqueue_options_t;
    
22.   l_message_properties  DBMS_AQ.message_properties_t;
    
23.   l_message_handle      RAW(16);
    
24.   l_queue_msg           sys.t_event_queue_payload;
    
25. BEGIN
    
26.   l_queue_msg := sys.t_event_queue_payload('Chemical_Wrong');
    
27. 
    
28.   DBMS_AQ.enqueue(queue_name          => 'sys.event_queue',
    
29.                   enqueue_options     => l_enqueue_options,
    
30.                   message_properties  => l_message_properties,
    
31.                   payload             => l_queue_msg,
    
32.                   msgid               => l_message_handle);
    
33.   COMMIT;
    
34. END;
    

复制代码

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

如果HR本人，需要以下权限
BEGIN

DBMS_RULE_ADM.grant_system_privilege(

    privilege    =>DBMS_RULE_ADM.create_rule_set_obj,

    grantee      => 'HR',

    grant_option => FALSE);

DBMS_RULE_ADM.grant_system_privilege(

    privilege    =>DBMS_RULE_ADM.create_evaluation_context_obj,

    grantee      => 'HR',

    grant_option => FALSE);

DBMS_RULE_ADM.grant_system_privilege(

     privilege   => DBMS_RULE_ADM.create_rule_obj,

    grantee      => 'HR',

    grant_option => FALSE);

END;

--------------------------------------------------
规则编程的条件语法示例：

1. ':step1.state=''SUCCEEDED'' and :step2.error_code=3'
   
2. 
   
3. '1=1'
   
4. 
   
5. ':step3.state != ''COMPLETED'''
   
6. 
   
7. ':step2.error_code not in (1,2,3)'
   
8. 
   
9. ':step1.state = ''NOT_STARTED'''
   

复制代码

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

1. BEGIN
   
2.   DBMS_SCHEDULER.create_program (
   
3.     program_name   => 'hr.test_program_1',
   
4.     program_type   => 'PLSQL_BLOCK',
   
5.     program_action => 'BEGIN
   
6.                          INSERT INTO hr.scheduler_test (id, description, created_date)
   
7.                          VALUES (hr.scheduler_test_seq.NEXTVAL, ''test_program_1'', SYSDATE);
   
8.                          COMMIT;
   
9.                        END;',
   
10.     enabled        => TRUE,
    
11.     comments       => 'Step2');
    
12. 
    
13.   DBMS_SCHEDULER.create_program (
    
14.     program_name   => 'hr.test_program_2',
    
15.     program_type   => 'PLSQL_BLOCK',
    
16.     program_action => 'BEGIN
    
17.                          INSERT INTO hr.scheduler_test (id, description, created_date)
    
18.                          VALUES (hr.scheduler_test_seq.NEXTVAL, ''test_program_2'', SYSDATE);
    
19.                          COMMIT;
    
20.                        END;',
    
21.     enabled        => TRUE,
    
22.     comments       => 'Step3');
    
23. 
    
24.   DBMS_SCHEDULER.create_program (
    
25.     program_name   => 'hr.test_program_3',
    
26.     program_type   => 'PLSQL_BLOCK',
    
27.     program_action => 'BEGIN
    
28.                          INSERT INTO hr.scheduler_test (id, description, created_date)
    
29.                          VALUES (hr.scheduler_test_seq.NEXTVAL, ''test_program_3'', SYSDATE);
    
30.                          COMMIT;
    
31.                        END;',
    
32.     enabled        => TRUE,
    
33.     comments       => 'Step4');
    
34. END;
    

复制代码

test_chain:

1. BEGIN
   
2.   DBMS_SCHEDULER.run_chain (
   
3.     chain_name    =>  'test_chain_1',
   
4.     job_name      =>  'test_chain_1_run_job',
   
5.     start_steps   =>  'chain_step_1, chain_step_2, chain_step_3');
   
6. END;
   

复制代码