使用Goldengate 实现Oracle for Oracle 单向数据同步
实验环境
数据源端: host1 ip 192.168.199.163
数据目标端: host2 ip 192.168.199.104
两台机器都安装 http://lqding.blog.51cto.com/9123978/1694971 文中描述安装配置好了Goldengate 。
要实现数据的同步,Oracle源端必须满足如下设置
Oracle需要运行在归档模式下
SQL> startup mount
ORACLE instance started.Total System Global Area 835104768 bytes
Fixed Size 2217952 bytes
Variable Size 574621728 bytes
Database Buffers 255852544 bytes
Redo Buffers 2412544 bytes
Database mounted.
SQL> alter database archivelog;Database altered.SQL> alter database open;Database altered.
2. 开启日志附加属性
SQL> ALTER DATABASE ADD SUPPLEMENTAL LOG DATA;Database altered.SQL> ALTER SYSTEM SWITCH LOGFILE;System altered.
ogg安装目录下提供了一些demo的sql
[oracle@localhost ogg]$ ls demo_ora_*
demo_ora_create.sql demo_ora_insert.sql demo_ora_lob_create.sql demo_ora_misc.sql demo_ora_pk_befores_create.sql demo_ora_pk_befores_insert.sql demo_ora_pk_befores_updates.sql
我们使用demo_ora_create.sql在源和目的端都创建两张表,在源端使用demo_ora_insert.sql插入数据。
host1
SQL> alter user scott identified by tiger account unlock;User altered.SQL> grant resource to scott; #ggsci 登录数据库时需要该权限
Grant succeeded.SQL> grant select any dictionary to scott; # add trandata时需要该权限Grant succeeded.
SQL> conn scott/tiger
Connected.
SQL> @demo_ora_create.sql
SQL> @demo_ora_insert.sql
host2
SQL> alter user scott identified by tiger account unlock;User altered.
SQL> grant resource to scott; #ggsci 登录数据库时需要该权限
Grant succeeded.SQL> grant select any dictionary to scott; # add trandata时需要该权限
SQL> conn scott/tiger
Connected.
SQL> @demo_ora_create.sql
为需要同步的表,添加附加日志
GGSCI (localhost.localdomain) 1> dblogin userid scott, password tiger
Successfully logged into database.GGSCI (localhost.localdomain) 2> add trandata scott.tcustmerLogging of supplemental redo data enabled for table SCOTT.TCUSTMER.GGSCI (localhost.localdomain) 3> add trandata scott.tcustordLogging of supplemental redo data enabled for table SCOTT.TCUSTORD.
一、初始化加载数据
在源端配置一个初始化Extract,用来同步表中现有数据
GGSCI (localhost.localdomain) 7> ADD EXTRACT EINILOAD, SOURCEISTABLE
EXTRACT added.
ADD EXTRACT命令用来添加一个EXTRACT, EINILOAD为Extract的group name 。SOURCEISTABLE表示数据源为表。
查看Extract的信息
GGSCI (localhost.localdomain) 9> INFO EXTRACT *, TASKSEXTRACT EINILOAD Initialized 2015-09-11 15:25 Status STOPPED
Checkpoint Lag Not Available
Log Read Checkpoint Not AvailableFirst Record Record 0
Task SOURCEISTABLE
配置初始化加载的捕获参数
GGSCI (localhost.localdomain) 10> edit params EINILOAD--
-- GoldenGate Initial Data Capture
-- for TCUSTMER and TCUSTORD
--
EXTRACT EINILOAD
USERID system, PASSWORD "oracle"
RMTHOST 192.168.199.104, MGRPORT 7809
RMTTASK REPLICAT, GROUP RINILOAD
TABLE SCOTT.TCUSTMER;
TABLE SCOTT.TCUSTORD;
在目标端,配置一个REPLICAT
GGSCI (localhost.localdomain) 2> ADD REPLICAT RINILOAD, SPECIALRUN
REPLICAT added.
查看REPLICAT信息
GGSCI (localhost.localdomain) 4> info replicat *, tasksREPLICAT RINILOAD Initialized 2015-08-22 14:18 Status STOPPED
Checkpoint Lag 00:00:00 (updated 00:02:50 ago)
Log Read Checkpoint Not Available
Task SPECIALRUN
配置Replicat参数
GGSCI (localhost.localdomain) 5> edit params riniload-- -- GoldenGate Initial Load Delivery -- REPLICAT RINILOAD ASSUMETARGETDEFS USERID system, PASSWORD "oracle" DISCARDFILE ./dirrpt/RINILOAD.dsc, PURGE MAP scott.*, TARGET scott.*;
启动Extract
GGSCI (localhost.localdomain) 11> start extract einiloadSending START request to MANAGER ...
EXTRACT EINILOAD starting
查看日志
GGSCI (localhost.localdomain) 21> view report einiload
如果有报错,查找原因并解决
Processing table SCOTT.TCUSTMERProcessing table SCOTT.TCUSTORD***********************************************************************
* ** Run Time Statistics ** *
***********************************************************************Report at 2015-09-11 16:23:40 (activity since 2015-09-11 16:23:33)Output to RINILOAD:From Table SCOTT.TCUSTMER:# inserts: 2# updates: 0# deletes: 0# discards: 0
From Table SCOTT.TCUSTORD:# inserts: 2# updates: 0# deletes: 0# discards: 0REDO Log StatisticsBytes parsed 0Bytes output 574
日志显示,已成功同步数据。
到目的库上验证
SQL> select count(*) from tcustmer;COUNT(*)
----------2SQL> select count(*) from tcustord;COUNT(*)
----------2
二、配置数据实时同步
源端,配置一个实时Extract
GGSCI (localhost.localdomain) 22> ADD EXTRACT EORAKK, TRANLOG, BEGIN NOW, THREADS 1
EXTRACT added.
编辑Extract的参数文件
GGSCI (localhost.localdomain) 23> EDIT PARAMS EORAKK-- -- Change Capture parameter file to capture -- TCUSTMER and TCUSTORD Changes -- EXTRACT EORAKK USERID system, PASSWORD oracle RMTHOST 192.168.199.104, MGRPORT 7809 RMTTRAIL ./dirdat/KK TABLE SCOTT.TCUSTMER; TABLE SCOTT.TCUSTORD;
为Extract添加远端tail file,也就是说这个tail file是在目的端生成的。
GGSCI (localhost.localdomain) 24> ADD RMTTRAIL ./dirdat/KK, EXTRACT EORAKK, MEGABYTES 5 RMTTRAIL added.
验证结果
GGSCI (localhost.localdomain) 28> INFO RMTTRAIL *Extract Trail: ./dirdat/KKExtract: EORAKKSeqno: 0RBA: 0File Size: 5M
启动Extract 进程
GGSCI (localhost.localdomain) 29> start extract eorakkSending START request to MANAGER ...
EXTRACT EORAKK starting
验证结果
GGSCI (localhost.localdomain) 30> INFO EXTRACT EORAKK, DETAILEXTRACT EORAKK Last Started 2015-09-11 17:07 Status RUNNING
Checkpoint Lag 00:00:00 (updated 00:00:01 ago)
Log Read Checkpoint Oracle Redo Logs2015-09-11 17:07:47 Thread 1, Seqno 25, RBA 36139008SCN 0.1174781 (1174781)Target Extract Trails:Remote Trail Name Seqno RBA Max MB./dirdat/KK 0 1050 5Extract Source Begin End /u01/app/oracle/oradata/orcl/redo01.log 2015-09-11 16:58 2015-09-11 17:07Not Available * Initialized * 2015-09-11 16:58Current directory /u01/app/oggReport file /u01/app/ogg/dirrpt/EORAKK.rpt
Parameter file /u01/app/ogg/dirprm/eorakk.prm
Checkpoint file /u01/app/ogg/dirchk/EORAKK.cpe
Process file /u01/app/ogg/dirpcs/EORAKK.pce
Stdout file /u01/app/ogg/dirout/EORAKK.out
Error log /u01/app/ogg/ggserr.log
GGSCI (localhost.localdomain) 31> VIEW REPORT EORAKK
GGSCI (localhost.localdomain) 32> INFO ALLProgram Status Group Lag at Chkpt Time Since ChkptMANAGER RUNNING EXTRACT RUNNING EORAKK 00:00:00 00:00:06
目标端,配置REPLICAT
安装checkpoint表
配置checkpoint表的名称
GGSCI (localhost.localdomain) 33> EDIT PARAMS ./GLOBALSHECKPOINTTABLE system.ggschkpt
生成checkpoint表
GGSCI (localhost.localdomain) 1> DBLOGIN USERID system, PASSWORD oracle Successfully logged into database.GGSCI (localhost.localdomain) 2> ADD CHECKPOINTTABLENo checkpoint table specified, using GLOBALS specification (system.ggschkpt)...Successfully created checkpoint table system.ggschkpt.GGSCI (localhost.localdomain) 3>
添加Replicat
GGSCI (localhost.localdomain) 3> ADD REPLICAT RORAKK, EXTTRAIL ./dirdat/KK
REPLICAT added.
创建Replicat的参数文件
GGSCI (localhost.localdomain) 4> EDIT PARAMS RORAKK--
-- Change Delivery parameter file to apply
-- TCUSTMER and TCUSTORD Changes
--
REPLICAT RORAKK
USERID system, PASSWORD oracle
HANDLECOLLISIONS
ASSUMETARGETDEFS
DISCARDFILE ./dirrpt/RORAKK.DSC, PURGE
MAP scott.tcustmer, TARGET scott.tcustmer;
MAP scott.tcustord, TARGET scott.tcustord;
启动Replicat
GGSCI (localhost.localdomain) 5> start replicat rorakkSending START request to MANAGER ... REPLICAT RORAKK starting
验证结果
GGSCI (localhost.localdomain) 6> info replicat rorakkREPLICAT RORAKK Last Started 2015-08-22 15:49 Status RUNNING
Checkpoint Lag 00:00:00 (updated 00:00:08 ago)
Log Read Checkpoint File ./dirdat/KK000000First Record RBA 1050
验证数据同步
在源数据库,执行如下脚本,对两个表进行insert、update、delete操作
[oracle@localhost ogg]$ sqlplus scott/tigerSQL*Plus: Release 11.2.0.1.0 Production on Fri Sep 11 17:58:17 2015Copyright (c) 1982, 2009, Oracle. All rights reserved.Connected to:
Oracle Database 11g Enterprise Edition Release 11.2.0.1.0 - 64bit Production
With the Partitioning, OLAP, Data Mining and Real Application Testing optionsSQL> @/u01/app/ogg/demo_ora_misc.sql
查看源表中的数据
SQL> select count(*) from tcustmer;COUNT(*)
----------5SQL> select count(*) from tcustord;COUNT(*)
----------3
查看目的表的数据
SQL> select count(*) from tcustmer;COUNT(*)
----------5SQL> select count(*) from tcustord;COUNT(*)
----------3
数据已同步
三、为同步添加data pump
如果没有data pump,Extract将Trail file写到远程机器上。如果为Extract配置了Data Pump。那么Extract将Trail file写到本地。然后Trail 文件由Data Pump传输到远端。
先修改Extract的配置
GGSCI (localhost.localdomain) 1> info allProgram Status Group Lag at Chkpt Time Since ChkptMANAGER RUNNING EXTRACT RUNNING EORAKK 00:00:00 00:00:09 GGSCI (localhost.localdomain) 2> stop extract eorakkSending STOP request to EXTRACT EORAKK ... Request processed.GGSCI (localhost.localdomain) 3> edit params eorakk-- -- Change Capture parameter file to capture -- TCUSTMER and TCUSTORD Changes -- EXTRACT EORAKK USERID system, PASSWORD oracle RMTHOST 192.168.199.104, MGRPORT 7809 EXTTRAIL ./dirdat/KK TABLE SCOTT.TCUSTMER; TABLE SCOTT.TCUSTORD;
将参数文件中的RMTTRAIL ./dirdat/kk 改为 EXTTRAIL ./dirdat/KK
2. 删除Extract的远程Trail
GGSCI (localhost.localdomain) 7> DELETE RMTTRAIL ./dirdat/KK
Deleting extract trail ./dirdat/KK for extract EORAKK
3. 增加一个本地Trail
GGSCI (localhost.localdomain) 10> ADD EXTTRAIL ./dirdat/KK, EXTRACT eorakk EXTTRAIL added.
4. 新增Data pump
GGSCI (localhost.localdomain) 12> ADD EXTRACT EPMPKK, EXTTRAILSOURCE ./dirdat/KK EXTRACT added.
Data pump本质上也是一个Extract,只是类型不同而已
为data pump配置参数文件
GGSCI (localhost.localdomain) 14> edit params epmpkk-- -- Data Pump parameter file -- EXTRACT EPMPKK PASSTHRU RMTHOST 192.168.199.104, MGRPORT 7809 RMTTRAIL ./dirdat/KK TABLE SCOTT.TCUSTMER; TABLE SCOTT.TCUSTORD;
为Data Pump添加远端Trail
GGSCI (localhost.localdomain) 15> add rmttrail ./dirdat/KK, EXTRACT EPMPKK RMTTRAIL added.
启动Extract、Data Pump
GGSCI (localhost.localdomain) 16> start extract eorakkSending START request to MANAGER ... EXTRACT EORAKK startingGGSCI (localhost.localdomain) 17> start extract epmpkkSending START request to MANAGER ... EXTRACT EPMPKK starting
验证数据同步
在源端,删除两个表的内容
SQL> delete from tcustmer;5 rows deleted.SQL> delete from tcustord;3 rows deleted.SQL> commit;Commit complete.
查看目的端表内容
SQL> select * from tcustmer;no rows selectedSQL> select * from tcustord;no rows selected
转载于:https://blog.51cto.com/lqding/1695162
使用Goldengate 实现Oracle for Oracle 单向数据同步相关推荐
- 如何实现Oracle数据库之间的数据同步?
我们都知道,在Oracle数据库的管理与开发工作中,总会存在着一些表数据和基础资料数据,这时需要有效的将这些数据库进行同步合并,有没有什么简单的方法可以实现Oracle数据库之间的数据同步呢?在此诚恺 ...
- redis和oracle同步方案,redis与oracle之间怎么实现数据同步?
redis与oracle之间怎么实现数据同步? 更新时间:2019-03-12 16:02 最满意答案 没有直接同步的方法,这个依赖于你的架构设计. 插入时同步,比如先更新了oracle,再更新red ...
- oracle 单向同步 方案,使用Goldengate 实现Oracle for Oracle 单向数据同步
实验环境 数据源端: host1 ip 192.168.199.163 数据目标端: host2 ip 192.168.199.104 要实现数据的同步,Oracle源端必须满足如下设置Oracle ...
- Oracle到MySQL实时数据同步CloudCanal实战
简述 CloudCanal 2.1.0.x 版本开始支持 Oracle 作为源端的数据迁移同步能力,目前邀请测试中. 本文通过 Oracle 到 MySQL 的数据迁移同步案例简要介绍这个源端的能力. ...
- 使用kafka connect 实现从oracle到kafka的数据同步
1.登陆Oracle: [oracle@localhost ~]$ lsnrctl status [oracle@localhost ~]$ lsnrctl start [oracle@localho ...
- oracle两表同步java代码,利用DBLink+JOB实现两个Oracle数据库之间的数据同步
该楼层疑似违规已被系统折叠 隐藏此楼查看此楼 第三步:建立JOB任务,定时同步数据在PL/SQL的command window输入以下语句: begin sys.dbms_job.submit(job ...
- 两个oracle数据库外网同步,利用DBLink+JOB实现两个Oracle数据库之间的数据同步
该楼层疑似违规已被系统折叠 隐藏此楼查看此楼 第三步:建立JOB任务,定时同步数据在PL/SQL的command window输入以下语句: begin sys.dbms_job.submit(job ...
- Oracle数据同步
温习一下Oracle中常说的HA.RAC.Datagurad的区别 简单的说 rac侧重于负载均衡 dg侧重于容灾 datagourd 双机侧重于业务的自动接管 关键看你的应用要求是什么样的 来进行 ...
- oracle rac 主备 轮训,oracle集群(RAC)和主备数据同步(DataGuard)思路
在线QQ客服:1922638 专业的SQL Server.MySQL数据库同步软件 Oracle主备库数据同步使用DataGuard.Data Guard 是Oracle的远程复制技术,它有物理和逻辑 ...
最新文章
- python数据处理pdf百度云_Python数据处理 PDF 高清版
- android 强制设置横屏 判断是横屏还是竖屏
- ubuntu 为用户添加组
- 第二次冲刺每日站立会议04
- 属于PHP语言结构的是,PHP语言结构
- 《Linux From Scratch》第二部分:准备构建 第五章:构建临时文件系统- 5.2 工具链技术备注...
- node本地连接服务器的数据库_基于Node.jsORM框架Sequelize的数据库迁移一
- oracle左连接没用_oracle左外连接不显示正确的空值
- tensorflow中的sequence_loss_by_example
- 【Oracle 学习】Scott账号解锁
- 超越界限,定义未来-- HP刀片工作站WS460c Gen9无惧4K挑战
- 终端terminal个性化配置
- 计算机组装常用工具有锤子,工具箱中常用的五金工具有哪些?
- MacOS 迅速上手 Makefile 编译 C / C++ 工程
- Leetcode——714. Best Time to Buy and Sell Stock with Transaction Fee
- 恶劣的仿造文化:从meebo到米博
- 拼多多如何引流推广产品?拼多多新产品如何推广?
- java娘_如何调教Java娘来优化MC!
- 大白菜U盘启动制作工具装机维护版V5.0–大白菜U盘下载中心
- MICHAEL KORS推出全新标志性智能腕表:Runway系列智能腕表
热门文章
- windows经典地雷小游戏(C语言实现)
- utorrent设置上传速度_utorrent下载速度慢怎样设置 utorrent常用设置图文教程
- windows配置gitlab秘钥并测试_你了解多少Linux系统GitLab安装与环境配置?
- QT5界面操作3: QPainter和paintEvent(self, event)的配合
- java 面试题 简书_java面试题
- ai怎样导出所选部分_Adobe Photoshop批量导出照片+模糊照片变清晰+火焰字体制作介绍...
- java 套娃_【leetcode编程题目354】俄罗斯套娃
- c语言for循环语句java,C语言三种类型的循环语句
- 重装了java然后说找不到路径,Java第三次作业第五题
- mysql性能分析工具profiling_Mysql系列(十)—— 性能分析工具profiling