Objective: Capturing scott.emp@database1.world changes to test.emp@database2. Already replication is working fine when schema name is same. Details ******** Source db name & user name: database1 , scott Destination db name & user name : database2,test In both db, strmadmin is the streams administrator user. Source Database (database1) ***************************** -- CREATES THE CAPTURE QUEUE TO STORE THE tables to be streamed spool capturequeue.log; connect strmadmin/strmadmin BEGIN DBMS_STREAMS_ADM.SET_UP_QUEUE ( queue_table => 'QAO_TEST_CAPTURE_TAB', queue_name => 'QAO_TEST_CAPTURE_QUEUE', queue_user => 'STRMADMIN' ); END; / --Adding Rules in Source BEGIN DBMS_STREAMS_ADM.ADD_TABLE_RULES( table_name => 'SCOTT.&1', streams_type => 'CAPTURE', streams_name => 'QAO_TEST_CAPTURE', queue_name => 'STRMADMIN.QAO_TEST_CAPTURE_QUEUE', include_dml => true, include_ddl => true, source_database => 'database1.world'); END; / ---Propogation rules BEGIN DBMS_STREAMS_ADM.ADD_TABLE_PROPAGATION_RULES( table_name => 'SCOTT.&1', streams_name => 'QAO_SCOTT_TEST_PROPAGATE', source_queue_name => 'STRMADMIN.QAO_TEST_CAPTURE_QUEUE', destination_queue_name =>'STRMADMIN.QAO_TEST_APPLY_QUEUE@database2.world', include_dml => true, include_ddl => FALSE, source_database => 'database1.world'); END; / --Getting SCN number DECLARE source_scn NUMBER; BEGIN source_scn := DBMS_FLASHBACK.GET_SYSTEM_CHANGE_NUMBER(); DBMS_APPLY_ADM.SET_TABLE_INSTANTIATION_SCN@database2.world( source_object_name => 'SCOTT.EMP', source_database_name => 'database1.world', instantiation_scn => source_scn ); END; / -- Starting Capturing in Source DB BEGIN DBMS_CAPTURE_ADM.START_CAPTURE( capture_name => 'QAO_TEST_CAPTURE'); END; / Destination database (database2) ******************************** -- Creating Apply queue BEGIN dbms_streams_adm.set_up_queue( queue_table => 'QAO_TEST_APPLY_TAB', queue_name => 'QAO_TEST_APPLY_QUEUE', queue_user => 'STRMADMIN'); END; / BEGIN DBMS_STREAMS_ADM.ADD_TABLE_RULES( table_name => 'TEST.&1', streams_type => 'APPLY', streams_name => 'QAO_TEST_APPLY', queue_name => 'STRMADMIN.QAO_SCOTT_APPLY_QUEUE', include_dml => true, include_ddl => false, source_database => 'database1.world'); END; / BEGIN DBMS_STREAMS_ADM.RENAME_SCHEMA( rule_name => 'STRMADMIN.EMP1093', from_schema_name => 'SCOTT', to_schema_name => 'TEST', step_number => 0, operation => 'add'); END; / EGIN DBMS_APPLY_ADM.ALTER_APPLY( apply_name => 'QAO_TEST_APPLY', apply_user => 'TEST' ); END; / BEGIN dbms_apply_adm.set_parameter( apply_name => 'QAO_TEST_APPLY', parameter => 'DISABLE_ON_ERROR', value => 'N'); END; / BEGIN DBMS_APPLY_ADM.START_APPLY( apply_name => 'QAO_TEST_APPLY' ); END; / *************