在一個典型的分布式商業應用中經常需要把個地區的數據備份到總部的數據庫中，一方面可以作為一種備份方式，另一方面也方便總部應用中的綜合統計。這是Oracle數據復制中的簡單應用，本文將以這樣一個例子，講述如何實現Oracle數據復制。
實際情況是，A公司總部在北京，有三個營業部分別位於上海(ORACLE.SHANGHAI.COM)、杭州(ORACLE.HANGZHOU.COM)和武漢(Oracle.
WUHAN.COM)。三個營業部的軟件系統相同，數據庫結構也相同。現在需要把三個營業部的數據全部備份到總部的數據庫中。
准備工作
在進行復制之前需要准備的東西很多，當然最基礎就是網絡必須暢通，之後需要收集一些復制環境的基本信息：
1．需要復制的數據庫站點的數量
2．每個站點的Oracle版本號
3．每個需要復制的數據庫的大小
4．每個數據庫所使用的字符集
5．每個需要復制的數據所用的方案名
收集完環境信息，可以開始建立總部的集中數據庫，集中數據庫要求版本高於所有主戰點的版本，最好所有的數據庫都是用相同的字符集。建好庫後為每個主站點的備份數據分別建一個表空間，表空間大於需要復制的數據量，至於預留以後的發展空間視實際情況而定。
為每個主站點的對應復制數據建立方案，如果各個主站點所使用的方案名不同，在集中數據庫站點分別建立名稱相同的對應方案。否則為各主站點的復制數據分別建立相應的方案名。實際情況是後者，各營業部的數據庫都是用Oracle的方案名，這裡我們建立三個對應方
案：SHORACL、HZORACL和WHORACL。所有數據庫的版本都是9i。
基本概念
復制之前先解釋一下復制中的幾個概念：
1．主站點（MaterSite）：在復制過程中提供數據源的站點。如上圖中的上海數據庫站點。
2．實體化視圖站點（MaterializedVIEwSite）：實體化視圖復制中的目標站點。如上圖中的北京數據庫站點。
3．多主體站點復制（MultimasterReplication）：復制環境中的站點都是主站點，對復制的數據庫對象有相同的管理權限。
4．實體化視圖復制（MaterializedVIEwReplication）：一個主體站點提供源復制對象，一個實體化視圖站點拷貝主站點數據。
5．實體化視圖（MaterializedVIEw）：在實體化視圖站點為每個復制表或者視圖建立一個對應的表保存相應的數據，該表只能通過Oracle的復制機制進行增刪改數據的操作。
6．快速刷新、完全刷新和強制刷新：復制過程中的三種刷新方式。快速刷新只復制源數據對象的改變部分；完全刷新每次都拷貝一遍源數據對象；強制刷新是數據庫的一個折衷方案，如果快速刷新失敗則使用完全刷新。
7．主體組（MasterGroup）：主體站點中被復制的源數據對象的集合。
8．實體化視圖組（MaterializedVIEwSite）：實體化視圖站點中復制對象的集合。
9．實體化視圖日志（MaterializedVIEwLog）：實體化視圖復制中使用快速刷新時記錄主體源數據對象操作日志的表。
同步復制和異步復制就不解釋了，本例采用每天一次的異步復制。
進行復制
配置好本地服務名分別為：上海站點：SH，杭州站點：HZ，武漢站點：WH，北京站點：BJ，進入沒有登錄的sqlplus，讓我們開始復制！
一．設置主站點。
這裡以上海主站點設置為例。
1．連接主站點，創建復制管理員並授予相應的權限，復制管理員是管理整個復制環境並創建復制對象的用戶。只有數據管理員可以建立主體組和實體化視圖組。
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．調度清除作業，該作業會定時清除延遲事務隊列並用傳播方將延遲事務推入其他主體站點或者實體化視圖站點。先更換用戶：
disconnect;
connectrepadmin/repadmin@SH;
begin
dbms_defer_sys.schedule_purge(
next_date=>sysdate,interval=>’sysdate+1’,delay_seconds=>0);
end;
next_date：下一次執行日期，sysdate表示立即。
interval：間隔時段，sysdate+1表示間隔一天，sysdate+1/24表示間隔一小時
delay_seconds：當延遲隊列沒有延遲事件時停止被次清除操作的延遲時間。
4．為實體化視圖站點建立復制代理。創建復制代理用戶並授予視圖接受方權限。復制代理是復制接收方連接主體站點的用戶
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．創建主體組。
disconnect;6．向主體組中添加復制對象
connectrepadmin/repadmin@SH;
begin
dbms_repcat.create_master_repgroup(gname=>’sh_rep’);
end;
/
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．在主體組中的數據對象可以被復制之前，必須為他們生成復制支持。該方法為復制創建必要的觸發器、包或者存儲過程：
begin
dbms_repcat.generate_replication_support(
sname=>’SHORACL’,
oname=>’CREDIT_CARD’,
type=>’TABLE’,
min_communication=>TRUE);
end;
/
9．為快速刷新創建實體化視圖日志：
creatematerializedvIEwlogonSHORACL.CREDIT_CARD;
如果是沒有主鍵的表示用一下語句：
creatematerializedvIEwlogonSHORACL.CREDIT_CARDwith
rowidexcludingnewvalues;
10．啟動復制：
begin二．設置實體化視圖站點。
dbms_repcat.resume_master_activity(
name=>’sh_rep’);
end;
/
1．創建復制管理員並授予相應的權限：
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．公共數據庫連接。需要每個復制需要創建三個數據庫連接。公共數據庫連接指定數據庫的全局名稱：
createpublicdatabaselinkORACLSHusing’Oracle.shanghai.
com’;
Using子句後跟的是全局數據庫名或者是連接字符串。
createpublicdatabaselinkORACLSHusing’(description=
(address=(protocol=tcp)(host=127.0.0.1)(port=1521))
(connect_data=(service_name=oracl)))’
4．建立清除延遲事務隊列調度作業：
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的數據庫連接：
createdatabaselinkORACLSHconnecttoproxy_bjOracle
identifIEdbyproxy_bjoralce
Connectto...IdentifIEdby...子句指明用什麼用戶連接遠程數據庫
6．建立復制調度數據庫連接作業：
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方案）
相應的權限建立實體化視圖：
disconnect;
connectsystem/passwd@BJ;
grantaltersessiontocrm;
grantcreateclustertocrm;
grantcreatedatabaselinktocrm;
grantcreatesequencetocrm;
grantcreatesessiontocrm;
grantcreatesynonymtocrm;
grantcreatetabletocrm;
grantcreatevIEwtocrm;
grantcreateproceduretocrm;
grantcreatetriggertocrm;
grantunlimitedtablespacetocrm;
grantcreatetypetocrm;
grantcreateanysnapshottocrm;
grantalteranysnapshottocrm;
8．建立復制方案的數據庫連接：
disconnect;
connectSHORACL/SHORACL@BJ;
createdatabaselinkORACLSHconnecttoORACLidentifIEd
byORACL;
復制方案的數據庫連接和復制管理員的數據庫連接要和system用戶間裡的對應公共數據庫連接使用相同的名字，在調度連接時將使用公共數據庫連接中指定的數據庫全局名或者連接字符串。
9．建立實體化視圖：
disconnect;
connectmvadmin/mvadmin@BJ;
creatematerializedvIEwSHORACL.CREDIT_CARDrefreshfast
withprimarykeyasselect*fromORACL.
CREDIT_CARD@ORACLSH;
@後面是數據庫連接名。如果該表沒有主鍵則使用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;
