|
Notice: This blog is written by Bo Tang.
job9:
- select * from dba_scheduler_credentials;
- select * from hr.scheduler_test;
- select hr.scheduler_test_seq.currval from dual;
- alter table hr.scheduler_test add ( event_name varchar2(40)) ;
- select sysdate from dual;
- create or replace procedure procnew( p_1 sys.t_event_queue_payload )
- is
- BEGIN
- INSERT INTO scheduler_test
- VALUES (scheduler_test_seq.NEXTVAL, 'job9',SYSDATE, p_1.event_name );
- COMMIT;
- END;
- select * from user_errors;
- begin
- dbms_scheduler.create_program (
- program_name => 'programnew',
- program_action=> 'procnew',
- program_type => 'STORED_PROCEDURE',
- number_of_arguments => 1,
- enabled => false) ;
- end;
- select * from user_scheduler_programs;
- select * from user_scheduler_program_args;
- begin
- dbms_scheduler.define_metadata_argument (
- program_name => 'programnew',
- argument_position => 1 ,
- metadata_attribute => 'EVENT_MESSAGE') ;
- end;
- begin
- dbms_scheduler.enable ('programnew');
- end;
- select * from user_scheduler_programs;
复制代码
--------------------------------------------
| ID | DESCRIPTION | CREATED_DATE | EVENT_NAME | 1 | 16 | test_program_2 | 9/17/2019 8:54:12 AM | | 2 | 4 | test_program_1 | 9/16/2019 7:46:07 PM | | 3 | 5 | test_program_2 | 9/16/2019 7:46:07 PM | | 4 | 6 | test_program_3 | 9/16/2019 7:46:07 PM | | 5 | 7 | test_program_1 | 9/16/2019 7:49:20 PM | | 6 | 8 | test_program_2 | 9/16/2019 7:49:20 PM | | 7 | 9 | test_program_3 | 9/16/2019 7:49:20 PM | | 8 | 10 | test_program_1 | 9/16/2019 8:04:39 PM | | 9 | 11 | test_program_3 | 9/16/2019 8:04:39 PM | | 10 | 12 | test_program_2 | 9/16/2019 8:08:53 PM | | 11 | 13 | test_program_3 | 9/16/2019 8:08:53 PM | | 12 | 14 | test_program_2 | 9/16/2019 8:16:23 PM | | 13 | 15 | job9 | 9/17/2019 8:54:11 AM | Chemical_Wrong |
-----------------------------------job10
- [root@station79 lib64]# ln -s /lib64/libpam.so.0.82.2 /lib64/libpam.so
复制代码
- select * from dba_scheduler_file_watchers;
- select * from dba_scheduler_credentials;
- begin
- dbms_scheduler.create_file_watcher(
- file_watcher_name => 'filewatcher1',
- directory_path => '/home/oracle/myfile',
- file_name => 'botang*.txt',
- credential_name => 'credential1');
- end;
复制代码
由于以上截图中的变化了的queue,所以一定要按照以下方法做job10:
- BEGIN
- DBMS_SCHEDULER.CREATE_JOB(
- jOB_NAME=> 'hr.job10',
- PROGRAM_NAME=> 'hr.program10',
- EVENT_CONDITION => 'tab.user_data.file_size > 10',
- QUEUE_SPEC=> 'filewatcher1',
- AUTO_DROP=> FALSE,
- ENABLED=> true);
- END;
复制代码- begin
- dbms_scheduler.set_attribute('hr.job10','parallel_instances',true);
- end;
复制代码
job11:
- select * from dba_scheduler_dests;
- select * from dba_scheduler_db_dests;
- select * from dba_scheduler_external_dests;
复制代码
- select * from dba_users order by 1;
- BEGIN
- DBMS_XDB.SETHTTPPORT(8888);
- END;
- @?/rdbms/admin/prvtrsch.plb
-
-
- BEGIN
- DBMS_SCHEDULER.SET_AGENT_REGISTRATION_PASS('mypassword');
- END;
-
- SELECT DBMS_XDB.GETHTTPPORT() FROM DUAL;
复制代码
以下是远程目的地端的配置:
- [oracle@station79 bin]$ pwd
- /u01/app/oracle/product/11.2.0/client_1/bin
- [oracle@station79 bin]$ ls
- acfsroot CompEMcentral.pm emctl.template genorasdksh patchAgtStPlugin.pm StartAgent.pl
- adrci CompEMcore.pm EMDeploy.pm gensyslib Path.pm symfind
- AgentLifeCycle.pm Directory.pm emdfail.command jssu RegisterTType.pm unzip
- AgentMisc.pm EMAgentPatch.pm EMDiag.pm kfed relink wrc
- AgentStatus.pm EMAgent.pm EmKeyCmds.pm kfod sAgentUtils.pm zip
- AgentSubAgent.pm EmCommonCmdDriver.pm EMomsCmds.pm LaunchEMagent.pm schagent
- bndlchk EMconnectorCmds.pm EMSAConsoleCommon.pm linkshlib SecureAgentCmds.pm
- commonenv emctl emutil nfsPatchPlugin.pm SecureOMSCmds.pm
- commonenv.template EmctlCommon.pm emutil.bat.template oerr SecureUtil.pm
- CompEMagent.pm emctl.pl emwd.pl osdbagrp sqlplus
- [oracle@station79 bin]$ ./schagent -h
- Oracle Scheduler Agent V 11.2.0.3.1 Usage
- -registerdatabase databaseHost databasePort
- Register with a database.
- -unregisterdatabase databaseHost databasePort
- Unregister from a database.
- -start
- Start the Scheduler agent
- -stop
- Stop the Scheduler agent
- [oracle@station79 bin]$ ./schagent -registerdatabase 192.168.0.76 8888
- Agent Registration Password ? ***********
- ERROR: Connecting to: http://192.168.0.76:8888/remote_scheduler_agent/register_agent. java.net.NoRouteToHostException: No route to host
- [oracle@station79 bin]$ ./schagent -registerdatabase 192.168.0.79 8888
- Agent Registration Password ? ***********
- Oracle Scheduler Agent Registration for 11.2 Agent
- Agent Registration Successful!
- [oracle@station79 bin]$ ./schagent -start
- Scheduler agent started
- [oracle@station79 bin]$
复制代码- select * from dba_scheduler_external_dests;
复制代码 | DESTINATION_NAME | HOSTNAME | PORT | IP_ADDRESS | ENABLED | COMMENTS | 1 | STATION79 | station79.example.com | 1025 | 192.168.0.79 | TRUE | Registered on 17-SEP-19 10.40.30.975846 AM PRC |
|
|