GoldenGate配置(二)之双向复制配置「建议收藏」

GoldenGate配置(二)之双向复制配置

大家好,又见面了,我是全栈君。

 GoldenGate配置(二)之双向复制配置


环境:

Item

Source System

Target System

Platform

Red Hat Enterprise

Linux Server release 5.4

Red Hat Enterprise

Linux Server release 5.4

Hostname

gc1

gc2

Database

Oracle 10.2.0.1

Oracle 11.2.0.1

Character Set

ZHS16GBK

ZHS16GBK

ORACLE_SID

PROD

EMREP

Listener Name/Port

LISTENER/1521

LISTENER/1521

Goldengate User

ogg

ogg

双向复制配置

说明:
此篇续接第一篇“GoldenGate配置(一)之单向复制配置”之后继续进行配置
关于上一篇,GoldenGate配置(一)之单向复制配置:点击打开链接


双向复制配置操作:

gc2:授权

SQL>grant CONNECT, RESOURCE to ogg;

SQL>grant CREATE SESSION, ALTER SESSION to ogg;

SQL>grant SELECT ANY DICTIONARY, SELECT ANY TABLE to ogg;

SQL>grant ALTER ANY TABLE to ogg;

SQL>grant FLASHBACK ANY TABLE to ogg;

SQL>grant EXECUTE on DBMS_FLASHBACK to ogg;

 

gc1:授权

SQL>grant CONNECT, RESOURCE to ogg;

SQL>grant CREATE SESSION, ALTER SESSION to ogg;

SQL>grant SELECT ANY DICTIONARY, SELECT ANY TABLE to ogg;

SQL>grant CREATE TABLE to ogg;

SQL>grant INSERT, UPDATE, DELETE on scott.tcustmer to ogg;–把须要同步表的DML操作授权给ogg

SQL>grant INSERT, UPDATE, DELETE on scott.tcustord to ogg;–把须要同步表的DML操作授权给ogg

 

gc2:开启补充日志

SQL>alter database add supplemental log data;

SQL>alter system switch logfile;

SQL>alter database force logging;

 

gc2:測试表加入到补充日志

GGSCI(gc2) 1> DBLOGIN USERID ogg, PASSWORD Ogg    

Successfully logged into database.

GGSCI(gc2) 2> ADD TRANDATA scott.TCUSTMER

Logging of supplemental redo data enabled fortable SCOTT.TCUSTMER.

GGSCI(gc2) 3> ADD TRANDATA scott.TCUSTORD

Logging of supplemental redo data enabled fortable SCOTT.TCUSTORD.

 

gc2:配置Extract进程

GGSCI(gc2) 4> EDIT PARAMS EORA_1

— Change Capture parameter file to capture

— TCUSTMER and TCUSTORD changes

EXTRACT EORA_1

SETENV (NLS_LANG=AMERICAN_AMERICA.ZHS16GBK)

USERID ogg, PASSWORD Ogg

TRANLOGOPTIONS EXCLUDEUSER ogg

EXTTRAIL ./dirdat/aa

TABLE scott.TCUSTMER;

TABLE scott.TCUSTORD;

~

~

“dirprm/eora_1.prm” [New] 9L, 257Cwritten

GGSCI(gc2) 5> ADD EXTRACT EORA_1, TRANLOG, BEGIN NOW

EXTRACT added.

GGSCI(gc2) 6> ADD EXTTRAIL ./dirdat/aa, EXTRACT EORA_1, MEGABYTES 5

EXTTRAIL added.

GGSCI(gc2) 7> START EXTRACT EORA_1

Sending START request to MANAGER …

EXTRACT EORA_1 starting

GGSCI(gc2) 8> INFO EXTRACT EORA_1

EXTRACT   EORA_1    Last Started 2014-06-1811:28   Status RUNNING

Checkpoint Lag       00:00:19 (updated 00:00:08 ago)

Log Read Checkpoint  Oracle Redo Logs

                     2014-06-18 11:27:42  Seqno 6, RBA 35344

 

gc2:配置Pump进程

GGSCI(gc2) 9> EDIT PARAMS PORA_1

加入下面内容:

— Data Pump parameter file to read thelocal

— trail of TCUSTMER and TCUSTORDchanges

EXTRACT PORA_1

SETENV(NLS_LANG=AMERICAN_AMERICA.ZHS16GBK)

PASSTHRU

RMTHOST gc1, MGRPORT 7809

RMTTRAIL ./dirdat/pa

TABLE scott.TCUSTMER;

TABLE scott.TCUSTORD;

~

~

~

“dirprm/pora_1.prm” [New] 10L, 250Cwritten

GGSCI(gc2) 10> ADD EXTRACT PORA_1, EXTTRAILSOURCE ./dirdat/aa

EXTRACT added.

GGSCI(gc2) 11> ADD RMTTRAIL ./dirdat/pa, EXTRACT PORA_1, MEGABYTES 5

RMTTRAIL added.

GGSCI(gc2) 12> START EXTRACT PORA_1

Sending START request to MANAGER …

EXTRACT PORA_1 starting

 

gc1:配置Replicat进程

GGSCI(gc1) 1> EDIT PARAMS ./GLOBALS

CHECKPOINTTABLE ogg.ggschkpt

~

~

“./GLOBALS” [New] 1L, 29C written

GGSCI(gc1) 2> quit     

[oracle@gc1ogg]$ ll GLOBALS   —验证

-rw-rw-rw- 1 oracle oinstall 29 Jun 18 11:33GLOBALS

GGSCI(gc1) 1> DBLOGIN USERID ogg, PASSWORD Ogg

Successfully logged into database.

GGSCI(gc1) 2> ADD CHECKPOINTTABLE

No checkpoint table specified, using GLOBALSspecification (ogg.ggschkpt)…

Successfully created checkpoint tableOGG.GGSCHKPT.

 

gc1:配置Replicate进程

GGSCI(gc1) 3> EDIT PARAM RORA_1

— Change Delivery parameter file to apply

— TCUSTMER and TCUSTORD Changes

REPLICAT RORA_1

SETENV (NLS_LANG=AMERICAN_AMERICA.ZHS16GBK)

USERID ogg, PASSWORD Ogg

HANDLECOLLISIONS

ASSUMETARGETDEFS

DISCARDFILE ./dirrpt/RORA_aa.DSC, PURGE

MAP scott.tcustmer, TARGET scott.tcustmer;

MAP scott.tcustord, TARGET scott.tcustord;

~

~

“dirprm/rora_1.prm” [New] 12L, 327Cwritten

GGSCI(gc1) 4> ADD REPLICAT RORA_1, EXTTRAIL ./dirdat/pa

REPLICAT added.

GGSCI(gc1) 5> START REPLICAT RORA_1

Sending START request to MANAGER …

REPLICAT RORA_1 starting

 

gc1:查看进程状态

GGSCI(gc1) 6> info all

Program    Status      Group       Lag           Time Since Chkpt

MANAGER    RUNNING                                          

EXTRACT    RUNNING     EORA_1      00:00:00      00:00:08   

EXTRACT    RUNNING     PORA_1      00:00:00      00:00:01   

REPLICAT   RUNNING     RORA_1      00:00:00      00:00:06  

 

gc2:查看进程状态

GGSCI(gc2) 13> info all

Program    Status      Group       Lag           Time Since Chkpt

MANAGER    RUNNING                                           

EXTRACT    RUNNING     EORA_1      00:00:00      00:00:09   

EXTRACT    RUNNING     PORA_1      00:00:00      00:00:06   

REPLICAT   RUNNING     RORA_1      00:00:00      00:00:01  

 

验证insert操作双向同步

gc1: gc1→gc2。DML操作:insert操作

SQL>insert into tcustmer VALUES(‘HYL’,’HUANG DBA.’,’HARBIN’,’CN’);

1 row created.

SQL>commit;

Commit complete.

 

gc2:验证insert操作同步

SQL>select * from tcustmer;

CUST NAME                           CITY                 ST

—- ————————————————– —

HYL  HUANGDBA.                     HARBIN               CN

WILL BG SOFTWARE CO.                SEATTLE              WA

JANE ROCKY FLYER INC.               DENVER               CO

 

gc2:gc2→gc1,DML操作:insert操作

SQL>insert into tcustmer VALUES(‘WT’,’WANGDBA.’,’QINGDAO’,’CN’);

1 row created.

SQL>commit;

Commit complete.

 

gc1:gc1→gc2。DML操作:update操作

SQL>select * from tcustmer;

CUST NAME                           CITY                 ST

—- ————————————————– —

HYL  HUANGDBA.                     HARBIN               CN

WILL BG SOFTWARE CO.                SEATTLE              WA

JANE ROCKY FLYER INC.               DENVER               CO

WT   WANGDBA.                      QINGDAO              CN

gc1:update操作

SQL>update tcustmer set city = ‘BEIJING’, state = ‘CN’ wherecust_code=’HYL’;

1 row updated.

SQL>commit;

Commit complete.

 

gc2:验证update操作同步

SQL>select * from tcustmer;

CUST NAME                           CITY                 ST

—- —————————— ———————-

HYL  HUANGDBA.                     BEIJING              CN

WILL BG SOFTWARE CO.                SEATTLE              WA

JANE ROCKY FLYER INC.               DENVER               CO

WT   WANGDBA.                      QINGDAO              CN

 

gc2:gc2→gc1,DML操作:update操作

SQL>update tcustmer set city = ‘BEIJING’, state = ‘CN’ wherecust_code=’WT’;

1 row updated.

SQL>commit;

Commit complete.

 

gc1:验证update操作同步

SQL>select * from tcustmer;

CUST NAME                           CITY                 ST

—- ————————————————– —

HYL  HUANGDBA.                     BEIJING              CN

WILL BG SOFTWARE CO.                SEATTLE              WA

JANE ROCKY FLYER INC.               DENVER               CO

WT   WANGDBA.                      BEIJING              CN

 

gc1:gc1→gc2,DML操作:delete操作

SQL>delete from tcustmer where CUST_CODE=’WT’;

1 row deleted.

SQL>commit;

Commit complete.

 

gc2:验证delete操作同步

SQL>select * from tcustmer;

CUST NAME                           CITY                 ST

—- ————————————————– —

HYL  HUANGDBA.                     BEIJING              CN

WILL BG SOFTWARE CO.                SEATTLE              WA

JANE ROCKY FLYER INC.               DENVER               CO

 

gc2:gc2→gc1。DML操作:delete操作

SQL>delete from tcustmer where CUST_CODE=’HYL’;

1 row deleted.

SQL>commit;

Commit complete.

 

gc1:验证delete操作同步

SQL>select * from TCUSTMER;

CUST NAME                           CITY                 ST

—- ————————————————– —

WILL BG SOFTWARE CO.                SEATTLE              WA

JANE ROCKY FLYER INC.               DENVER               CO

 

–至此,GoldenGate双向同步复制完毕

声明:
         原创作品,出自 “深蓝的blog” 博客,同意转载。转载时请务必注明出处(http://blog.csdn.net/huangyanlong)。

         关于涉及版权事宜,作者有权追究法律责任。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/116145.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • mysql 字符串类型 分区_MySQL分区类型

    mysql 字符串类型 分区_MySQL分区类型博文大纲:1、RANGE分区2、LIST分区3、HASH分区4、key分区5、MySQL分表和分区的区别6、附加:如何实现将分区放在不同的目录下进行存储MySQL分区类型如下:RANFGE分区LIST分区HASH分区key分区上面的四种分区的条件必须是整形,如果不是整形需要通过函数将其转换为整形。1、RANGE分区RANGE分区是基于属于一个给定连续区间的列值,把多行分配给分区。这些区间要连续且不…

    2022年6月8日
    28
  • 净推荐值NPS(Net Promoter Score)[通俗易懂]

    净推荐值NPS(Net Promoter Score)[通俗易懂]净推荐值净推荐值(NetPromoterScore,NPS)目录[隐藏]1什么是净推荐值2净推荐值的理论基础[3]3净推荐值的计算4净推荐值的意义5净推荐值的评析6净推荐值在企业中的应用分析[3]7企业通过净推荐值提高客户忠诚度的主要步骤[5]8净推荐值提高客户忠诚度的实证分析[5]9净推荐值应用实例10参考文献[编辑]什么是净推荐值  净推荐值(N…

    2022年6月12日
    32
  • Eureka集群原理

    Eureka集群原理问题:微服务RPC远程服务调用最核心的是什么?高可用,试想你的注册中心只有一个onlyone,它出故障了那就呵呵o( ̄︶ ̄)o了,会导致整个微服务环境不可用。解决办法:搭建Eureka注册中心集群,实现负载均衡+故障容错Eureka集群的原理:互相注册,相互守望。一个Eureka集群包含7001和7002等许多服务,在这个集群中,7001指向其他所有服务…

    2022年5月28日
    38
  • 常见学习率衰减方式

    常见学习率衰减方式学习率学习率的作用​ 在机器学习中,监督式学习通过定义一个模型,并根据训练集上的数据估计最优参数。梯度下降法是一个广泛被用来最小化模型误差的参数优化算法。梯度下降法通过多次迭代,并在每一步中最小化成本函数(cost来估计模型的参数。学习率(learningrate),在迭代过程中会控制模型的学习进度。​ 在梯度下降法中,都是给定的统一的学习率,整个优化过程中都以确定的步长进行更新,在…

    2022年6月7日
    41
  • javaweb实现即时消息推送功能

    javaweb实现即时消息推送功能在浏览某些网页的时候,例如 WebQQ、京东在线客服服务、CSDN私信消息等类似的情况下,我们可以在网页上进行在线聊天,或者即时消息的收取与回复,可见,这种功能的需求由来已久,并且应用广泛。网上关于这方面的文章也能搜到一大堆,不过基本上都是理论,真正能够运行的代码很少,原理性的东西我就不当搬运工了,本文主要是贴示例代码,最多在代码中穿插一点便于理解,本文主要的示例代码基于 javascri

    2022年5月5日
    615
  • mySQL函数根据经纬度计算两点距离

    mySQL函数根据经纬度计算两点距离

    2022年2月23日
    42

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号