導(dǎo)讀：
　　前幾天都是用Package來完成streams的配置，但在管理上用OEM會(huì)感覺更為直觀，當(dāng)然對(duì)所有相關(guān)的Package很了解的話，也就都差不多了。在9i的OEM中看上去對(duì)streams的功能還不是很強(qiáng)。只是簡(jiǎn)單的一些應(yīng)用。下面有時(shí)間就要搞10gR2，想跳過10gR1的。下面帖一個(gè)在OEM建立單表復(fù)制的過程腳本。
　　源數(shù)據(jù)庫: GATES
　　目標(biāo)數(shù)據(jù)庫: CLONE
1.設(shè)置操作
　　- Turn on supplemental logging and switch log file at source database.
　　- Create and set default tablespace for LogMiner at source database.
　　- 在源數(shù)據(jù)庫中捕獲以下各表, 然后傳播并將更改應(yīng)用于目標(biāo)數(shù)據(jù)庫。
　　"SCOTT"."BONUS"
2.導(dǎo)出/導(dǎo)入操作
　　- 導(dǎo)出從源數(shù)據(jù)庫選擇的所有對(duì)象。
　　- 將它們導(dǎo)入到目標(biāo)數(shù)據(jù)庫。
3.啟動(dòng)操作
　　- 首先在目標(biāo)數(shù)據(jù)庫中啟動(dòng)應(yīng)用進(jìn)程。
　　- 在源數(shù)據(jù)庫中啟動(dòng)捕獲進(jìn)程。
　　-- Setup Operations:



　　REM


　　REM The following sections setup streams at the destination database


　　REM


　　ACCEPT dest_strmadmin_passwd PROMPT '請(qǐng)輸入目標(biāo)數(shù)據(jù)庫


　　CLONE 中的用戶 STRMADMIN 的口令 : 'HIDE


　　connect STRMADMIN/&dest_strmadmin_passwd@CLONE





　　REM


　　REM Addapply rules fortables at the destination database


　　REM


　　BEGIN


　　DBMS_STREAMS_ADM.ADD_TABLE_RULES(


　　table_name =>'"SCOTT"."BONUS"',


　　streams_type =>'APPLY',


　　streams_name =>'STRMADMIN_GATES_VONGATES_',


　　queue_name =>'"STRMADMIN"."STREAMS_QUEUE"',


　　include_dml =>true,


　　include_ddl =>true,


　　source_database =>'GATES.VONGATES.COM');


　　END;


　　/





　　REM


　　REM The following sections setup streams at the source database


　　REM


　　ACCEPT source_strmadmin_passwd PROMPT '請(qǐng)輸入源數(shù)據(jù)庫


　　GATES 中的用戶 STRMADMIN 的口令 : 'HIDE


　　connect SYS/&source_dba_passwd@GATESasSYSDBA





　　REM


　　REM Turn onsupplemental logging


　　REM


　　ALTERDATABASEADDSUPPLEMENTAL LOGDATA (PRIMARYKEY,UNIQUEINDEX)


　　COLUMNS;





　　REM


　　REM Switch logfile


　　REM


　　ALTERSYSTEM SWITCH LOGFILE;





　　REM


　　REM Createlogminer tablespace


　　REM


　　CREATETABLESPACE LOGMNRTS DATAFILE 'logmnrts_GATES.dbf'


　　SIZE 25M REUSE


　　AUTOEXTEND ONMAXSIZE UNLIMITED;





　　REM


　　REM Setlogminer tablespace


　　REM


　　BEGIN


　　DBMS_LOGMNR_D.SET_TABLESPACE('LOGMNRTS');


　　END;


　　/


　　connect STRMADMIN/&source_strmadmin_passwd@GATES





　　REM


　　REM Addcapture rules fortables at the source database


　　REM


　　BEGIN


　　DBMS_STREAMS_ADM.ADD_TABLE_RULES(


　　table_name =>'"SCOTT"."BONUS"',


　　streams_type =>'CAPTURE',


　　streams_name =>'STRMADMIN_CAPTURE',


　　queue_name =>'"STRMADMIN"."STREAMS_QUEUE"',


　　include_dml =>true,


　　include_ddl =>true,


　　source_database =>'GATES.VONGATES.COM');


　　END;


　　/





　　REM


　　REM Addpropagation rules fortables at the source database


　　REM


　　BEGIN


　　DBMS_STREAMS_ADM.ADD_TABLE_PROPAGATION_RULES(


　　table_name =>'"SCOTT"."BONUS"',


　　streams_name =>'STRMADMIN_PROPAGATE',


　　source_queue_name =>'"STRMADMIN"."STREAMS_QUEUE"',


　　destination_queue_name =>'"STRMADMIN"."STREAMS_QUEUE"@CLONE.VONGATES.COM',


　　include_dml =>true,


　　include_ddl =>true,


　　source_database =>'GATES.VONGATES.COM');


　　END;


　　/


　　--Export/Import Operations:


　　expUSERID="STRMADMIN"@GATESTABLES="SCOTT"."BONUS"


　　FILE=tables.dmp GRANTS=Y ROWS=Y LOG=exportTables.log


　　OBJECT_CONSISTENT=Y INDEXES=Y





　　imp USERID="STRMADMIN"@CLONEFULL=Y CONSTRAINTS=Y FILE=tables.dmp


　　IGNORE=Y GRANTS=Y ROWS=Y COMMIT=Y LOG=importTables.log


　　STREAMS_CONFIGURATION=Y STREAMS_INSTANTIATION=Y





　　--Startup Operations:


　　ACCEPT dest_strmadmin_passwd PROMPT '請(qǐng)輸入目標(biāo)數(shù)據(jù)庫


　　CLONE 中的用戶 STRMADMIN 的口令 : 'HIDE


　　connect STRMADMIN/&dest_strmadmin_passwd@CLONE





　　REM


　　REM Start apply process at the destination database


　　REM


　　DECLARE


　　v_started number ;


　　BEGIN


　　SELECTdecode(status, 'ENABLED', 1 , 0 ) INTOv_started


　　FROMDBA_APPLY WHEREAPPLY_NAME ='STRMADMIN_GATES_VONGATES_';





　　if(v_started = 0 ) then


　　DBMS_APPLY_ADM.START_APPLY(apply_name =>'STRMADMIN_GATES_VONGATES_');


　　endif;


　　END;


　　/





　　ACCEPT source_strmadmin_passwd PROMPT '請(qǐng)輸入源數(shù)據(jù)庫


　　GATES 中的用戶 STRMADMIN 的口令 : 'HIDE


　　connect STRMADMIN/&source_strmadmin_passwd@GATES





　　DECLARE


　　v_started number ;


　　BEGIN


　　SELECTdecode(status, 'ENABLED', 1 , 0 ) INTOv_started


　　FROMDBA_CAPTURE WHERECAPTURE_NAME ='CAPTURE';


　　if(v_started = 0 ) then


　　DBMS_CAPTURE_ADM.START_CAPTURE(capture_name =>'CAPTURE');


　　endif;


　　END;


　　/





本文轉(zhuǎn)自
http://oracle.itpub.net/post/20957/146515

用Oracle Streams wizard生成配置腳本