本文永久地址:https://www.askmac.cn/archives/goldengate-oracle-mysql.html
采用OGG Goldengate实现Oracle与MySQL之间的复制
一、安装Goldengate
- 根据MySQL版本及操作系统版本,下载合适的MySQL安装介质,本例中操作系统为Windows XP,MySQL版本为1.42,因此,下载“Oracle GoldenGate V11.1.1.0.3 for MySQL 5.x on Windows 2003, 2008.zip”,文件大小约14MB;
- 将上述zip文件展开到OGG安装目录,本例为D:\Oracle\GGS11g_MySQL;
- 进入目录D:\Oracle\GGS11g_MySQL,执行“ggsci”进入OGG命令行,执行如下命令创建子目录:
Ggsci> create subdirs
- 在OGG命令行下执行如下命令,为OGG管理器命名:
Ggsci> EDIT PARAM ./GLOBALS
在文件中,添加如下一行,并保存:
MGRSERVNAME GGSMYSQL
- 配置OGG mgr参数:
Ggsci> EDIT PARAM MGR
在文件中,添加如下内容,并保存:
port 8809
DYNAMICPORTLIST 8840-8850
autorestart er *, retries 5, waitminutes 1
purgeoldextracts /ggs/dirdat/*,usecheckpoints, minkeepdays 3
- 启动OGG mgr:
Ggsci> strat mgr
目标端Oracle数据库的Goldengate安装,除了介质不同,与上述安装步骤相同,在此不再赘述。
二、安装并准备MySQL数据库
- 下载并安装MySQL V5.1.42,本例中安装目录为D:\Oracle\MySQL5.1.42;
- 设置环境变量MYSQL_HOME,指向D:\Oracle\MySQL5.1.42;使得Goldengate EXTRACT进程可以根据这个环境变量找到MySQL配置文件ini(其他平台为my.conf);
- 在MySQL配置文件ini中设置下列参数:
- 将log-bin设置为一个目录和日志文件格式,如下例日志文件名为00001、test.00002等,目录为“D:/Oracle/MySQL5.1.42/logs/test.bin”
log-bin=”D:/Oracle/MySQL5.1.42/logs/test.bin”
- 设置max_binlog_size规定binary日志文件尺寸(以字节为单位),最小值应该为4096
max_binlog_size=10000000
- 将binlog_format设置为ROW。设为ROW使得DML语句以binary格式记入日志,任何其他日志格式(mixed或statement)将引起EXTRACT进程停止。
binlog_format=row
- 重新启动MySQL服务器。
- 执行如下命令:
Shell> mysql –u root –p
Enter password: root
mysql> use test
Database changed
mysql> create table test1(id varchar(10) primary key, name varchar(20));
Query OK, 0 rows affected (0.06 sec)
三、配置Goldengate进程
在MySQL源端配置EXTRACT抽取进程和DATAPUMP数据泵进程。三个进程的参数文件样例如下。
- 源端添加EXTRACT进程exta:
- add extract exta, tranlog, begin now
- edit param exta
源端EXTRACT进程参数文件:
–日志捕获进程
extract exta
dboptions host localhost, connectionport 3306
sourcedb test, userid root, password root
exttrail ./dirdat/ea
–数据库对象
table TEST.TEST1;
- add exttrail ./dirdat/ea, extract exta, megabytes 10
- start exta
- info exta,确认状态为RUNNING,否则查找解决错误
- 源端添加Data Pump进程dmpa:
- add extract dmpa, exttrailsource ./dirdat/ea
- edit param dmpa
源端数据泵进程参数文件:
extract dmpa
rmthost 127.0.0.1, mgrport 7809
rmttrail ./dirdat/ra
passthru
table TEST.TEST1;
- add rmttrail ./dirdat/ra, extract dmpa, megabytes 10
- start dmpa
- info dmpa, 确认状态为RUNNING,否则查找解决错误
- 在MySQL端生成def文件,复制到目标端
- Ggsci> edit param defgen
defsfile ./dirdef/mysql.def, purge
dboptions host localhost, connectionport 3306
sourcedb test, userid root, password root
table test.test1;
- Shell> defgen paramfile ./dirprm/defgen.prm
- 将生成的def文件ftp或复制到目标端Goldengate子目录dirdef下。
- 目标端添加应用进程repa:
本例中目标为Oracle数据库信息为127.0.0.1:1521:xe。数据库用户为test,目标表为ora_test1:
create table ora_test1(id varchar2(10) primary key, name varchar2(20));
- add replicat repa, exttrail ./dirdat/ra nodbcheckpoint
- edit param repa
目标段交付进程参数文件:
REPLICAT REPA
USERID goldengate, PASSWORD goldengate
SOURCEDEFS ./dirdef/mysql.def
ASSUMETARGETDEFS
DISCARDFILE ./dirrpt/ra.dsc, PURGE
MAP TEST.TEST1, TARGET test.ora_test1;
- start repa, 确认状态为RUNNING,否则查找解决错误。
四、测试Goldengate
- 执行如下命令,在MySQL表test1中插入三条记录:
Shell> mysql –u root –p
Enter password: root
mysql> use test
Database changed
mysql> insert into test1 values(‘1′,’User1’);
Query OK, 1 row affected (0.00 sec)
mysql> insert into test1 values(‘2′,’User2’);
Query OK, 1 row affected (0.02 sec)
mysql> insert into test1 values(‘3′,’User3’);
Query OK, 1 row affected (0.00 sec)
- 在目标端Oracle数据库上执行如下命令,查询是否同步了3条记录:
Shell> sqlplus test/test
SQL> select * from ora_test1;
Leave a Reply