ogg实时同步oracle到postgresql

vi oggcore.rsp #-------------------------------------------------------------------------------# Specify the installation option.# Specify ORA19c for installing Oracle GoldenGate for Oracle Database 19c or#         ORA18c for installing Oracle GoldenGate for Oracle Database 18c or#         ORA12c for installing Oracle GoldenGate for Oracle Database 12c or#         ORA11g for installing Oracle GoldenGate for Oracle Database 11g #-------------------------------------------------------------------------------INSTALL_OPTION=ORA11g#-------------------------------------------------------------------------------# Specify a location to install Oracle GoldenGate#-------------------------------------------------------------------------------SOFTWARE_LOCATION=/ogg/goldengate#-------------------------------------------------------------------------------# Specify true to start the manager after installation. #-------------------------------------------------------------------------------START_MANAGER=false

cd /ogg/fbo_ggs_Linux_x64_shiphome/Disk1/response./runInstaller -silent -responseFile /ogg/fbo_ggs_Linux_x64_shiphome/Disk1/response/oggcore.rsp

create subdirs

--创建OGG用户并赋权create tablespace goldengate datafile '+DATA' size 500M autoextend on; create user goldengate identified by goldengate default tablespace goldengate temporary tablespace TEMP quota unlimited on goldengate;--OGG用户在源端所需权限(DML)GRANT CONNECT TO goldengate;GRANT ALTER ANY TABLE TO goldengate;      GRANT ALTER SESSION TO goldengate;GRANT CREATE SESSION TO goldengate;GRANT FLASHBACK ANY TABLE TO goldengate;GRANT SELECT ANY DICTIONARY TO goldengate;GRANT SELECT ANY TABLE TO goldengate;GRANT RESOURCE TO goldengate;

alter database force logging;ALTER DATABASE ADD SUPPLEMENTAL LOG DATA;SYS@jifen1>select NAME,OPEN_MODE,FORCE_LOGGING,SUPPLEMENTAL_LOG_DATA_MIN from v$database;NAME      OPEN_MODE            FOR SUPPLEME--------- -------------------- --- --------JIFEN     READ WRITE           YES YES

EDIT PARAMS ./GLOBALSGGSCHEMA goldengateCHECKPOINTTABLE goldengate.ggschkptdblogin userid goldengate password xxxxxxxxADD CHECKPOINTTABLE  add trandata HBTLC.TF_ACC_DETAIL_1009

PORT 7809DYNAMICPORTLIST 7800-8000AUTOSTART ER *AUTORESTART EXTRACT *,WAITMINUTES 2, RESETMINUTES 5PURGEOLDEXTRACTS /ogg/goldengate/dirdat/*,USECHECKPOINTS,MINKEEPDAYS 3LAGREPORTHOURS 1LAGINFOMINUTES 30LAGCRITICALMINUTES 45SYSLOG ERROR,WARN

start mgr

edit param extpgEXTRACT extpgSETENV (NLS_LANG=AMERICAN_AMERICA.ZHS16GBK)SETENV (ORACLE_HOME="/u01/app/oracle/product/11.2.0/db_1")SETENV (ORACLE_SID="jifen1")USERID goldengate, PASSWORD xxxxxxxxxDISCARDFILE /ogg/goldengate/dirrpt/extpg.dsc,APPEND,MEGABYTES 1024EXTTRAIL /ogg/goldengate/dirdat/aa tranlogoptions dblogreaderTABLE HBTLC.oggtest;table HBTLC.TF_ACC_DETAIL_1009

add extract extpg tranlog,begin now,threads 2;ADD EXTTRAIL /ogg/goldengate/dirdat/aa, EXTRACT extpg, megabytes 1000

start extpg

EXTRACT DPPGSETENV (NLS_LANG=AMERICAN_AMERICA.ZHS16GBK)PASSTHRURMTHOST 133.0.117.4 MGRPORT 7809RMTTRAIL /app/ogg/dirdat/dpTABLE HBTLC.oggtest;table HBTLC.TF_ACC_DETAIL_1009;

GGSCI (DBN03 as goldengate@jifen1) 80> add extract dppg,EXTTRAILSOURCE /ogg/goldengate/dirdat/aaEXTRACT added.GGSCI (DBN03 as goldengate@jifen1) 81> ADD RMTTRAIL /app/ogg/dirdat/dp, EXTRACT dppg, MEGABYTES 1000RMTTRAIL added.

start dppg

edit params defgendefsfile ./dirdef/defgen.defuserid goldengate , password xxxxxxxxxxxTABLE HBTLC.TF_ACC_DETAIL_1009;TABLE HBTLC.oggtest;

[oracle@DBN03 goldengate]$ ./defgen paramfile ./dirprm/defgen.prm***********************************************************************defsfile ./dirdef/defgen.defuserid goldengate , password ***TABLE HBTLC.TF_ACC_DETAIL_1009;Retrieving definition for HBTLC.TF_ACC_DETAIL_1009.TABLE HBTLC.oggtest;Retrieving definition for HBTLC.OGGTEST.2021-06-09 00:21:09  WARNING OGG-06439  No unique key is defined for table OGGTEST. All viable columns will be used to represent the key, but may not guarantee uniqueness. KEYCOLS may be used to define the key.Definitions generated for 2 tables in ./dirdef/defgen.def.

scp defgen.def  postgresql@133.0.117.4:/app/postgresql

export GGATE=/app/oggexport ORACLE_HOME=/app/instantclientexport ODBCINI=$GGATE/odbc.iniexport LD_LIBRARY_PATH=$ORACLE_HOME:${PGHOME}/lib:$GGATE/lib:$LD_LIBRARY_PATH

unzip 19100200714_ggs_Linux_x64_PostgreSQL_64bit.zip tar -xvf ggs_Linux_x64_PostgreSQL_64bit.tar

GGSCI (DBN08) 1> create subdirs

postgres=# create user goldengate superuser password 'xxxxxx';CREATE ROLE.

edit param mgrPORT 7809

start mgr

DBLOGIN SOURCEDB Postgres userid goldengateadd checkpointtable hbtlc.ggschkpt

edit param REMPGREPLICAT REMPGSOURCEDEFS /app/ogg/dirdef/defgen.defSETENV(PGCLIENTENCODING="UTF8" )SETENV(ODBCINI="/app/ogg/odbc.ini")SETENV(NLS_LANG="AMERICAN_AMERICA.AL32UTF8")TARGETDB Postgres,userid goldengate,password xxxxxxxxxDISCARDFILE /app/ogg/dirrpt/REMPG_aa.rpt, appendMAP HBTLC.oggtest, TARGET hbtlc.oggtest;

[ODBC Data Sources]  GG_Postgres=DataDirect 10 PostgreSQL Wire Protocol  [ODBC]  IANAAppCodePage=106InstallDir=/app/ogg[Postgres] Driver=/app/ogg/lib/GGpsql25.soDescription=DataDirect 10 PostgreSQL Wire ProtocolDatabase=jifenHostName=133.0.117.4PortNumber=5432  LogonID=goldengatePassword=xxxxxxxxx

add replicat REMPG,exttrail /app/ogg/dirdat/dp,begin now,checkpointtable hbtlc.ggschkptREPLICAT added.start REPLICAT REMPG

--Oracleinsert into oggtest values(1,'aaa');insert into oggtest values(2,'zzz');--PostgreSQLjifen=# select * from hbtlc.oggtest ;    id    | name ----------+------ 1.000000 | aaa 2.000000 | zzz(2 rows)

jifen>select current_scn from v$database;CURRENT_SCN----------------------17379359410015SYS@jifen2>create view HBTLC.OGG_1011 as select * from HBTLC.TF_ACC_DETAIL_1011 as of scn 17379359410015;View created.

edit param RMPG1011REPLICAT RMPG1011SOURCEDEFS /app/ogg/dirdef/defgen.defSETENV(PGCLIENTENCODING="UTF8" )SETENV(ODBCINI="/app/ogg/odbc.ini")SETENV(NLS_LANG="AMERICAN_AMERICA.AL32UTF8")TARGETDB Postgres,userid goldengate,password xxxxxxxxxxDISCARDFILE /app/ogg/dirrpt/REMPG_aa.rpt, appendMAP HBTLC.TF_ACC_DETAIL_1011, TARGET hbtlc.TF_ACC_DETAIL_1011;add replicat RMPG1011,exttrail /app/ogg/dirdat/dp,checkpointtable hbtlc.ggschkptstart RMPG1011, aftercsn 17379359410014

stop RMPG1018

jifen=# select log_csn from hbtlc.ggschkpt where group_name='RMPG1018';    log_csn     ---------------- 17381216337537

jifen1>col xa format 999999999999999999999
jifen1>select sum(DETAIL_SEQ_ID) xa from hbtlc.TF_ACC_DETAIL_1018 as of scn 17381216337537;

        XA
----------------------
280681007420939625

jifen=# select  sum(DETAIL_SEQ_ID) from hbtlc.TF_ACC_DETAIL_1018;
        sum         
--------------------
 280681007420939625

MAP HBTLC.TF_ACC_DETAIL_1014, TARGET hbtlc.TF_ACC_DETAIL_1014 ,keycols (detail_seq_id);

点击此处阅读原文

↓↓↓