eygle.com   eygle.com
eygle.com eygle
eygle.com  
 

« Oracle基于时间点的恢复 | Blog首页 | 关于Oracle的冲突解决机制的研究 »

使用dbms_rectifier_diff解决高级复制中的数据冲突问题

很多时候在高级复制中可能存在数据冲突和不一致现象。
Oracle提供的dbms_rectifier_diff包可以用于解决该冲突。

以下通过实例来说明一下该Package的用法。

1.创建复制组及复制对象
SQL> execute dbms_repcat.create_master_repgroup('rep_tt');
PL/SQL procedure successfully completed
SQL> select gname,master,status from dba_repgroup;
GNAME                          MASTER STATUS
------------------------------ ------ ---------
REP_TT                         Y      QUIESCED

SQL> execute dbms_repcat.create_master_repobject(sname=>'hawa',
oname=>'test', type=>'table',use_existing_object=>true,
gname=>'rep_tt',copy_rows=>false);

PL/SQL procedure successfully completed

SQL> 
SQL> execute dbms_repcat.generate_replication_support('hawa','test','table');

PL/SQL procedure successfully completed

SQL> select gname, master, status from dba_repgroup;

GNAME                          MASTER STATUS
------------------------------ ------ ---------
REP_TT                         Y      QUIESCED

SQL> select * from dba_repobject;

SNAME     ONAME     TYPE             STATUS     GENERATION_STATUS         ID OBJECT_COMMENT    GNAME     
------------------------------ ------------------------------ ---------------- ---------- ---------------
HAWA      TEST      TABLE            VALID      GENERATED               8620                   REP_TT    
HAWA      TEST$RP   PACKAGE          VALID         8641 SYSTEM-GENERATED: REPLICATION          REP_TT    
HAWA      TEST$RP   PACKAGE BODY     VALID         8677 SYSTEM-GENERATED: REPLICATION          REP_TT    

3 rows selected

SQL> 
SQL> execute dbms_repcat.add_master_database(gname=>'rep_tt',
master=>'AUTHAA.COOLYOUNG.COM.CN',
use_existing_objects=>true, copy_rows=>false, 
propagation_mode => 'synchronous');

PL/SQL procedure successfully completed


SQL> execute dbms_repcat.resume_master_activity('rep_tt',true);

PL/SQL procedure successfully completed

SQL> select * from dba_repgroup;

SNAME     MASTER STATUS    SCHEMA_COMMENT    GNAME     FNAME     RPC_PROCESSING_DISABLED OWNER
-------- ------------------ ---- ------ ---- ---- -----------------------------------------------
REP_TT    Y      NORMAL                      REP_TT              N  PUBLIC

2.创建保存冲突数据的数据表

a.missing_rows表用以保存冲突行
SQL> create table hawa.missing_rows_test
  2  as
  3  select * from hawa.test where 1=0;

Table created

b.用于保存缺失行位置及rowid
SQL> create table hawa.MISSING_LOCATION_TEST (
  2  present VARCHAR2(128),
  3  absent VARCHAR2(128),
  4  r_id ROWID);

Table created

3.使用dbms_rectifier_diff.DIFFERENCES查找缺失记录
SQL> begin dbms_rectifier_diff.DIFFERENCES(
  2  SNAME1    		         =>'HAWA',
  3  ONAME1                         =>'TEST',
  4  REFERENCE_SITE                 =>'AVATAR.COOLYOUNG.COM.CN',
  5  SNAME2                         =>'HAWA',
  6  ONAME2                         =>'TEST',
  7  COMPARISON_SITE                =>'AUTHAA.COOLYOUNG.COM.CN',
  8  WHERE_CLAUSE                   =>NULL,
  9  COLUMN_LIST                    =>NULL,
 10  MISSING_ROWS_SNAME             =>'HAWA',
 11  MISSING_ROWS_ONAME1            =>'MISSING_ROWS_TEST',
 12  MISSING_ROWS_ONAME2            =>'MISSING_LOCATION_TEST',
 13  MISSING_ROWS_SITE              =>'AVATAR.COOLYOUNG.COM.CN',
 14  MAX_MISSING                    =>500,
 15  COMMIT_ROWS                    =>100
 16  );
 17  end;
 18  /
PL/SQL procedure successfully completed

冲突记录被保存在我们创建的指定表中
SQL> select count(*) from hawa.missing_rows_test;

  COUNT(*)
----------
       172

共有172条差异记录
SQL> select count(*) from hawa.test;

  COUNT(*)
----------
       548

SQL> select count(*) from hawa.test@authaa;

  COUNT(*)
----------
       376

SQL> select count(*) from hawa.missing_location_test;

  COUNT(*)
----------
       172

4.使用DBMS_RECTIFIER_DIFF.RECTIFY进行数据整合

首先需要注意的是:
RECTIFY过程使用DIFFERENCES产生的数据进行数据调整。
在第一个表中存在,在第二个表中不存在的数据将被插入第二张表。
在第二个表中存在,在第一个个表中不存在的数据将被从第二张表中删除。

另外,在这个数据纠正过程中,你可以使用dbms_repcat.suspend_master_activity将复制组暂时挂起。
这样便于保证数据完整性。
但这不是必须的,如果复制一直激活,可能会有新的冲突出现。
SQL> BEGIN DBMS_RECTIFIER_DIFF.RECTIFY(
  2  SNAME1                         =>'HAWA',
  3  ONAME1                         =>'TEST',
  4  REFERENCE_SITE                 =>'AVATAR.COOLYOUNG.COM.CN',
  5  SNAME2                         =>'HAWA',
  6  ONAME2                         =>'TEST',
  7  COMPARISON_SITE                =>'AUTHAA.COOLYOUNG.COM.CN',
  8  COLUMN_LIST                    =>NULL,
  9  MISSING_ROWS_SNAME             =>'HAWA',
 10  MISSING_ROWS_ONAME1            =>'MISSING_ROWS_TEST',
 11  MISSING_ROWS_ONAME2            =>'MISSING_LOCATION_TEST',
 12  MISSING_ROWS_SITE              =>'AVATAR.COOLYOUNG.COM.CN',
 13  COMMIT_ROWS                    =>100
 14  );
 15  END;
 16  /
PL/SQL procedure successfully completed
SQL> select count(*) from hawa.test@authaa;
  COUNT(*)
----------
       548
SQL> select count(*) from hawa.test;
  COUNT(*)
----------
       548
数据矫正完成以后,数据会自动从missing_rows表中删除。
SQL> select count(*) from hawa.missing_rows_test;

  COUNT(*)
----------
         0

SQL> 

历史上的今天...
    >> 2012-01-19文章:
    >> 2009-01-19文章:
    >> 2008-01-19文章:
    >> 2007-01-19文章:
    >> 2006-01-19文章:
           Oracle10gR2 ASM 值得信赖么?

无觅

By eygle on 2005-01-19 15:26 | Comments (2) | Advanced | 155 |

2 Comments

你说得比较简单,如果你能将lob 等特殊处理问题实验一下,你会有更有价值的发现...

能对lob字段的特殊处理分析一下吗?或者有没有其他的解决方案?


CopyRight © 2004~2020 云和恩墨,成就未来!, All rights reserved.
数据恢复·紧急救援·性能优化 云和恩墨 24x7 热线电话:400-600-8755 业务咨询:010-59007017-7040 or 7037 业务合作: marketing@enmotech.com