使用Data Pump 来进行初始化

(1)配置OGG 进程   datapump (参考datapump模式的搭建)
8.1在source和target database 上创建测试用户
--source database
 SQL> create user sender identified by oracle default tablespace users temporary tablespace temp;  --创建用户
 User created.
 SQL> grant connect,resource,dba to sender;
 Grant succeeded.

2. --target database
 SQL> create user receiver identified by oracle default tablespace users temporary tablespace temp;  --创建用户
 User created.
 SQL> grant connect,resource,dba to receiver;
 Grant succeeded.

8.2 配置SourceDB 的复制队列

GGSCI (ogg02) 10> dblogin userid ggs, password ggs
Successfully logged into database.

GGSCI (ogg02) 11> add extract ext1,tranlog, begin now
EXTRACT added.

GGSCI (ogg02) 12> add exttrail /u01/pjj/dirdat/lt, extract ext1
EXTTRAIL added.
修改抽取进程ext1参数:
GGSCI (ogg1) 13> edit params ext1
extract ext1
userid ggs, password ggs
exttrail /u01/pjj/dirdat/lt
ddl include mapped objname sender.*;
table sender.*;
8.2.1 增加Pump 进程

GGSCI (ogg1) 8> add extract dpump,exttrailsource /u01/pjj/dirdat/lt
EXTRACT added. 
--这里指定我们localtrail 的位置。
GGSCI (ogg02) 18> add rmttrail /u01/pjj/dirdat/rt, extract dpump,megabytes 10    --trail文件的大小
RMTTRAIL added.

配置Data Pump 参数:

GGSCI (gg1) 56> view params dpump

extract dpump
userid ggs@ogg1, password ggs
dynamicresolution
passthru
rmthost 192.168.1.62, mgrport 7809
rmttrail /u01/ggs/dirdat/rt
table sender.*;


配置Data Pump 参数: 
-----------------------------------------以这个为准
GGSCI (ogg02) 27> edit params dpump   --查看一下
extract dpump
userid ggs, password ggs
dynamicresolution
passthru
rmthost 192.168.56.23, mgrport 7809
rmttrail /u01/pjj/dirdat/rt             
table sender.*;
9. target 端 

9.1 添加checkpointtable
GGSCI (ogg2) 1> dblogin userid ggs,password ggs
Successfully logged into database.

GGSCI (ogg2) 2> add checkpointtable ggs.checkpoint
Successfully created checkpoint table ggs.checkpoint.

9.2添加target replicat进程
GGSCI (ogg04) 1>  add replicat rep1,exttrail /u01/pjj/dirdat/rt, checkpointtable ggs.checkpoint

REPLICAT added.

GGSCI (ogg04) 2> edit params rep1
replicat rep1
ASSUMETARGETDEFS
userid ggs,password ggs
discardfile /u01/pjj/dirdat/rep1_discard.txt,append, megabytes 10
DDL
map sender.*, target receiver.*;

--------------------------------------------------------------------------------------------------------
1.启动抽取进程和Data pump,不启动Rep1.
2. 创建directory

在source和target 端都创建该directory。
SQL> create directory backup as '/oradata/oggback';
Directory created.

确认:
SQL> select * from dba_directories;
OWNER DIRECTORY_NAME            DIRECTORY_PATH
----- ------------------------- -----------------------------------------------------------------------
SYS   BACKUP                    /u01/backup
SYS   GGS_DDL_TRACE             /u01/app/oracle/diag/rdbms/dave/dave/trace
SYS   XMLDIR                    /u01/app/oracle/product/11.2.0/db_1/rdbms/xml
SYS   DATA_PUMP_DIR             /u01/app/oracle/admin/dave/dpdump/
SYS   ORACLE_OCM_CONFIG_DIR     /u01/app/oracle/product/11.2.0/db_1/ccr/state

3. 确认长事务已经完成

SQL> select  start_time  from v$transaction where to_date(start_time, 'yyyy-mm-dd hh24:mi:ss')<to_date('2014-03-22 05:02:26','yyyy-mm-dd hh24:mi:ss');
no rows selected
4. 获取源端获取数据库当前的SCN

SQL> select dbms_flashback.get_system_change_number from dual;

GET_SYSTEM_CHANGE_NUMBER
------------------------
           748013

5. 在源端导出数据

$ expdp  system/oracle directory=backup dumpfile=sender_%U.dmp logfile=user.log schemas=sender parallel=2  flashback_scn=748013; 
6. 在Target 端导入

[oracle@ogg1 backup]$ scp *.dmp 192.168.56.23:/oradata/oggback
oracle@192.168.1.62's password: 
sender_01.dmp                                                                                     100%  304KB 304.0KB/s   00:00    
sender_02.dmp                                                                                     100%   36KB  36.0KB/s   00:00    
[oracle@ogg1 backup]$
[oracle@ogg2 ggs]$ impdp system/oracle directory=backup dumpfile= sender_%U.dmp logfile=user.log  parallel=2  table_exists_action=replace REMAP_SCHEMA=sender:receiver;        
7. 用SCN 启动Replicat
GGSCI (ogg2) 17> start rep1, aftercsn 748013
GGSCI (ogg2) 18> info rep2

REPLICAT   REP1      Last Started 2014-03-22 06:44   Status RUNNING
Checkpoint Lag         00:00:00 (updated 00:00:08 ago)
Process ID                19233
Log Read Checkpoint  File /u01/ggs/dirdat/lt000000
                     First Record  RBA 0

8. 验证同步情况

第八章:ogg初始化datapump相关推荐

  1. OGG-01004|OGG 初始化数据问题处理

    作者 | JiekeXu 来源 | JiekeXu DBA之路(ID: JiekeXu_IT) 大家好,我是 JiekeXu,很高兴又和大家见面了,今天和大家一起来看看 OGG 初始化数据问题处理,欢 ...

  2. ogg初始化mysql数据_利用OGG进行数据库表的初始化

    利用OGG进行数据库表的初始化 前提是已经搭建好了OGG的运行环境和OGG程序的安装部署!!! 若不知道如何安装OGG请查阅博客中相关安装部署文档. 1.停止目标端replicat进程re1 2.配置 ...

  3. Ogg For Bigdata 同步Oracle数据到KAFKA(包括初始化历史数据)

    OGG同步Oracle数据到KAFKA:OGG初始化进程初始化历史数据 在前面曾写过几篇关于OGG同步Oracle等库数据到kafka的文章: OGG实时同步Oracle数据到Kafka实施文档(供f ...

  4. ogg oracle 测试kafka_基于OGG的Oracle与Hadoop集群/kafka准实时同步

    Oracle里存储的结构化数据导出到Hadoop体系做离线计算是一种常见数据处置手段.近期有场景需要做Oracle到Hadoop体系的实时导入,这里以此案例做以介绍. Oracle作为商业化的数据库解 ...

  5. 使用 Direct Initial Load 初始化 GoldenGate 同步数据

    作者简介 桑凯 现任职于云和恩墨,具有多年 Oracle 数据库企业级运维经验,擅长容灾项目解决方案设计,作为项目经理负责多个基于 Oracle DataGuard 和 GoldenGate 的双中心 ...

  6. ogg oracle 测试kafka_利用ogg实现oracle到kafka的增量数据实时同步

    前言 ogg即Oracle GoldenGate是Oracle的同步工具,本文讲如何配置ogg以实现Oracle数据库增量数据实时同步到kafka中,其中同步消息格式为json. 下面是我的源端和目标 ...

  7. Oracle OGG Kafka

    GoldenGate介绍 GoldenGate软件是一种基于日志的结构化数据复制软件.GoldenGate 能够实现大量交易数据的实时捕捉.变换和投递,实现源数据库与目标数据库的数据同步,保持亚秒级的 ...

  8. OGG遇到相关问题汇总

    OGG初始化加载数据时遇到的问题 1.target端拒绝source端访问2016-12-13 14:31:03 INFO OGG-00963 Oracle GoldenGate Manager fo ...

  9. 【OGG】经典架构在postgresql-14上的安装部署-1

    环境 操作系统: ORACLE Linux7.9-64bit 数据库版本: Postgresql-14.2-64bit OGG版本:OGG21.3-64bit 2台测试服务器:(源)192.168.5 ...

最新文章

  1. 新勒索软件DynA-Crypt不仅要加密你的文件,而且窃取并删除它们
  2. 数学中的向量乘积和矩阵乘积总结
  3. 20款Notepad++插件下载和介绍
  4. django-ckeditor表情包修改
  5. s查找mysql服务_MySQL菜鸟实录(一):MySQL服务安装实战
  6. C++中4种方式把字符串和数字连接起来(转载)
  7. 详解ROS中的TF使用
  8. linux下网络包分析工具下载,Wireshark下载-网络封包分析工具 v3.2.6 官方版 - 下载吧...
  9. Recovery真的不是难事!
  10. POJ-1251-Jungle Roads
  11. Phycharm下载并安装
  12. 韩顺平 php大牛班课程,2016 泰牛程序员 韩顺平 PHP 大牛班 javascript课程 完整笔记.doc...
  13. Python 国产库推荐:musicpy
  14. 如何在你的Android手机上配置 Python 环境?
  15. 【整理】PYTHON代码审查工具
  16. pytorch_LSTM:参数
  17. 用百度地图sdk返回详细地址描述
  18. VLink的简单验证过程
  19. 毕业后的去向:继续读研还是直接就业?
  20. 安装jdk,没有jre

热门文章

  1. Prerender.io 配置过程 给你的VUE单页面网站增加一点seo吧~
  2. android 电池温度传感器,android传感器
  3. 12.4 票据背书实现
  4. 【问题解决】Ubuntu(Linux)显示时出现菱形乱码
  5. MP3自动播放,并且顺序播放
  6. Windows下Docker配置安装加速器
  7. 基于SpringBoot的汉服推广管理系统
  8. java的lookup方法_深入理解Spring中的Lookup(方法注入)
  9. C#控制台应用程序——防伪码
  10. 平面设计师个人简历模板