一、Goldengate双向复制配置
1.1.在进行如下配置之前,先在源数据库source system(原来的目标数据库)端
添加辅助的redolog配置:
SQL>alter database add supplemental log data;
SQL>alter system switch logfile;
SQL>alter database force logging;
1.2.在原Source和原Target分别用scott用户创建一张emp_ogg表
SQL> create table emp_ogg as select * from emp
where 1=0; //原source库建立表但不插入数据
Table created.
单项复制时Source端是EINI_1进程,Target端是RINI_1进程,双向复制时反之,以便完成两表的初始化同步,配置如下:
原Source
GGSCI (gc2) 36> ADD REPLICAT RINI_1, SPECIALRUN
REPLICAT added.
GGSCI (gc2) 43> EDIT PARAMS RINI_1
-- GoldenGate Initial Load Delivery
--
REPLICAT RINI_1
SETENV (NLS_LANG=AMERICAN_AMERICA.ZHS16GBK)
ASSUMETARGETDEFS
USERID ogg, PASSWORD ogg
DISCARDFILE ./dirrpt/RINIaa.dsc, PURGE
MAP scott.*, TARGET scott.*;
原Target
GGSCI
(oraclelinux54.cuug.net) 10> ADD EXTRACT
EINI_1, SOURCEISTABLE
EXTRACT added.
GGSCI
(oraclelinux54.cuug.net) 11> INFO EXTRACT *, TASKS
EXTRACT EINI_1
Initialized 2014-08-12
23:05 Status STOPPED
Checkpoint Lag Not Available
Log Read Checkpoint Not Available
First Record Record 0
Task SOURCEISTABLE
GGSCI
(oraclelinux54.cuug.net) 12> EDIT PARAMS EINI_1
-- GoldenGate Initial Data Capture
-- for EMP_OGG and DEPT_OGG
--
EXTRACT EINI_1
SETENV (NLS_LANG=AMERICAN_AMERICA.ZHS16GBK)
USERID ogg, PASSWORD ogg
RMTHOST gc2, MGRPORT 7809
RMTTASK REPLICAT, GROUP RINI_1
TABLE scott.EMP_OGG; //这里我们只为初始化scott用户下的emp_ogg表
GGSCI
(oraclelinux54.cuug.net) 19> START EXTRACT
EINI_1
Sending START request to
MANAGER ...
EXTRACT EINI_1 starting
GGSCI
(oraclelinux54.cuug.net) 20> VIEW REPORT
EINI_1
……...
***********************************************************************
* ** Run Time Statistics
** *
***********************************************************************
Report at 2014-08-12
23:11:04 (activity since 2014-08-12 23:10:59)
Output to RINI_1:
From Table SCOTT.EMP_OGG:
# inserts: 14 //可以看出两边已经同步成功
# updates: 0
# deletes: 0
# discards: 0
1.3.在ogg环境下,添加日志跟踪:
GGSCI
(oraclelinux54.cuug.net) DBLOGIN USERID ogg, PASSWORD ogg
GGSCI
(oraclelinux54.cuug.net) ADD TRANDATA scott.* //这里为了试验方便,我们设置为scott下全部表均设为可同步状态
2013-08-13
03:21:18 GGS WARNING
109 No unique key is defined for table EMP_OGG. All
viable columns will be used to represent the key, but may not guarantee
uniqueness. KEYCOLS may be used to
define the key.
2013-08-13
03:21:18 GGS WARNING 301
Failed to add supplemental log group on table SCOTT.EMP_OGG due to
ORA-01031: insufficient privileges,
SQL ALTER TABLE "SCOTT"."EMP_OGG" ADD SUPPLEMENTAL LOG
GROUP "GGS_EMP_OGG_74686"
("EMPNO","ENAME","JOB","MGR","HIREDATE","SAL","COMM","DEPTNO")
ALWAYS /* GOLDENGATE_DDL_REPLICATION */.
解决办法:
SQL>alter table emp_ogg add constraint emp_ogg_pk primary
key(empno);
SQL> grant alter any table to ogg;
Grant
succeeded.
1.4.配置extract
GGSCI
(gc2) 71> EDIT PARAMS
EORA_1 //编辑前先停止进程
EXTRACT EORA_1
SETENV (NLS_LANG=AMERICAN_AMERICA.ZHS16GBK)
USERID ogg, PASSWORD ogg
EXTTRAIL ./dirdat/aa
TABLE scott.*;
DDL INCLUDE OBJNAME "scott.*"
TRANLOGOPTIONS EXCLUDEUSER ogg //双向复制关键
GGSCI
(oraclelinux54.cuug.net) 74> EDIT PARAMS EORA_1 //编辑前先停止进程
EXTRACT EORA_1
SETENV (NLS_LANG=AMERICAN_AMERICA.ZHS16GBK)
USERID ogg, PASSWORD ogg
TRANLOGOPTIONS EXCLUDEUSER ogg
EXTTRAIL ./dirdat/aa
TABLE scott.*;
DDL INCLUDE OBJNAME "scott.*"
GGSCI (双节点执行)> ADD EXTRACT
EORA_1, TRANLOG, BEGIN NOW
注:
ADD EXTRACT EORA_1:添加EXTRACT进程,这就是一直运行,一段停止redo 里的日志就没人去抓取了
TRANLOG, BEGIN NOW:现在开始同步日志,也可以用异步,那就要另外配置
EXTRACT added.
GGSCI (双节点执行)> ADD EXTTRAIL
./dirdat/aa, EXTRACT EORA_1, MEGABYTES 5 //添加跟踪文件给EORA_1用,大小为5M
EXTTRAIL added.
GGSCI (双节点执行)> START EXTRACT EORA_1
1.5.配置pump进程
GGSCI
(gc2) 72> EDIT PARAMS
PORA_1 //编辑前先停止进程
EXTRACT PORA_1
SETENV (NLS_LANG=AMERICAN_AMERICA.ZHS16GBK)
PASSTHRU
RMTHOST oraclelinux54.cuug.net, MGRPORT 7809
RMTTRAIL /u01/app/ogg/dirdat/pa
TABLE scott.*;
GGSCI
(oraclelinux54.cuug.net) 75> EDIT PARAMS PORA_1 //编辑前先停止进程
EXTRACT PORA_1
SETENV (NLS_LANG=AMERICAN_AMERICA.ZHS16GBK)
PASSTHRU
RMTHOST gc2, MGRPORT 7809
RMTTRAIL ./dirdat/pa
TABLE scott.*;
GGSCI (双节点执行)> ADD EXTRACT PORA_1, EXTTRAILSOURCE ./dirdat/aa // 告诉PORA_1要传送哪个路径下的跟踪信息
EXTRACT
added.
GGSCI (双节点执行)> ADD RMTTRAIL ./dirdat/pa, EXTRACT
PORA_1, MEGABYTES 5 // 表示把捕获到的信息传送到远程的哪个目录的文件中
RMTTRAIL
added.
GGSCI (双节点执行)> START EXTRACT PORA_1
配置replicate
GGSCI (gc2) 74> EDIT PARAM RORA_1
REPLICAT RORA_1
SETENV (NLS_LANG=AMERICAN_AMERICA.ZHS16GBK)
USERID ogg, PASSWORD ogg
HANDLECOLLISIONS
ASSUMETARGETDEFS
DISCARDFILE ./dirrpt/RORA_aa.DSC, PURGE
DDL INCLUDE ALL
DDLERROR DEFAULT IGNORE RETRYOP MAXRETRIES 3
RETRYDELAY 5
DDLERROR DEFAULT DISCARD
DDLERROR DEFAULT IGNORE RETRYOP
MAP scott.*, TARGET scott.*;
GGSCI
(oraclelinux54.cuug.net) 87> EDIT PARAM
RORA_1
REPLICAT RORA_1
SETENV (NLS_LANG=AMERICAN_AMERICA.ZHS16GBK)
USERID ogg, PASSWORD ogg
HANDLECOLLISIONS
ASSUMETARGETDEFS
DISCARDFILE ./dirrpt/RORA_aa.DSC, PURGE
DDL INCLUDE ALL
DDLERROR DEFAULT IGNORE RETRYOP MAXRETRIES 3 RETRYDELAY 5
DDLERROR DEFAULT DISCARD
DDLERROR DEFAULT IGNORE RETRYOP
MAP scott.*, TARGET scott.*;
GGSCI
(双节点执行) 87> ADD REPLICAT RORA_1, EXTTRAIL ./dirdat/pa //表示从哪里提取传送过来的信息
GGSCI (双节点执行)
87> START REPLICAT RORA_1
SQL> conn / as sysdba
Connected.
SQL> grant insert on scott.emp_ogg to ogg;
Grant succeeded.
SQL> conn / as sysdba
Connected.
SQL> grant delete on scott.emp_ogg to ogg;
Grant succeeded.
SQL> grant update on scott.emp_ogg to ogg;
Grant succeeded.
二、配置checkpoint
GGSCI
(oraclelinux54.cuug.net) EDIT PARAMS ./GLOBALS
CHECKPOINTTABLE ogg.ggschkpt
GGSCI
(oraclelinux54.cuug.net) exit
GGSCI
(oraclelinux54.cuug.net) DBLOGIN USERID ogg, PASSWORD ogg
Successfully
logged into database.
GGSCI
(oraclelinux54.cuug.net) ADD CHECKPOINTTABLE //如果单项复制已经做了,这里不用再添加
应该看到,两节点的进程都为Running状态
GGSCI (gc2) 73> info all
Program Status
Group Lag Time Since Chkpt
MANAGER RUNNING
EXTRACT RUNNING EORA_1
00:00:00 00:00:02
EXTRACT RUNNING PORA_1
00:00:00 00:00:04
REPLICAT RUNNING RORA_1
00:00:00 00:00:01
GGSCI
(oraclelinux54.cuug.net) 88> info all
Program Status
Group Lag Time Since Chkpt
MANAGER RUNNING
EXTRACT RUNNING EORA_1
00:00:00 00:00:09
EXTRACT RUNNING PORA_1
00:00:00 00:00:02
REPLICAT RUNNING RORA_1
00:00:00 00:00:05
三、测试双向传送结果
3.1.source 到target
Source system
SQL> INSERT INTO emp_ogg
VALUES(8000,'HL','CLERK',7902,'12-DEC-80',800,100,20);
1 row created.
SQL> commit;
Commit complete.
SQL> select * from emp_ogg;
EMPNO ENAME JOB MGR HIREDATE SAL COMM
DEPTNO
---------- ----------
--------- ---------- --------- ---------- ---------- ----------
8000 HL CLERK 7902 12-DEC-80 800 100
20
Target system
SQL> select * from emp_ogg;
EMPNO ENAME JOB MGR HIREDATE SAL COMM
DEPTNO
---------- ----------
---------- ---------- --------------------- ---------- ---------- ----------
8000 HL CLERK 7902 1980-12-12 : 00:00:00 800 100 20
3.2target 到 source
Target system
SQL> select * from tcustmer;
CUST NAME CITY ST
----
------------------------------ -------------------- --
WILL BG
SOFTWARE CO. SEATTLE WA
JANE ROCKY
FLYER INC. DENVER CO
SQL> insert into tcustmer values ('HL','zai','cuug','en');
1 row created.
SQL> commit;
Commit
complete.
Source system
SQL> select * from tcustmer;
CUST NAME CITY ST
----
------------------------------ -------------------- --
WILL BG
SOFTWARE CO. SEATTLE WA
JANE ROCKY
FLYER INC. DENVER CO
helei zai cuug en
四、支持DDL复制配置
4.1在两个节点执行执行DDL同步脚本命令:
先进入goldengate软件安装目录,以SYSDBA身份登录oracle执行以下脚本,执行脚本过程中,需要输入的用户全部是ogg,安装模式为INITIALSETUP,如果数据字典或者某些内部的包有错误,则需要运行catalog.sql和catproc.sql脚本。
SQL>show parameter recyclebin;
NAME TYPE VALUE
------------------------------------
----------- ------------------------------
recyclebin
string off 必须是off
这里执行第二个脚本@ddl_setup时会报一个recyclebin的错误,而且只能在Pfile中修改recyclebin=off后用pfile起库,执行两个清除脚本,再重新运行一下脚本
SQL>@marker_setup
SQL>@ddl_setup
SQL>@role_setup
SQL>grant GGS_GGSUSER_ROLE to ogg;
SQL>@ddl_enable
如果某项脚本执行错误,需要重新执行时,先要执行清除的脚本:ddl_remove.sql和marker_remove.sql