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

注：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