ogg异构数据同步初始化的2中方法
2023-09-27 14:20:52 时间
下面以源端是oracle,目的端是mysql为例
#########################抽取数据不落地#################################
源端oracle:
GGSCI (host01) 4> ADD EXTRACT EINI_1, SOURCEISTABLE
EXTRACT added.
GGSCI (db.cn.oracle.com) 3> EDIT PARAMS EINI_1
EXTRACT EINI_1
SETENV (NLS_LANG=AMERICAN_AMERICA.AL32UTF8)
USERID goldengate, PASSWORD goldengate
RMTHOST 192.168.1.135, MGRPORT 7809
RMTTASK REPLICAT, GROUP RINI_1
TABLE hxl.metric; --这里数据量大的话还可以使用filter拆分多个抽取进程
目的端mysql
GGSCI (host02) 4> ADD REPLICAT RINI_1, SPECIALRUN
REPLICAT added.
GGSCI (host02) 5> EDIT PARAMS RINI_1
replicat RINI_1
sourcedefs /u01/goldengate19c_for_mysql/dirdef/defgen.prm
SETENV (MYSQL_UNIX_PORT=/opt/mysql5727/mysql.sock)
targetdb db_hxl@localhost:3306 userid goldengate, password mysql
reperror default, discard
discardfile ./dirrpt/RINI_1.dsc,APPEND,MEGABYTES 1000
MAP hxl.metric,TARGET db_hxl.metric;
在源端(oracle)启动抽取进程,会自动启动目的端的应用进程
GGSCI (host01) 7> START EXTRACT EINI_1
Sending START request to MANAGER ...
EXTRACT EINI_1 starting
处理完成后源端和目的端的进程都会自动停掉
#########################抽取数据落地#################################
源端oracle
1.编辑初始化抽取进程参数
GGSCI>edit params ext_init
EXTRACT ext_init
SETENV (NLS_LANG=AMERICAN_AMERICA.AL32UTF8)
USERID goldengate, PASSWORD goldengate
RMTHOST 192.168.1.135, MGRPORT 7809
rmtfile ./dirdat/ei, maxfiles 999999, megabytes 1500, append
TABLE hxl.metric;
2.添加抽取进程并启动
GGSCI>add extract ext_init, SOURCEISTABLE
GGSCI>start ext_init
这个时候日志会同步到mysql端的dirdat目录下,主库的抽取进程执行完成后会自动停掉
目的端mysql
1.创建初始化复制进程
GGSCI>edit params rep_init
replicat rep_init
--sourcedefs /u01/goldengate19c_for_mysql/dirdef/defgen.prm
SETENV (MYSQL_UNIX_PORT=/opt/mysql5727/mysql.sock)
targetdb db_hxl@localhost:3306 userid goldengate, password mysql
reperror default, discard
discardfile ./dirrpt/rep_init.dsc,APPEND,MEGABYTES 1000
MAP hxl.metric,TARGET db_hxl.metric;
2.添加checkpoint
GGSCI > dblogin sourcedb db_hxl@192.168.1.135:3306 userid goldengate password mysql
Successfully logged into database.
GGSCI (host135 DBLOGIN as goldengate) 47> add checkpointtable db_oggadmin.checkpoint
Successfully created checkpoint table db_oggadmin.checkpoint.
这里需要提前创建好库db_oggadmin,并赋予权限给到同步的账号goldengate。
3.checkpoint加入到全局文件
GGSCI > edit params ./GLOBALS
checkpointtable db_oggadmin.checkpoint
4.添加复制进程
GGSCI > add replicat rep_init, exttrail ./dirdat/ei,checkpointtable db_oggadmin.checkpoint
REPLICAT added.
5.启动
GGSCI>start rep_init
检查数据同步完成后需要手工停掉复制进程并删除
GGSCI>stop rep_init
GGSCI>delete replicat rep_init
相关文章
- CentOS6.5使用rsync远程同步
- [转] JavaScript:彻底理解同步、异步和事件循环(Event Loop)
- QQ窗体的控制,同步异步打开360网盘,控制360网盘窗体的移动
- Linux C线程同步的三种方法
- 云知声发布多模态 AI 芯片战略,同步曝光三款在研芯片
- Linux Command rsync 远程同步
- win7时间同步出错的解决方法
- C++程序设计课程同步项目——循环结构程序设计项目任务一
- react 聊聊setState异步背后的原理,react如何感知setState下的同步与异步?
- 使用ntp从时间同步服务器更新centos系统时间的方法
- 解决CentOS 6环境时区、日期、时间同步方法
- Node.js的那些坑——如何让异步并发方法同步顺序执行(for循环+异步操作)
- promise中异步同步方法 Unexpected reserved word ‘await‘
- ES6语法异步转同步(小程序中测试)
- SVN 钩子操作-同步更新web目录
- Juniper重组以实现职能和策略同步
- Linux服务器时间同步
- 小技巧随手记:一行代码实现星级评分、同步阻塞实现sleep函数、一行代码生成随机字符串(唯一ID/Number.prototype.toString([radix])用法)、获取浏览器Cookie的值、颜色RGB转十六进制、使用数字分隔符、最快获取dom方法(ID同名变量获取dom元素)、带命名空间的事件绑定
- Cookie管理 WebView同步
- 【JAVA】同步监视器、同步块和同步监视方法
- 线上服务 静态html CMS 发布rsync 同步
- CreateFile()----同步
- Navicat定时 同步数据库
- centos 5.4中mysql主从同步配置方法
- C#多线程问题(从不同步的代码块中调用了对象同步方法。)