GoldenGate单向复制配置

  1. 云栖社区>
  2. 博客>
  3. 正文

GoldenGate单向复制配置

科技探索者 2017-11-21 22:24:00 浏览511
展开阅读全文

本文中将演示下使用ogg在两台oracle 10g数据库服务器间实现单向复制的配置!

一:环境介绍
db1:source端
ip地址:192.168.123.10
数据库版本:10.2.0.1 64 bit
操作系统版本:centos 5.4 64 bit
ogg版本:fbo_ggs_Linux_x64_ora10g_64bit.tar

db2: target端
ip地址:192.168.123.20
数据库版本:10.2.0.1 64 bit
操作系统版本:centos 5.4 64 bit
ogg版本:fbo_ggs_Linux_x64_ora10g_64bit.tar

二:准备工作,在source和target端都配置
1:配置环境变量和tnsnames.ora文件


  1. [oracle@db1 ~]$ tail  .bash_profile   
  2. export ORACLE_SID=db1 
  3. export ORACLE_BASE=/u01/app/oracle  
  4. export ORACLE_HOME=$ORACLE_BASE/product/10.2.0/db1  
  5. export PATH=$ORACLE_HOME/bin:$PATH  
  6. export NLS_LANG=AMERICAN_AMERICA.AL32UTF8  
  7. export NLS_DATE_FORMAT='yyyy-mm-dd-hh24:mi:ss' 
  8. export EDITOR=vim 
  9. export TNS_ADMIN=$ORACLE_HOME/network/admin  
  10. export LD_LIBRARY_PATH=$ORACLE_HOME/lib:/lib:/usr/lib  
  11. export GGATE=$ORACLE_BASE/ogg  
  12.  
  13. [oracle@db1 ~]$ source .bash_profile   
  14.  
  15. [oracle@db1 ~]$ cat $TNS_ADMIN/tnsnames.ora  
  16. DB1 =  
  17.   (DESCRIPTION =  
  18.     (ADDRESS = (PROTOCOL = TCP)(HOST = db1)(PORT = 1521))  
  19.     (CONNECT_DATA =  
  20.       (SERVER = DEDICATED)  
  21.       (SERVICE_NAME = db1)  
  22.     )  
  23.   )  
  24.  
  25. DB2 =  
  26.   (DESCRIPTION =  
  27.     (ADDRESS = (PROTOCOL = TCP)(HOST = db2)(PORT = 1521))  
  28.     (CONNECT_DATA =  
  29.       (SERVER = DEDICATED)  
  30.       (SERVICE_NAME = db2)  
  31.     )  
  32.   ) 

2:确定数据库运行在归档模式,开启数据库附加日志,打开force logging,创建用于复制的数据库账号ogg,为了方便,这里直接赋予dba权限,如果对数据库安全要求高,可以去查询ogg文档,赋予复制需要的最小权限!(source和target端做相同的操作)


  1. [oracle@db1 ~]$ sqlplus /nolog  
  2. SQL> conn /as sysdba  
  3. Connected.  
  4. SQL> archive log list;  
  5. Database log mode              Archive Mode  
  6. Automatic archival             Enabled  
  7. Archive destination            USE_DB_RECOVERY_FILE_DEST  
  8. Oldest online log sequence     1  
  9. Next log sequence to archive   2  
  10. Current log sequence           2  
  11.  
  12. SQL> select supplemental_log_data_min from v$database;  
  13.  
  14. SUPPLEME  
  15. --------  
  16. NO  
  17.  
  18. SQL> alter database add supplemental log data;         
  19. Database altered.  
  20.  
  21. SQL> select supplemental_log_data_min from v$database;  
  22.  
  23. SUPPLEME  
  24. --------  
  25. YES  
  26.  
  27. SQL> alter database force logging;  
  28. Database altered.  
  29.  
  30. SQL> create tablespace tbs_ogg;  
  31. Tablespace created.  
  32.  
  33. SQL> create user ogg identified by ogg default tablespace tbs_ogg temporary tablespace temp account unlock;  
  34. User created.  
  35.  
  36. SQL> grant connect,resource,dba to ogg;  
  37. Grant succeeded 

备注: 在oracle中可以通过rowid来定位某条记录,但是目标端的数据库和源端数据库的数据库可能完全不一样,所以无法通过rowid来确定源端数据库的逻辑变化,这时附加日志supplemental log便登上了表演的舞台。数据库在开启附加日志功能后,对于源端的修改操作,oracle会同时追加能够唯一标示记录的列到redo log。这样目标端数据库就可以知道源端发生了哪些具体的变化。

三:安装ogg软件,启动mgr管理进程,source和target端做相同的操作


  1. [oracle@db1 ~]$ mkdir $GGATE   
  2. [oracle@db1 ~]$ cd $GGATE   
  3. [oracle@db1 ogg]$ tar -xvf /home/oracle/fbo_ggs_Linux_x64_ora10g_64bit.tar   
  4.  
  5. [oracle@db1 ogg]$ ./ggsci   
  6. GGSCI (db1) 1> create subdirs  
  7.  
  8. Creating subdirectories under current directory /u01/app/oracle/ogg  
  9.  
  10. Parameter files                /u01/app/oracle/ogg/dirprm: already exists  
  11. Report files                   /u01/app/oracle/ogg/dirrpt: created  
  12. Checkpoint files               /u01/app/oracle/ogg/dirchk: created  
  13. Process status files           /u01/app/oracle/ogg/dirpcs: created  
  14. SQL script files               /u01/app/oracle/ogg/dirsql: created  
  15. Database definitions files     /u01/app/oracle/ogg/dirdef: created  
  16. Extract data files             /u01/app/oracle/ogg/dirdat: created  
  17. Temporary files                /u01/app/oracle/ogg/dirtmp: created  
  18. Stdout files                   /u01/app/oracle/ogg/dirout: created  
  19.  
  20. GGSCI (db1) 2> edit params mgr  
  21.  
  22. GGSCI (db1) 3> view params mgr  
  23. PORT 7809  
  24.  
  25. GGSCI (db1) 4> start mgr  
  26. Manager started.  
  27.  
  28. GGSCI (db1) 5> info mgr  
  29. Manager is running (IP port db1.7809). 

四:准备测试用户和表


  1. SQL> conn /as sysdba  
  2. Connected.  
  3.  
  4. SQL> alter user hr identified by hr account unlock;  
  5. User altered.  
  6.  
  7. SQL> grant connect,resource,select_catalog_role to hr;  
  8. Grant succeeded.  
  9.  
  10. SQL> conn hr/hr  
  11. Connected.  
  12.  
  13. SQL> create table t1 as select * from dba_objects;  
  14. Table created.  
  15.  
  16. SQL> alter table t1 add constraint pk_t1 primary key(object_id);  
  17. Table altered.  
  18.  
  19. SQL> select count(*) from t1; //source端  
  20.  
  21.   COUNT(*)  
  22. ----------  
  23.      50315  
  24.  
  25. SQL> select count(*) from t1; //target端,只复制表定义,不填充数据  
  26.  
  27.   COUNT(*)  
  28. ----------  
  29.          0 

 五:初始化加载数据,在异构数据库平台(例如oracle-mysql),这个功能显得非常的有用!而在oracle-oracle的数据复制条件下,oracle推荐使用expdp/impdp工具

1.source端添加extract进程


  1. GGSCI (db1) 1> add extract einig1,sourceistable  //sourceistable代表直接从表中读取数据  
  2. EXTRACT added.  
  3.  
  4. GGSCI (db1) 2> edit params einig1 //einig1代表extract initial load group 1缩写  
  5.  
  6. GGSCI (db1) 3> view params einig1  
  7. extract einig1  
  8. setenv (NLS_LANG=AMERICAN_AMERICA.AL32UTF8)  
  9. userid ogg,password ogg  
  10. rmthost 192.168.123.20,mgrport 7809  
  11. rmttask replicat,group rinig1  
  12. table hr.t1; 

2.target端添加replicat进程


  1. GGSCI (db2) 1> add replicat rinig1,specialrun //specialrun代表只运行一次  
  2. REPLICAT added.  
  3.  
  4. GGSCI (db2) 2> edit params rinig1 //rinig1代表replicat initial load group 1缩写  
  5.  
  6. GGSCI (db2) 3> view params rinig1 //rinig1的名字必须同source端定义的group名字相同  
  7. replicat rinig1  
  8. setenv (NLS_LANG=AMERICAN_AMERICA.AL32UTF8)  
  9. assumetargetdefs  
  10. userid ogg,password ogg  
  11. discardfile ./dirrpt/rinig1.dsc,purge  
  12. map hr.*,target hr.*; 

3.source端启动extract进程,查看日志输出


  1. GGSCI (db1) 4> start extract einig1  
  2.  
  3. Sending START request to MANAGER ...  
  4. EXTRACT EINIG1 starting 

GGSCI (db1) 5> view report einig1

2012-06-20 09:40:55  INFO    OGG-01017  Wildcard resolution set to IMMEDIATE because SOURCEISTABLE is used.
***********************************************************************
                 Oracle GoldenGate Capture for Oracle
    Version 11.2.1.0.1 OGGCORE_11.2.1.0.1_PLATFORMS_120423.0230_FBO
   Linux, x64, 64bit (optimized), Oracle 10g on Apr 23 2012 07:44:10
 
Copyright (C) 1995, 2012, Oracle and/or its affiliates. All rights reserved.


                    Starting at 2012-06-20 09:40:55
***********************************************************************
Operating System Version:
Linux
Version #1 SMP Thu Sep 3 03:28:30 EDT 2009, Release 2.6.18-164.el5
Node: db1
Machine: x86_64
                         soft limit   hard limit
Address Space Size   :    unlimited    unlimited
Heap Size            :    unlimited    unlimited
File Size            :    unlimited    unlimited
CPU Time             :    unlimited    unlimited

 

Process id: 26185

Description:

***********************************************************************
**            Running with the following parameters                  **
***********************************************************************

2012-06-20 09:40:55  INFO    OGG-03035  Operating system character set identified as UTF-8. Locale: en_US, LC_ALL:
.
extract einig1
setenv (NLS_LANG=AMERICAN_AMERICA.AL32UTF8)
Set environment variable (NLS_LANG=AMERICAN_AMERICA.AL32UTF8)
userid ogg,password ***
rmthost 192.168.123.20,mgrport 7809
rmttask replicat,group rinig1
table hr.t1;
Using the following key columns for source table HR.T1: OBJECT_ID.

2012-06-20 09:40:59  INFO    OGG-01815  Virtual Memory Facilities for: COM
    anon alloc: mmap(MAP_ANON)  anon free: munmap
    file alloc: mmap(MAP_SHARED)  file free: munmap
    target directories:
    /u01/app/oracle/ogg/dirtmp.

CACHEMGR virtual memory values (may have been adjusted)
CACHESIZE:                               64G
CACHEPAGEOUTSIZE (normal):                8M
PROCESS VM AVAIL FROM OS (min):         128G
CACHESIZEMAX (strict force to disk):     96G

Database Version:
Oracle Database 10g Enterprise Edition Release 10.2.0.1.0 - 64bi
PL/SQL Release 10.2.0.1.0 - Production
CORE    10.2.0.1.0      Production
TNS for Linux: Version 10.2.0.1.0 - Production
NLSRTL Version 10.2.0.1.0 - Production

Database Language and Character Set:
NLS_LANG         = "AMERICAN_AMERICA.AL32UTF8" 
NLS_LANGUAGE     = "AMERICAN" 
NLS_TERRITORY    = "AMERICA" 
NLS_CHARACTERSET = "AL32UTF8"

Processing table HR.T1

***********************************************************************
*                   ** Run Time Statistics **                         *
***********************************************************************

Report at 2012-06-20 09:42:26 (activity since 2012-06-20 09:40:59)

Output to rinig1:

From Table HR.T1:
       #                   inserts:     50315
       #                   updates:         0
       #                   deletes:         0
       #                  discards:         0

REDO Log Statistics
  Bytes parsed                    0
  Bytes output             13168227

 4:target端验证


  1. [oracle@db2 ogg]$ sqlplus hr/hr  
  2. SQL> select count(*) from t1;  
  3.  
  4.   COUNT(*)  
  5. ----------  
  6.      50315 

六:配置db1,db2间的实时同步复制
1:在source上配置extract进程,进程的名字不能超过8个字符


  1. GGSCI (db1) 1> edit params eora_t1  
  2.  
  3. GGSCI (db1) 2> view params eora_t1  
  4. extract eora_t1  
  5. setenv (NLS_LANG=AMERICAN_AMERICA.AL32UTF8)  
  6. userid ogg,password ogg  
  7. exttrail ./dirdat/aa  
  8. table hr.*; 

  2:开启hr用户下所有表的附加日志 


  1. GGSCI (db1) 3> dblogin userid ogg, password ogg  
  2. Successfully logged into database.  
  3.  
  4. GGSCI (db1) 4> add trandata hr.* 

3:添加extract进程,添加trail文件,文件名前缀不能超过2个字符


  1. GGSCI (db1) 5> add extract eora_t1,tranlog,begin now  
  2. EXTRACT added.  
  3.  
  4. GGSCI (db1) 6> add exttrail ./dirdat/aa,extract eora_t1,megabytes 100 //添加trail文件  
  5. EXTTRAIL added.  
  6.  
  7. GGSCI (db1) 7> start extract eora_t1  
  8.  
  9. Sending START request to MANAGER ...  
  10. EXTRACT EORA_T1 starting  
  11.  
  12. GGSCI (db1) 8> info extract eora_t1  
  13.  
  14. EXTRACT    EORA_T1   Last Started 2012-06-20 10:06   Status RUNNING  
  15. Checkpoint Lag       00:00:00 (updated 00:00:02 ago)  
  16. Log Read Checkpoint  Oracle Redo Logs  
  17.                      2012-06-20 10:06:36  Seqno 3, RBA 21804544  
  18.                      SCN 0.562134 (562134)  
  19.  
  20. GGSCI (db1) 9> info all  
  21. Program     Status      Group       Lag at Chkpt  Time Since Chkpt  
  22.  
  23. MANAGER     RUNNING                                             
  24. EXTRACT     RUNNING     EORA_T1     00:08:24      00:00:05    

4:添加pump进程


  1. GGSCI (db1) 10> edit params pora_t1  
  2.  
  3. GGSCI (db1) 11> view params pora_t1  
  4. extract pora_t1  
  5. setenv (NLS_LANG=AMERICAN_AMERICA.AL32UTF8)  
  6. passthru  
  7. rmthost 192.168.123.20,mgrport 7809  
  8. rmttrail ./dirdat/pa  
  9. table hr.*;  
  10.  
  11. GGSCI (db1) 12> add extract pora_t1,exttrailsource ./dirdat/aa  //这里aa文件名同前面extract进程参数文件中定义的trail文件名一  
  12.  
  13. 致  
  14. EXTRACT added.  
  15.  
  16. GGSCI (db1) 13> add rmttrail ./dirdat/pa,extract pora_t1,megabytes 100 //添加传输到target数据库的trail问文件名,应该同参数文  
  17.  
  18. 件中描述的一致  
  19. RMTTRAIL added.  
  20.  
  21. GGSCI (db1) 14> start extract pora_t1  
  22. Sending START request to MANAGER ...  
  23. EXTRACT PORA_T1 starting  
  24.  
  25. GGSCI (db1) 15> info all  
  26. Program     Status      Group       Lag at Chkpt  Time Since Chkpt  
  27.  
  28. MANAGER     RUNNING                                             
  29. EXTRACT     RUNNING     EORA_T1     00:00:00      00:00:02      
  30. EXTRACT     RUNNING     PORA_T1     00:00:00      00:00:22    

4:在target端添加检查表,配置replicat进程


  1. GGSCI (db2) 1> edit params ./GLOBALS  
  2. GGSCI (db2) 2> view params ./GLOBALS  
  3. checkpointtable ogg.ggschkpt  
  4.  
  5. GGSCI (db2) 3> exit //这里需要退出ggsci终端  
  6. [oracle@db2 ~]$ sqlplus ogg/ogg  
  7. SQL> select tname from tab;  
  8. no rows selected  
  9.  
  10. [oracle@db2 ogg]$ ggsci   
  11. GGSCI (db2) 1> dblogin userid ogg,password ogg  
  12. Successfully logged into database.  
  13.  
  14. GGSCI (db2) 2> add checkpointtable  
  15. No checkpoint table specified, using GLOBALS specification (ogg.ggschkpt)...  
  16. Successfully created checkpoint table ogg.ggschkpt.  
  17.  
  18. SQL> select tname from tab;  
  19.  
  20. TNAME  
  21. ------------------------------  
  22. GGSCHKPT  
  23. GGSCHKPT_LOX  
  24.  
  25. GGSCI (db2) 3> edit params rora_t1  
  26. GGSCI (db2) 4> view params rora_t1  
  27. replicat rora_t1  
  28. setenv (NLS_LANG=AMERICAN_AMERICA.AL32UTF8)  
  29. userid ogg,password ogg  
  30. handlecollisions  
  31. assumetargetdefs  
  32. discardfile ./dirrpt/rora_t1.dsc,purge  
  33. map hr.* ,target hr.*;  
  34.  
  35. GGSCI (db2) 5> add replicat rora_t1,exttrail ./dirdat/pa  
  36. REPLICAT added.  
  37.  
  38. GGSCI (db2) 6> start replicat rora_t1  
  39.  
  40. Sending START request to MANAGER ...  
  41. REPLICAT RORA_T1 starting  
  42.  
  43. GGSCI (db2) 7> info replicat rora_t1  
  44. REPLICAT   RORA_T1   Last Started 2012-06-20 10:21   Status RUNNING  
  45. Checkpoint Lag       00:00:00 (updated 00:00:03 ago)  
  46. Log Read Checkpoint  File ./dirdat/t1000000  
  47.                      First Record  RBA 0  
  48.  
  49. GGSCI (db2) 8> info all  
  50. Program     Status      Group       Lag at Chkpt  Time Since Chkpt  
  51.  
  52. MANAGER     RUNNING                                             
  53. REPLICAT    RUNNING     RORA_T1     00:00:00      00:00:05     

备注:
在target端配置replicat进程之前,通常需要在目标端的数据库中创建一个checkpoint表,这个表是基于ogg checkpoint文件的,它记录了所有ogg可恢复的checkpoint以及sequence,这个操作不是必须的,但oracle强烈建议使用它,因为它可以使得checkpoint包含在replicat的事务中,保证了可以从各类失败场景中恢复!

七:测试同步
1:插入数据


  1. [oracle@db1 ogg]$ sqlplus hr/hr  
  2. SQL> desc t1  
  3.  Name                                      Null?    Type  
  4.  ----------------------------------------- -------- ----------------------------  
  5.  OWNER                                              VARCHAR2(30)  
  6.  OBJECT_NAME                                        VARCHAR2(128)  
  7.  SUBOBJECT_NAME                                     VARCHAR2(30)  
  8.  OBJECT_ID                                 NOT NULL NUMBER  
  9.  DATA_OBJECT_ID                                     NUMBER  
  10.  OBJECT_TYPE                                        VARCHAR2(19)  
  11.  CREATED                                            DATE  
  12.  LAST_DDL_TIME                                      DATE  
  13.  TIMESTAMP                                          VARCHAR2(19)  
  14.  STATUS                                             VARCHAR2(7)  
  15.  TEMPORARY                                          VARCHAR2(1)  
  16.  GENERATED                                          VARCHAR2(1)  
  17.  SECONDARY                                          VARCHAR2(1)  
  18.  
  19. SQL> select max(object_id) from t1;  
  20.  
  21. MAX(OBJECT_ID)  
  22. --------------  
  23.          52504  
  24.  
  25. SQL> insert into t1 (object_id,object_name) values (52505,'ogg_test');  
  26. 1 row created.  
  27.  
  28. SQL> commit;  
  29. Commit complete.  
  30.  
  31. SQL> conn hr/hr@db2  
  32. Connected.  
  33. SQL> select max(object_id) from t1;  
  34.  
  35. MAX(OBJECT_ID)  
  36. --------------  
  37.          52505 

2:抽取trail文件中可打印的内容分析


  1. [root@db1 dirdat]# pwd  
  2. /u01/app/oracle/ogg/dirdat  
  3. [root@db1 dirdat]# strings aa000000   
  4. uri:db1::u01:app:oracle:ogg6  
  5. ./dirdat/aa0000007  
  6. 564200  
  7. Linux1  
  8. db12  
  9. 2.6.18-164.el53  
  10. "#1 SMP Thu Sep 3 03:28:30 EDT 20094  
  11. x86_642  
  12. DB12  
  13. db13  
  14. Oracle Database 10g Enterprise Edition Release 10.2.0.1.0 - 64bi  
  15. PL/SQL Release 10.2.0.1.0 - Production  
  16. CORE    10.2.0.1.0      Production  
  17. TNS for Linux: Version 10.2.0.1.0 - Production  
  18. NLSRTL Version 10.2.0.1.0 - Production  
  19. EORA_T11  
  20. ?Version 11.2.1.0.1 OGGCORE_11.2.1.0.1_PLATFORMS_120423.0230_FBO4  
  21. HR.T1  
  22. ogg_test  
  23. 52505  
  24. 1900-01-01:00:00:00  
  25. 1900-01-01:00:00:00  
  26. AAAM0YAAEAAAARlAAA  
  27. 5642006  
  28. 2.46.299Z  
  29.  
  30. [root@db2 dirdat]# pwd  
  31. /u01/app/oracle/ogg/dirdat  
  32. [root@db2 dirdat]# strings pa000000   
  33. uri:db1::u01:app:oracle:ogg5  
  34. uri:db1::u01:app:oracle:ogg6  
  35. ./dirdat/pa0000007  
  36. Linux1  
  37. db12  
  38. 2.6.18-164.el53  
  39. "#1 SMP Thu Sep 3 03:28:30 EDT 20094  
  40. x86_642  
  41. DB12  
  42. db13  
  43. Oracle Database 10g Enterprise Edition Release 10.2.0.1.0 - 64bi  
  44. PL/SQL Release 10.2.0.1.0 - Production  
  45. CORE    10.2.0.1.0      Production  
  46. TNS for Linux: Version 10.2.0.1.0 - Production  
  47. NLSRTL Version 10.2.0.1.0 - Production  
  48. EORA_T11  
  49. ?Version 11.2.1.0.1 OGGCORE_11.2.1.0.1_PLATFORMS_120423.0230_FBO4  
  50. HR.T1  
  51. ogg_test  
  52. 52505  
  53. 1900-01-01:00:00:00  
  54. 1900-01-01:00:00:00  
  55. AAAM0YAAEAAAARlAAA  
  56. 5642006  
  57. 2.46.299Z 

3:删除测试


  1. SQL> conn hr/hr  
  2. Connected.  
  3. SQL> delete from t1 where object_id > 1000;  
  4. 49362 rows deleted.  
  5.  
  6. SQL> commit;  
  7. Commit complete  
  8.  
  9. SQL> select max(object_id) from t1;  
  10.  
  11. MAX(OBJECT_ID)  
  12. --------------  
  13.           1000  
  14.  
  15. SQL> conn hr/hr@db2  
  16. Connected.  
  17. SQL> select max(object_id) from t1;  
  18.  
  19. MAX(OBJECT_ID)  
  20. --------------  
  21.           1000 

本文的配置中不涉及ddl操作的复制,这部分内容将在后续的文章中进行介绍!

本文转自斩月博客51CTO博客,原文链接http://blog.51cto.com/ylw6006/903752如需转载请自行联系原作者


ylw6006

网友评论

登录后评论
0/500
评论
科技探索者
+ 关注