Oracle數(shù)據(jù)復制是實現(xiàn)分布式數(shù)據(jù)環(huán)境的一種技術(shù)，通過在不同的物理站點拷貝數(shù)據(jù)來建立分布式數(shù)據(jù)環(huán)境。它與分布式數(shù)據(jù)庫不同，在分布式數(shù)據(jù)庫中，雖然每個數(shù)據(jù)對象也對所有的站點可用，但是特定的數(shù)據(jù)對象只存在于一個特定的站點中。而數(shù)據(jù)復制實現(xiàn)所有的站點都有相同數(shù)據(jù)對象的可用拷貝。

在一個典型的分布式商業(yè)應用中經(jīng)常需要把個地區(qū)的數(shù)據(jù)備份到總部的數(shù)據(jù)庫中，一方面可以作為一種備份方式，另一方面也方便總部應用中的綜合統(tǒng)計。這是Oracle數(shù)據(jù)復制中的簡單應用，本文將以這樣一個例子，講述如何實現(xiàn)Oracle數(shù)據(jù)復制。

實際情況是，A公司總部在北京，有三個營業(yè)部分別位于上海(ORACLE.SHANGHAI.COM)、杭州(ORACLE.HANGZHOU.COM)和武漢(ORACLE.

WUHAN.COM)。三個營業(yè)部的軟件系統(tǒng)相同，數(shù)據(jù)庫結(jié)構(gòu)也相同?，F(xiàn)在需要把三個營業(yè)部的數(shù)據(jù)全部備份到總部的數(shù)據(jù)庫中。

準備工作

在進行復制之前需要準備的東西很多，當然最基礎就是網(wǎng)絡必須暢通，之后需要收集一些復制環(huán)境的基本信息：

1．需要復制的數(shù)據(jù)庫站點的數(shù)量

2．每個站點的Oracle版本號

3．每個需要復制的數(shù)據(jù)庫的大小

4．每個數(shù)據(jù)庫所使用的字符集

5．每個需要復制的數(shù)據(jù)所用的方案名

收集完環(huán)境信息，可以開始建立總部的集中數(shù)據(jù)庫，集中數(shù)據(jù)庫要求版本高于所有主戰(zhàn)點的版本，最好所有的數(shù)據(jù)庫都是用相同的字符集。建好庫后為每個主站點的備份數(shù)據(jù)分別建一個表空間，表空間大于需要復制的數(shù)據(jù)量，至于預留以后的發(fā)展空間視實際情況而定。

為每個主站點的對應復制數(shù)據(jù)建立方案，如果各個主站點所使用的方案名不同，在集中數(shù)據(jù)庫站點分別建立名稱相同的對應方案。否則為各主站點的復制數(shù)據(jù)分別建立相應的方案名。實際情況是后者，各營業(yè)部的數(shù)據(jù)庫都是用Oracle的方案名，這里我們建立三個對應方

案：SHORACL、HZORACL和WHORACL。所有數(shù)據(jù)庫的版本都是9i。

基本概念

復制之前先解釋一下復制中的幾個概念：

1．主站點（MaterSite）：在復制過程中提供數(shù)據(jù)源的站點。如上圖中的上海數(shù)據(jù)庫站點。

2．實體化視圖站點（MaterializedViewSite）：實體化視圖復制中的目標站點。如上圖中的北京數(shù)據(jù)庫站點。

3．多主體站點復制（MultimasterReplication）：復制環(huán)境中的站點都是主站點，對復制的數(shù)據(jù)庫對象有相同的管理權(quán)限。

4．實體化視圖復制（MaterializedViewReplication）：一個主體站點提供源復制對象，一個實體化視圖站點拷貝主站點數(shù)據(jù)。

5．實體化視圖（MaterializedView）：在實體化視圖站點為每個復制表或者視圖建立一個對應的表保存相應的數(shù)據(jù)，該表只能通過Oracle的復制機制進行增刪改數(shù)據(jù)的操作。

6．快速刷新、完全刷新和強制刷新：復制過程中的三種刷新方式?？焖偎⑿轮粡椭圃磾?shù)據(jù)對象的改變部分；完全刷新每次都拷貝一遍源數(shù)據(jù)對象；強制刷新是數(shù)據(jù)庫的一個折衷方案，如果快速刷新失敗則使用完全刷新。

7．主體組（MasterGroup）：主體站點中被復制的源數(shù)據(jù)對象的集合。

8．實體化視圖組（MaterializedViewSite）：實體化視圖站點中復制對象的集合。

9．實體化視圖日志（MaterializedViewLog）：實體化視圖復制中使用快速刷新時記錄主體源數(shù)據(jù)對象操作日志的表。

同步復制和異步復制就不解釋了，本例采用每天一次的異步復制。

進行復制

配置好本地服務名分別為：上海站點：SH，杭州站點：HZ，武漢站點：WH，北京站點：BJ，進入沒有登錄的sqlplus，讓我們開始復制！

一．設置主站點。

這里以上海主站點設置為例。

1．連接主站點，創(chuàng)建復制管理員并授予相應的權(quán)限，復制管理員是管理整個復制環(huán)境并創(chuàng)建復制對象的用戶。只有數(shù)據(jù)管理員可以建立主體組和實體化視圖組。

connectsystem/passwd@SH

createuserrepadminidentifiedbyrepadmin;

begin

dbms_repcat_admin.grant_admin_any_schema(

username=>’repadmin’);

end;

/

grantcommentanytabletoREPADMIN;

grantlockanytabletoREPADMIN;

后面的兩個grant語句使復制管理員可以為任何表建立實體化視圖日志。如果想改用戶可以使用視圖管理器，還需要下面的命令：

grantselectanydictionarytoREPADMIN;

2．注冊傳播方，傳播方會將主體站點的延遲事務隊列推入其他主體站點或者實體化視圖站點。

begin

dbms_defer_sys.register_purpagator(username=>’repadmin’);

end;

3．調(diào)度清除作業(yè)，該作業(yè)會定時清除延遲事務隊列并用傳播方將延遲事務推入其他主體站點或者實體化視圖站點。先更換用戶：

disconnect;

connectrepadmin/repadmin@SH;

begin

dbms_defer_sys.schedule_purge(

next_date=>sysdate,interval=>’sysdate+1’,delay_seconds=>0);

end;

next_date：下一次執(zhí)行日期，sysdate表示立即。

interval：間隔時段，sysdate+1表示間隔一天，sysdate+1/24表示間隔一小時

delay_seconds：當延遲隊列沒有延遲事件時停止被次清除操作的延遲時間。

4．為實體化視圖站點建立復制代理。創(chuàng)建復制代理用戶并授予視圖接受方權(quán)限。復制代理是復制接收方連接主體站點的用戶

disconnect;

connectsystem/passwd@SH;

createuserproxy_bjoracleidentifiedbyproxy_bjoracle;

begin

dbms_repcat_admin.register_user_repgroup(

user_name=>’proxy_bjoracle,

privilege_type=>’proxy_snapadmin’,list_of_gnames=>NULL);

end;

/

grantselect_catalog_roletoproxy_bjoracle;

5．創(chuàng)建主體組。

disconnect;

connectrepadmin/repadmin@SH;

begin

dbms_repcat.create_master_repgroup(gname=>’sh_rep’);

end;

/

6．向主體組中添加復制對象

a)添加表：

begin

dbms_repcat.create_master_repobject(

gname=>’sh_rep’,

type=>’TABLE’,

oname=>’CREDIT_CARD’

sname=>’SHORACL’

use_existing_object=>TRUE,

copy_rows=>TRUE);

end;

b)添加索引

begin

dbms_repcat.create_master_repobject(

gname=>’sh_rep’,

type=>’INDEX’,

oname=>’INDEX_CREDIT_CARD’

sname=>’SHORACL’

use_existing_object=>TRUE,

copy_rows=>FALSE);

end;

/

7．如果添加的表沒有主鍵需要設置可以代替主鍵的列或者列的集合

begin

dbms_repcat.set_columns(

sname=>’SHORACL’,

oname=>’CREDIT_CARD’,

column_list=>’CREDIT_CARD_ID’);

end;

/

8．在主體組中的數(shù)據(jù)對象可以被復制之前，必須為他們生成復制支持。該方法為復制創(chuàng)建必要的觸發(fā)器、包或者存儲過程：

begin

dbms_repcat.generate_replication_support(

sname=>’SHORACL’,

oname=>’CREDIT_CARD’,

type=>’TABLE’,

min_communication=>TRUE);

end;

/

9．為快速刷新創(chuàng)建實體化視圖日志：

creatematerializedviewlogonSHORACL.CREDIT_CARD;

如果是沒有主鍵的表示用一下語句：

creatematerializedviewlogonSHORACL.CREDIT_CARDwith

rowidexcludingnewvalues;

10．啟動復制：

begin

dbms_repcat.resume_master_activity(

name=>’sh_rep’);

end;

/

二．設置實體化視圖站點。

1．創(chuàng)建復制管理員并授予相應的權(quán)限：

disconnect;

connectsystem/passwd@BJ;

createusermvadminidentifiedby

mvadmin;

begin

dbms_repcat_admin.

grant_admin_any_schema(username=>’mvadmin’);

end;

/

grantcommentanytabletomvadmin;

grantlockanytabletomvadmin;

grantselectanydictionarytomvadmin;

2．注冊傳播方：

begin

dbms_defer_sys.register_propagator(

username=>’mvadmin’);

end;

/

3．公共數(shù)據(jù)庫連接。需要每個復制需要創(chuàng)建三個數(shù)據(jù)庫連接。公共數(shù)據(jù)庫連接指定數(shù)據(jù)庫的全局名稱：

createpublicdatabaselinkORACLSHusing’oracle.shanghai.

com’;

Using子句后跟的是全局數(shù)據(jù)庫名或者是連接字符串。

createpublicdatabaselinkORACLSHusing’(description=

(address=(protocol=tcp)(host=127.0.0.1)(port=1521))

(connect_data=(service_name=oracl)))’

4．建立清除延遲事務隊列調(diào)度作業(yè)：

disconnect;

connectmvadmin/mvadmin@BJ;

begin

dbms_defer_sys.schedule_purge(

next_date=>sysdate,

interval=>’/*1:hr*/sysdate+1’,

delay_seconds=>0,

rollback_segment=>’’);

end;

5．建立復制管理員mvadmin的數(shù)據(jù)庫連接：

createdatabaselinkORACLSHconnecttoproxy_bjoracle

identifiedbyproxy_bjoralce

Connectto...Identifiedby...子句指明用什么用戶連接遠程數(shù)據(jù)庫

6．建立復制調(diào)度數(shù)據(jù)庫連接作業(yè)：

begin

dbms_defer_sys.schedule_push(

destination=>’ora92zjk’,interval=>’/*1:hr*/sysdate+1’,

next_date=>sysdate,stop_on_error=>false,

delay_seconds=>0,parallelism=>0);

end;

/

7．授予SHORACL用戶（對應SHORACL方案）

相應的權(quán)限建立實體化視圖：

disconnect;

connectsystem/passwd@BJ;

grantaltersessiontocrm;

grantcreateclustertocrm;

grantcreatedatabaselinktocrm;

grantcreatesequencetocrm;

grantcreatesessiontocrm;

grantcreatesynonymtocrm;

grantcreatetabletocrm;

grantcreateviewtocrm;

grantcreateproceduretocrm;

grantcreatetriggertocrm;

grantunlimitedtablespacetocrm;

grantcreatetypetocrm;

grantcreateanysnapshottocrm;

grantalteranysnapshottocrm;

8．建立復制方案的數(shù)據(jù)庫連接：

disconnect;

connectSHORACL/SHORACL@BJ;

createdatabaselinkORACLSHconnecttoORACLidentified

byORACL;

復制方案的數(shù)據(jù)庫連接和復制管理員的數(shù)據(jù)庫連接要和system用戶間里的對應公共數(shù)據(jù)庫連接使用相同的名字，在調(diào)度連接時將使用公共數(shù)據(jù)庫連接中指定的數(shù)據(jù)庫全局名或者連接字符串。

9．建立實體化視圖：

disconnect;

connectmvadmin/mvadmin@BJ;

creatematerializedviewSHORACL.CREDIT_CARDrefreshfast

withprimarykeyasselect*fromORACL.

CREDIT_CARD@ORACLSH;

@后面是數(shù)據(jù)庫連接名。如果該表沒有主鍵則使用rowid來刷新

creatematerializedviewSHORACL.CREDIT_CARDrefresh

fastwithrowidasselect*fromORACL.CREDIT_CARD@ORACLSH;

10．為多個視圖建立刷新組：

begin

dbms_refresh.make(

name=>’mvadmin.sh_refresh’,list=>’’,

next_date=>sysdate,interval=>’sysdate+1’,

implicit_destroy=>false,rollback_seg=>’’,

push_deferred_rpc=>true,refresh_after_errors=>false);

end;

更多信息請查看IT技術(shù)專欄