采用Goldengate实现Oracle与MySQL之间的复制

ALLSTARS_ORACLE

采用Goldengate实现Oracle与MySQL之间的复制
一、安装Goldengate
1.        根据MySQL版本及操作系统版本，下载合适的MySQL安装介质，本例中操作系统为Windows XP，MySQL版本为5.1.42，因此，下载“Oracle GoldenGate V11.1.1.0.3 for MySQL 5.x on Windows 2003, 2008.zip”，文件大小约14MB；
2.        将上述zip文件展开到OGG安装目录，本例为D:\Oracle\GGS11g_MySQL；
3.        进入目录D:\Oracle\GGS11g_MySQL，执行“ggsci”进入OGG命令行，执行如下命令创建子目录：
Ggsci> create subdirs

4.        在OGG命令行下执行如下命令，为OGG管理器命名：
Ggsci> EDIT PARAM ./GLOBALS
在文件中，添加如下一行，并保存：
MGRSERVNAME GGSMYSQL
5.        配置OGG mgr参数：
Ggsci> EDIT PARAM MGR
在文件中，添加如下内容，并保存：
port 8809
DYNAMICPORTLIST 8840-8850
autorestart er *, retries 5, waitminutes 1
purgeoldextracts  /ggs/dirdat/*,usecheckpoints, minkeepdays 3
6.        启动OGG mgr：
Ggsci> strat mgr

目标端Oracle数据库的Goldengate安装，除了介质不同，与上述安装步骤相同，在此不再赘述。

二、安装并准备MySQL数据库
1.        下载并安装MySQL V5.1.42，本例中安装目录为D:\Oracle\MySQL5.1.42；
2.        设置环境变量MYSQL_HOME，指向D:\Oracle\MySQL5.1.42；使得Goldengate EXTRACT进程可以根据这个环境变量找到MySQL配置文件my.ini（其他平台为my.conf）；
3.        在MySQL配置文件my.ini中设置下列参数：
        将log-bin设置为一个目录和日志文件格式，如下例日志文件名为test.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
4.        重新启动MySQL服务器。
5.        执行如下命令：
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数据泵进程。三个进程的参数文件样例如下。
1.        源端添加EXTRACT进程exta：
a)        add extract exta, tranlog, begin now
b)        edit param exta
源端EXTRACT进程参数文件：
--日志捕获进程
extract exta
dboptions host localhost, connectionport 3306
sourcedb test, userid root, password root
exttrail ./dirdat/ea
--数据库对象
table TEST.TEST1;
c)        add exttrail  ./dirdat/ea, extract exta, megabytes 10
d)        start exta
e)        info exta，确认状态为RUNNING，否则查找解决错误


2.        源端添加Data Pump进程dmpa：
a)        add extract dmpa, exttrailsource  ./dirdat/ea
b)        edit param dmpa
源端数据泵进程参数文件：
extract  dmpa
rmthost 127.0.0.1, mgrport 7809
rmttrail ./dirdat/ra
passthru
table TEST.TEST1;

c)        add rmttrail ./dirdat/ra, extract dmpa,  megabytes 10
d)        start dmpa
e)        info dmpa, 确认状态为RUNNING，否则查找解决错误

3.        在MySQL端生成def文件，复制到目标端
a)        Ggsci> edit param defgen
defsfile ./dirdef/mysql.def, purge
dboptions host localhost, connectionport 3306
sourcedb test, userid root, password root
table test.test1;
b)        Shell> defgen paramfile ./dirprm/defgen.prm
c)        将生成的mysql.def文件ftp或复制到目标端Goldengate子目录dirdef下。

4.        目标端添加应用进程repa：
本例中目标为Oracle数据库信息为127.0.0.1：1521：xe。数据库用户为test，目标表为ora_test1:
create table ora_test1(id varchar2(10) primary key, name varchar2(20));
a)        add replicat repa, exttrail ./dirdat/ra nodbcheckpoint
b)        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;

c)        start repa, 确认状态为RUNNING，否则查找解决错误。

四、测试Goldengate
1.        执行如下命令,在MySQL表test.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)

2.        在目标端Oracle数据库上执行如下命令，查询是否同步了3条记录：
Shell> sqlplus test/test
SQL> select * from ora_test1;