Oracle Streaming Admin

Check Streaming Status
Propagation Process Admin
Apply and Capture Process Admin
correct the data using DBMS_STREAMS.SET_TAG

Check Streaming Status

–Capture Process Status Query
SELECT CAPTURE_NAME,QUEUE_NAME,STATUS,ERROR_NUMBER,ERROR_MESSAGE FROM DBA_CAPTURE;
SELECT CAPTURE_NAME,STATE FROM V$STREAMS_CAPTURE;

–Propagation Process Status Query
SELECT PROPAGATION_NAME,STATUS,ERROR_MESSAGE,ERROR_DATE FROM DBA_PROPAGATION;

–Apply Process Status Query
SELECT APPLY_NAME,STATUS,ERROR_NUMBER,ERROR_MESSAGE FROM DBA_APPLY;

–APPLY ERROR
SELECT APPLY_NAME,QUEUE_NAME,ERROR_NUMBER,ERROR_MESSAGE,ERROR_CREATION_TIME  FROM DBA_APPLY_ERROR;

SELECT COUNT(1)  FROM DBA_APPLY_ERROR;

PROPAGATION PROCESS ADMINISTRATION

#Command for Enable(Start) the Propagation Process from SOURCE Location
BEGIN
DBMS_PROPAGATION_ADM.START_PROPAGATION(propagation_name => 'prop_src_to_dest');
END;
/

#Command for Disable(Stop) the Propagation Process from SOURCE Location
BEGIN
DBMS_PROPAGATION_ADM.STOP_PROPAGATION(propagation_name => 'prop_src_to_dest');
END;
/

BEGIN
DBMS_PROPAGATION_ADM.STOP_PROPAGATION( propagation_name => 'prop_src_to_dest',force => true);
END;

#Command for Enable(Start) the Propagation Process from DESTI Location
BEGIN
DBMS_PROPAGATION_ADM.START_PROPAGATION(propagation_name => 'prop_dest_to_src');
END;
/

#Command for Disable(Stop) the Propagation Process from DESTI Location
BEGIN
DBMS_PROPAGATION_ADM.STOP_PROPAGATION(propagation_name => 'prop_dest_to_src');
END;
/

ORACLE STREAMS APPLY & CAPTURE PROCESS ADMINISTRATION

source

#Command for start the Apply Process from SOURCE Location
exec dbms_apply_adm.start_apply (apply_name=> ‘applys_src’);

#Command for start the Capture Process from SOURCE Location
exec dbms_capture_adm.start_capture (capture_name=>’captures_src’);

#Command for stop the Apply Process from SOURCE Location
exec dbms_apply_adm.stop_apply (apply_name=> ‘applys_src’);

#Command for stop the Capture Process from SOURCE Location
exec dbms_capture_adm.stop_capture (capture_name=>’captures_src’);

destination

#Command for start the Apply Process from DESTI Location
exec dbms_apply_adm.start_apply (apply_name=> ‘applys_dest’);

#Command for start the Capture Process from DESTI Location
exec dbms_capture_adm.start_capture (capture_name=>’captures_dest’);

#Command for stop the Apply Process from DESTI Location
exec dbms_apply_adm.stop_apply (apply_name=> ‘applys_dest’);

#Command for stop the Capture Process from DESTI Location
exec dbms_capture_adm.stop_capture (capture_name=>’captures_dest’);

correct the data using DBMS_STREAMS.SET_TAG

Note: Please make sure that which data is right and which data is wrong so accordingly you have to connect the
delhi or chennai site

for example. for these specific subsciber data was wrong in chennai so we do connect with chennai

sqlplus scott/***********@orcldesti
Note: orcldesti is the alias for connect the DESTI database

SQL>exec DBMS_STREAMS.SET_TAG(‘ff’);

Note:- make sure that you have to do set tag on before make any data correction so when you do perform any
data change that data never go to replicate inside the delhi and it’s only keep change in chennai

SQL>select ID,CUSTOMERSTATUS,USER_IDENTITY, RADIUSPOLICY from tblcustomer where CUI=’918925991771′;

SQL>UPDATE tblcustomer
SET CUSTOMERSTATUS=’inactive’
where CUI=’918925991771′;

1 row updated
Note:- make sure that data is update for specific one subscriber only

SQL>select ID,CUSTOMERSTATUS,USER_IDENTITY, RADIUSPOLICY from tblcustomer where CUI=’918925991771′;
Note:- make sure that data is update correctly

SQL>exec DBMS_STREAMS.SET_TAG(null);
Note:- make sure that you have to have do set tag as null before exit the sql session

SQL>exit;

Advertisement