采用Goldengate实现Oracle与MySQL之间的复制
采用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;
页:
[1]