ogg 进程开启前的数据怎么同步(ogg捕获dml)

技术OGG双向DML复制怎么实现本篇内容主要讲解“OGG双向DML复制怎么实现”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“OGG双向DML复制怎么实现”吧!环境解释:hos

本篇内容主要讲解“OGG双向现代语言博士现代语言博士复制怎么实现”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“OGG双向现代语言博士现代语言博士复制怎么实现”吧!

环境解释:hostname:slient,db_name:test作为源库,而hostname:one,db_name:onemo作为目标库,本次只需要配置一次反向的操作即可:即one为源端, slient为目标端.配置步骤:1、源端:检查数据库是否在归档模式,建议在归档模式:SQL archive log list;Database log mode Archive ModeAutomatic archival EnabledArchive destination USE_DB_RECOVERY_FILE_DESThttp://

ng>
 ENAME                                              VARCHAR2(10)
 JOB                                                VARCHAR2(9)
 SAL                                                NUMBER
 COMM                                               NUMBER

SQL> conn / as sysdba
Connected.
SQL>

–查看表BONUS的force_logging 属性
语法: alter table schema.table_name logging;  

SQL> select OWNER,TABLE_NAME,STATUS,LOGGING from dba_tables where owner='SCOTT' and table_name='BONUS';

OWNER                          TABLE_NAME                     STATUS   LOG
—————————— —————————— ——– —
SCOTT                          BONUS                          VALID    YES

4.源端:以goldengate这个schema登陆数据库GGSCI (one) 1> dblogin userid ogg,password ogg;
Successfully logged into database.

GGSCI (one as ogg@onemo) 2>
GGSCI (one as ogg@onemo) 7> add trandata scott.BONUS

2017-10-27 04:57:07  WARNING OGG-06439  No unique key is defined for table BONUS. All viable columns will be used to represent the key, but may not guarantee uniqueness. KEYCOLS may be used to define the key.

Logging of supplemental redo data enabled for table SCOTT.BONUS.
TRANDATA for scheduling columns has been added on table 'SCOTT.BONUS'.
TRANDATA for instantiation CSN has been added on table 'SCOTT.BONUS'.
GGSCI (one as ogg@onemo) 8>

5.源端配置抓取进程
GGSCI (one as ogg@onemo) 9> add extract ext_rev, tranlog, begin now,threads 1  
EXTRACT added.

GGSCI (one as ogg@onemo) 10> info all

Program     Status      Group       Lag at Chkpt  Time Since Chkpt

MANAGER     RUNNING                                           
EXTRACT     STOPPED     EXT_REV     00:00:00      00:00:05    
REPLICAT    RUNNING     REP_DEMO    00:00:00      00:00:06    

6.源端:添加队列文件
GGSCI (one as ogg@onemo) 12> add EXTTRAIL /u01/app/oracle/ogg/dirdat/rv, extract ext_rev,megabytes 100  
EXTTRAIL added.

GGSCI (one as ogg@onemo) 13>

7.源端编辑的抓取进程的参数extract;
GGSCI (one as ogg@onemo) 30> edit param ext_rev

EXTRACT ext_rev
setenv (ORACLE_SID=onemo)  
setenv (NLS_LANG=AMERICAN_AMERICA.ZHS16GBK)  
userid ogg,password ogg  
exttrail /u01/app/oracle/ogg/dirdat/rv  
dynamicresolution  
TABLE scott.bonus;  

GGSCI (one as ogg@onemo) 31>

8.源库启动extact抓取进程:
GGSCI (one as ogg@onemo) 28> start ext_rev

Sending START request to MANAGER …
EXTRACT EXT_REV starting

GGSCI (one as ogg@onemo) 29> info all

Program     Status      Group       Lag at Chkpt  Time Since Chkpt

MANAGER     RUNNING                                           
EXTRACT     RUNNING     EXT_REV     00:08:37      00:00:03    
REPLICAT    RUNNING     REP_DEMO    00:00:00      00:00:01    

GGSCI (one as ogg@onemo) 30>

9.源库配置datapump进程,将抓取数据传到目标主机。负责TCPIP通讯
GGSCI (one as ogg@onemo) 32> add extract dpe_rev, exttrailsource /u01/app/oracle/ogg/dirdat/rv
EXTRACT added.

–输出:目标主机怎么写,也是定义datapumo进程的输出。
GGSCI (one as ogg@onemo) 34> add rmttrail /opt/ogg/ogg_home/dirdat/tv,EXTRACT dpe_rev,MEGABYTES 100
RMTTRAIL added.

GGSCI (one as ogg@onemo) 35>

10.源端配置datapump进程参数
GGSCI (one as ogg@onemo) 39> edit param DPE_REV
extract dpe_rev
setenv (ORACLE_SID=onemore)
setenv ( NLS_LANG = AMERICAN_AMERICA.ZHS16GBK )
passthru
–REPORT AT 01:59
–reportrollover at 02:00
rmthost  192.168.56.20,mgrport 7809, compress
rmttrail /opt/ogg/ogg_home/dirdat/tv
Dynamicresolution
table scott.bonus;
~
"dirprm/dpe_rev.prm" [New] 10L, 265C written

GGSCI (one as ogg@onemo) 40>

GGSCI (one as ogg@onemo) 40> info all

Program     Status      Group       Lag at Chkpt  Time Since Chkpt

MANAGER     RUNNING                                           
EXTRACT     STOPPED     DPE_REV     00:00:00      00:05:17    
EXTRACT     RUNNING     EXT_REV     00:00:00      00:00:02    
REPLICAT    RUNNING     REP_DEMO    00:00:00      00:00:07    

–启动DPE_REV
GGSCI (one as ogg@onemo) 41> start DPE_REV

Sending START request to MANAGER …
EXTRACT DPE_REV starting

GGSCI (one as ogg@onemo) 42> info all

Program     Status      Group       Lag at Chkpt  Time Since Chkpt

MANAGER     RUNNING                                           
EXTRACT     RUNNING     DPE_REV     00:00:00      00:05:34    
EXTRACT     RUNNING     EXT_REV     00:00:00      00:00:07    
REPLICAT    RUNNING     REP_DEMO    00:00:00      00:00:04    

GGSCI (one as ogg@onemo) 43>

11.目标端为replicat进程创建checkpoint表
[ogg@slient ogg_home]$ pwd
/opt/ogg/ogg_home
[ogg@slient ogg_home]$ ggsci

Oracle GoldenGate Command Interpreter for Oracle
Version 12.2.0.1.1 OGGCORE_12.2.0.1.0_PLATFORMS_151211.1401_FBO
Linux, x64, 64bit (optimized), Oracle 11g on Dec 12 2015 00:54:38
Operating system character set identified as UTF-8.

Copyright (C) 1995, 2015, Oracle and/or its affiliates. All rights reserved.

GGSCI (slient) 1> dblogin userid ogg,password ogg
Successfully logged into database.

GGSCI (slient as ogg@test) 2> add checkpointtable ogg.rep_bouns_ckpt

Successfully created checkpoint table ogg.rep_bouns_ckpt.

GGSCI (slient as ogg@test) 3>

12.目标端配置目标端replicate进程
GGSCI (slient as ogg@test) 4> add replicat rep_rev,exttrail /opt/ogg/ogg_home/dirdat/tv,checkpointtable ogg.rep_bouns_ckpt
REPLICAT added.

GGSCI (slient as ogg@test) 5>

13.编辑目标端replicate参数
GGSCI (slient as ogg@test) 5>   edit param rep_rev
replicat rep_rev
setenv (oracle_sid=test)
setenv (nls_lang ="american_america.zhs16gbk")
userid ogg,password ogg
–report at 01:59
–reportrollover at 02:00
reperror default,abend
discardfile /opt/ogg/ogg_home/dirrpt/repb.dsc,append, megabytes 10
assumetargetdefs
–allownoopupdates
dynamicresolution
–insertallrecords
map scott.bonus,target scott.bonus;
~
~
"dirprm/rep_rev.prm" [New] 13L, 356C written

GGSCI (slient as ogg@test) 6>

GGSCI (slient as ogg@test) 6> info all

Program     Status      Group       Lag at Chkpt  Time Since Chkpt

MANAGER     RUNNING                                           
EXTRACT     RUNNING     DPEA        00:00:00      00:00:07    
EXTRACT     RUNNING     EXTA        00:00:00      00:00:10    
REPLICAT    STOPPED     REP_REV     00:00:00      00:02:57    

14.目标端启动并查看replicate进程是否运行
GGSCI (slient as ogg@test) 7> start REP_REV

Sending START request to MANAGER …
REPLICAT REP_REV starting

GGSCI (slient as ogg@test) 8> info all

Program     Status      Group       Lag at Chkpt  Time Since Chkpt

MANAGER     RUNNING                                           
EXTRACT     RUNNING     DPEA        00:00:00      00:00:02    
EXTRACT     RUNNING     EXTA        00:00:00      00:00:03    
REPLICAT    RUNNING     REP_REV     00:00:00      00:00:02    

GGSCI (slient as ogg@test) 9>

15. 测试源端和目标端的数据

–测试前先检查源库和目标库:
源库:
SQL> show user
USER is "SCOTT"
SQL>
SQL> select * from bonus;

ENAME      JOB              SAL       COMM
———- ——— ———- ———-
wang       sales           1000         .1

SQL>

目标库:
SQL> show user
USER is "SCOTT"
SQL> select * from BONUS;

no rows selected

SQL>  

开始测试:
源库:
SQL> insert into bonus values('li','manager',10000,0.2);

1 row created.

SQL> commmit;
SQL>  select * from bonus;

ENAME      JOB              SAL       COMM
———- ——— ———- ———-
li         manager        10000         .2
wang       sales           1000         .1

检查目标库:
SQL>  select * from bonus;

ENAME      JOB              SAL       COMM
———- ——— ———- ———-
li         manager        10000         .2

再过一会查看:
源库:
SQL>  select * from bonus;

ENAME      JOB              SAL       COMM
———- ——— ———- ———-
li         manager        10000         .2
li         manager        10000         .2
li         manager        10000         .2
wang       sales           1000         .1

目标库:
SQL>  select * from bonus;

ENAME      JOB              SAL       COMM
———- ——— ———- ———-
li         manager        10000         .2
li         manager        10000         .2
li         manager        10000         .2
li         manager        10000         .2

就这样,来回在两个库之间不停的copy过来copy去(未防止日志不停增长,关闭目标库、源库相关extract、replicate等进程)

到此,相信大家对“OGG双向DML复制怎么实现”有了更深的了解,不妨来实际操作一番吧!这里是网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!

内容来源网络,如有侵权,联系删除,本文地址:https://www.230890.com/zhan/155148.html

(0)

相关推荐

  • 如何在Ethereum 2.0中编写查询Validator余额的JS代码?

    技术以太坊2.0查询Validator余额的JS代码怎么写以太坊2.0查询Validator余额的JS代码怎么写,很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,

    攻略 2021年12月14日
  • 怎样可以,一个人怎样才能实现自己的目标

    技术怎样可以,一个人怎样才能实现自己的目标在现实生活和工作中,有些人看到周围许多人取得了成绩,再看看自己,就会产生落差感,继而困惑:为什么别人总是比我成功怎样可以?为什么我总是在原地踏步?遇到这种情况,应先问问自己:“我

    生活 2021年10月21日
  • 寻寻觅觅的意思,如何解读李清照的《声声慢》

    技术寻寻觅觅的意思,如何解读李清照的《声声慢》李清照是我国文学史上杰出的女作家,宋词婉约派的主要代表人物,其作品对后世有着较大的影响寻寻觅觅的意思。《声声慢》可能是易安后期的作品。李清照所处的时代,是烽火连天,山河破碎的

    生活 2021年10月22日
  • Adapter适配器中如何通过Interface接口响应回调

    技术Adapter适配器中如何通过Interface接口响应回调这篇文章主要介绍了Adapter适配器中如何通过Interface接口响应回调,具有一定借鉴价值,感兴趣的朋友可以参考下,希望大家阅读完这篇文章之后大有收获

    攻略 2021年11月15日
  • 体育模拟

    技术体育模拟 体育模拟import randomdef printInfo(): print(“模拟体育竞技”) print(“学号后两位:26,曾俊谌”)
    def getInputs():

    礼包 2021年11月14日
  • Redis中如何实现支持几乎所有加锁场景的分布式锁

    技术Redis中如何实现支持几乎所有加锁场景的分布式锁小编给大家分享一下Redis中如何实现支持几乎所有加锁场景的分布式锁,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下

    攻略 2021年11月2日