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

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

作者:eygle

出处:http://blog.eygle.com

日期:January 19, 2005

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


很多时候在高级复制中可能存在数据冲突和不一致现象。 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 MIN_COMMUNICATION REPLICATION_TRIGGER_EXISTS INTERNAL_PACKAGE_EXISTS GROUP_OWNER NESTED_TABLE ------------------------------ ------------------------------ ---------------- ---------- ----------------- ---------- -------------------------------------------------------------------------------- ----------------- HAWA TEST TABLE VALID GENERATED 8620 REP_TT Y Y Y PUBLIC N HAWA TEST$RP PACKAGE VALID 8641 SYSTEM-GENERATED: REPLICATION REP_TT PUBLIC HAWA TEST$RP PACKAGE BODY VALID 8677 SYSTEM-GENERATED: REPLICATION REP_TT PUBLIC

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>

<SCRIPT src="http://pagead2.googlesyndication.com/pagead/show_ads.js" type=text/javascript> </SCRIPT>

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏杨建荣的学习笔记

生产环境sql语句调优实战第四篇(r2笔记41天)

生产中有一条sql语句消耗了大量的cpu资源,执行时间在18秒左右, Session:PRODBUSER (1560:61133)SQL ID:1hg2wcua...

21750
来自专栏杨建荣的学习笔记

一条简单的sql在11g和12c中的不同(r5笔记第2天)

今天在查看awr报告的时候,有一句很简单的sql语句引起了我的注意,因为它排在SQL Order by Reads的第2位。 Physical ReadsExe...

36040
来自专栏杨建荣的学习笔记

关于desc的一个奇怪问题及分析(r2第18天)

在平时的工作中,desc这个命令可谓短小精悍,可以很方便的查看表结构和not null的情况。 今天在生产环境中碰到一个有些奇怪的desc问题。 首先是数据迁移...

28550
来自专栏杨建荣的学习笔记

关于oracle中的反连接(r3笔记第95天)

在之前的章节中见到讨论过oracle中的半连接 http://blog.itpub.net/23718752/viewspace-1334483/ 与半连接相对...

22670
来自专栏杨建荣的学习笔记

关于统计信息过期的性能落差(r5笔记第36天)

今天客户反馈某一个应用部署补丁的时候,执行了一个脚本一个多小时还没有执行完。 语句是下面这样的形式。 insert into em1_rater_00068_0...

42360
来自专栏乐沙弥的世界

ORA-06502 assigning values from SQL to PL/SQL variables

    最近SQL查询返回的结果给PL/SQL变量出现ORA-06502错误。这个错误的描述是ORA-06502: PL/SQL: numeric or val...

7310
来自专栏乐沙弥的世界

Oracle 监控索引的使用率

    Oracle提供了索引监控特性来判断索引是否被使用。在Oracle 10g中,收集统计信息会使得索引被监控,在Oracle 11g中该现象不复存在。尽管...

20130
来自专栏Ryan Miao

oracle创建表相关

1 --创建表 2 create table person( 3 id number primary key, 4 name varchar2(40),...

26950
来自专栏数据和云

突破常识:SQL增加DISTINCT后查询效率反而提高

杨廷琨,网名 yangtingkun 云和恩墨技术总监,Oracle ACE Director,ACOUG 核心专家 只要增加了DISTINCT关键字,Orac...

38060
来自专栏沃趣科技

语句效率统计视图 | 全方位认识 sys 系统库

在上一篇《统计信息查询视图|全方位认识 sys 系统库》中,我们介绍了利用sys 系统库的查询统计信息的快捷视图,本期将为大家介绍语句查询效率语句统计信息相关的...

26650

扫码关注云+社区

领取腾讯云代金券