1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47
| DECLARE
cscn NUMBER;
BEGIN
DBMS_STREAMS_ADM.SET_UP_QUEUE(queue_name=>'capture_queue',
queue_user=>'STRMADMIN');
DBMS_STREAMS_ADM.SET_UP_QUEUE(queue_name=>'apply_queue',
queue_user=>'STRMADMIN');
DBMS_APPLY_ADM.CREATE_APPLY(
queue_name => 'strmadmin.apply_queue',
apply_name => 'apply_hr_jobs',
apply_captured => FALSE);
DBMS_STREAMS_ADM.ADD_TABLE_RULES(
table_name => 'hr.jobs',
streams_type => 'apply',
streams_name => 'apply_hr_jobs',
queue_name => 'strmadmin.apply_queue',
source_database => '192.168.153.136/DB11G');
DBMS_STREAMS_ADM.ADD_TABLE_PROPAGATION_RULES(
table_name => 'hr.jobs',
streams_name => 'send_hr_jobs',
source_queue_name => 'strmadmin.capture_queue',
destination_queue_name => 'strmadmin.apply_queue@192.168.153.136/DB11G',
source_database => '192.168.153.135/DB11G',
queue_to_queue => TRUE);
DBMS_STREAMS_ADM.ADD_TABLE_RULES(
table_name => 'hr.jobs',
streams_type => 'sync_capture',
streams_name => 'sync_capture',
queue_name => 'strmadmin.capture_queue');
cscn := DBMS_FLASHBACK.GET_SYSTEM_CHANGE_NUMBER();
DBMS_APPLY_ADM.SET_TABLE_INSTANTIATION_SCN@"192.168.153.136/DB11G"(
source_object_name => 'hr.jobs',
source_database_name => '192.168.153.135/DB11G',
instantiation_scn => cscn);
DBMS_APPLY_ADM.START_APPLY(
apply_name => 'apply_hr_jobs');
END;
/ |
Partager