GoldenGate添加进程及初始化
1、源端添加表級附加日志
GGSCI (primary) 5> dblogin userid ggs password XXXXXX
Successfully logged into database.
GGSCI (primary) 6> add trandata test.*
(將該用戶下所有表添加表級附加日志)
GGSCI> add trandata test.*
源端添加capture進程
add extract EXTL66, tranlog, begin now, threads 1
add EXTTRAIL ./dirdat/r1, extract EXTL66,MEGABYTES 100
(單實例不需要制定thread參數,用于RAC)
設置capture參數
GGSCI (primary) 11>edit params EXTL66
extract EXTL66
setenv (ORACLE_SID=“DAXIAO”)
setenv ( NLS_LANG = AMERICAN_AMERICA.ZHS16GBK )
userid ggs, password XXXXXX
REPORT AT 01:59
–ddloptions nocrossrename,report
–DDL include objname "IPS2." exclude objname “IPS2.TIPS_DIS_TRANS_TMP”
–DDL include objname ERATING_QTDS. exclude objname ERATING_QTDS.DBMS_TABCOMP_TEM*
–DDLOPTIONS REMOVECOMMENTS BEFORE
reportrollover at 02:00
–TRANLOGOPTIONS CONVERTUCS2CLOBS
–THREADOPTIONS MAXCOMMITPROPAGATIONDELAY 3000 IOLATENCY 3000
discardfile ./dirrpt/extl66.dsc,append,megabytes 100
–gettruncates
–warnlongtrans 10m, checkintervals 3m
exttrail ./dirdat/r1
numfiles 3000
dynamicresolution
table ERATING_XYJ.LOG_DAILY_LOGID;
table ERATING_XYJ.LOG_RECORD_DETAIL;
table ERATING_XYJ.LOG_ROLE_FIRST_LOGIN;
table ERATING_XYJ.LOG_SERIAL_USE;
table ERATING_XYJ.LOG_USER_FIRST_LOGIN_INFO;
table ERATING_XYJ.LOG_USER_FUND_DETAIL;
table ERATING_XYJ.LOG_USER_PURCHASE_DETAIL;
table ERATING_XYJ.SYS_ACTIVITY_GAMES;
table ERATING_XYJ.SYS_ACTIVITY_INFO;
table ERATING_XYJ.SYS_SERIAL_NO;
table ERATING_XYJ.UMS_ROLE;
table ERATING_XYJ.UMS_USER;
table ERATING_XYJ.UMS_USER_FUND_SUMMARY;
table ERATING_XYJ.UMS_USER_PURCHASE_DETAIL;
啟動進程
GGSCI>start EXTL66
驗證源端capture進程
GGSCI (primary) 35> info all
Program Status Group Lag at Chkpt Time Since Chkpt
MANAGER RUNNING
EXTRACT RUNNING EXTL66 00:00:00 00:00:09
2、源端創建datapump
add extract dpelc66,exttrailsource ./dirdat/r1 (指定源端數據文件)
add rmttrail ./dirdat/tq,EXTRACT dpelc66,MEGABYTES 100 (指定目標端生成文件位置,名字,大小)
edit params dpelc66
extract DPELC66
setenv (ORACLE_SID=“DAXIAO”)
setenv ( NLS_LANG = AMERICAN_AMERICA.ZHS16GBK )
passthru
REPORT AT 01:59
reportrollover at 02:00
rmthost XXXXXX , mgrport 7806, compress
rmttrail ./dirdat/tq
dynamicresolution
numfiles 3000
–table
table ERATING_XYJ.LOG_DAILY_LOGID;
table ERATING_XYJ.LOG_RECORD_DETAIL;
table ERATING_XYJ.LOG_ROLE_FIRST_LOGIN;
table ERATING_XYJ.LOG_SERIAL_USE;
table ERATING_XYJ.LOG_USER_FIRST_LOGIN_INFO;
table ERATING_XYJ.LOG_USER_FUND_DETAIL;
table ERATING_XYJ.LOG_USER_PURCHASE_DETAIL;
table ERATING_XYJ.SYS_ACTIVITY_GAMES;
table ERATING_XYJ.SYS_ACTIVITY_INFO;
table ERATING_XYJ.SYS_SERIAL_NO;
table ERATING_XYJ.UMS_ROLE;
table ERATING_XYJ.UMS_USER;
table ERATING_XYJ.UMS_USER_FUND_SUMMARY;
table ERATING_XYJ.UMS_USER_PURCHASE_DETAIL;
注:rmttrail參數要和 add rmttrail參數一致;
TABLE參數要和 Capture進程的 TABLE參數一致;
啟動 DataPump進程:
GGSCI>start dpelc66
在源端執行DML操作,并且提交
查看源端./goldengate/dirdat/r1 文件大小
查看目標端./goldengate/dirdat/t1 文件大小變化
13源端數據庫獲取SCN
如果采用exp/imp方式,先獲取SCN在執行exp/imp,如果是rman備份,就備份完成后在獲取數據庫的SCN
SQL> select to_char(CURRENT_SCN) from v$database;
TO_CHAR(CURRENT_SCN)
244292
select to_char(dbms_flashback.get_system_change_number()) from dual;
單表或多表一般用expdp 確認undo足夠大, 如果全庫數據庫量大的話建議用rman
expdp “/ as sysdba” directory=EXPDIR dumpfile=rrr.dmp FLASHBACK_SCN=244292
3、創建目標端replicate進程
GGSCI (standby) 3> dblogin userid ggs,password XXXXX
GGSCI (standby) 4> add checkpointtable ggs.rep_app_ckpt
GGSCI (standby) 6> add replicat replc66,exttrail ./dirdat/tq,checkpointtable ggs.rep_app_ckpt
注:
Exttrail參數要和源端 DataPump進程的 rmttrail 參數指向一致;
Checkpointtable 參數引用的表必須已用 add checkpointtable命令創建
GGSCI (standby) 7> edit param REPLC66
replicat REPLC66
setenv ( ORACLE_SID=“BISTD3” )
setenv ( NLS_LANG = AMERICAN_AMERICA.ZHS16GBK )
userid ggs ,password XXXXX
sqlexec “Alter session set constraints=deferred”
REPORT AT 01:59
reportrollover at 02:00
–ddl include mapped exclude objname TRIAL_TTLD.DBMS_TABCOMP_TEMP_UNCMP
DDLERROR 24344 ignore
DDLERROR 1917 ignore
DDLERROR 1471 ignore
DDLERROR DEFAULT abend
DDLSUBST ‘enable’ WITH ‘disable’ INCLUDE OBJTYPE ‘trigger’, OPTYPE alter
DDLSUBST ‘enable’ WITH ‘disable’ INCLUDE INSTR ‘ZGLT_CASCADE’, OPTYPE alter, OBJTYPE ‘CONSTRAINT’
reperror default,abend
–HANDLECOLLISIONS
discardfile /u02/ogg10g/ggs/dirrpt/REPLC66.dsc,append, megabytes 10
assumetargetdefs
checksequencevalue
allownoopupdates
dynamicresolution
numfiles 3000
map ERATING_XYJ.LOG_DAILY_LOGID, target ESTAGING.LOG_DAILY_LOGID_E071;
map ERATING_XYJ.LOG_RECORD_DETAIL, target ESTAGING.LOG_RECORD_DETAIL_E071;
map ERATING_XYJ.LOG_ROLE_FIRST_LOGIN, target ESTAGING.LOG_ROLE_FIRST_LOGIN_E071;
map ERATING_XYJ.LOG_SERIAL_USE, target ESTAGING.LOG_SERIAL_USE_E071;
map ERATING_XYJ.LOG_USER_FIRST_LOGIN_INFO, target ESTAGING.LOG_USER_FIRST_LOGIN_INFO_E071;
map ERATING_XYJ.LOG_USER_FUND_DETAIL, target ESTAGING.LOG_USER_FUND_DETAIL_E071;
map ERATING_XYJ.LOG_USER_PURCHASE_DETAIL, target ESTAGING.LOG_USER_PURCHASE_DETAIL_E071;
map ERATING_XYJ.SYS_ACTIVITY_GAMES, target ESTAGING.SYS_ACTIVITY_GAMES_E071;
map ERATING_XYJ.SYS_ACTIVITY_INFO, target ESTAGING.SYS_ACTIVITY_INFO_E071;
map ERATING_XYJ.SYS_SERIAL_NO, target ESTAGING.SYS_SERIAL_NO_E071;
map ERATING_XYJ.UMS_ROLE, target ESTAGING.UMS_ROLE_E071;
map ERATING_XYJ.UMS_USER, target ESTAGING.UMS_USER_E071;
map ERATING_XYJ.UMS_USER_FUND_SUMMARY, target ESTAGING.UMS_USER_FUND_SUMMARY_E071;
map ERATING_XYJ.UMS_USER_PURCHASE_DETAIL, target ESTAGING.UMS_USER_PURCHASE_DETAIL_E071;
table ERATING_XYJ.LOG_DAILY_LOGID_E071;
table ERATING_XYJ.LOG_RECORD_DETAIL_E071;
table ERATING_XYJ.LOG_ROLE_FIRST_LOGIN_E071;
table ERATING_XYJ.LOG_SERIAL_USE_E071;
table ERATING_XYJ.LOG_USER_FIRST_LOGIN_INFO_E071;
table ERATING_XYJ.LOG_USER_FUND_DETAIL_E071;
table ERATING_XYJ.LOG_USER_PURCHASE_DETAIL_E071;
table ERATING_XYJ.SYS_ACTIVITY_GAMES_E071;
table ERATING_XYJ.SYS_ACTIVITY_INFO_E071;
table ERATING_XYJ.SYS_SERIAL_NO_E071;
table ERATING_XYJ.UMS_ROLE_E071;
table ERATING_XYJ.UMS_USER_E071;
table ERATING_XYJ.UMS_USER_FUND_SUMMARY_E071;
table ERATING_XYJ.UMS_USER_PURCHASE_DETAIL_E071;
目標端啟動replicat進程
啟動replicat進程需要確保源端和目標端數據庫已經初始化完成
第一次啟動需要指定aftercsn scn_number參數
SCN_NUMBER為數據庫通過RMAN備份后查詢獲得的SCN,exp/imp操作之前的SCN
GGSCI (standby) 10> start replicat rep_app, aftercsn 244920
總結
以上是生活随笔為你收集整理的GoldenGate添加进程及初始化的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 计算机科学summer program,
- 下一篇: 单片机的电子电路基本知识