3.create apply process
on db02
declare
BEGIN
DBMS_STREAMS_ADM.ADD_table_RULES(
table_name => 'test.t1',
streams_type => 'apply',
streams_name => 'apply_db02',
queue_name => 'streamadmin.str_dest_queue',
include_dml => true,
include_ddl => true,
include_tagged_lcr => false,
source_database => 'db01',
inclusion_rule => true);
END;
/
declare
BEGIN
DBMS_APPLY_ADM.SET_PARAMETER(
apply_name=> 'apply_stream',
parameter => 'disable_on_error',
value => 'n');
END;
/
declare
BEGIN
DBMS_APPLY_ADM.START_APPLY(
apply_name => 'apply_db02');
END;
/
|