我們經常希望把各地的數據入庫後進行統一的應用。現在可以用復制技術來解決這個問題。但實現數據庫復制也是要有一些條件的。
首先，數據庫要具備高級復制功能（用system身份登錄數據庫，查看v$option視圖，如果其中Advanced replication為TRUE，則支持高級復制功能；否則不支持）。
如果具備高級復制功能，數據庫要進行一些參數初始化。
db_domain = test.com.cn 指明數據庫的域名(默認的是WORLD)，這裡可以用您公司的域名；global_names = true 它要求數據庫鏈接(database link)和被連接的數據庫名稱一致，現在全局數據庫名：db_name+”.”+db_domain ；
跟數據庫job執行有關的參數：
job_queue_processes = 1；
job_queue_interval = 60；
distributed_transactions = 10；
open_links = 4
第一行定義SNP進程的啟動個數為n。系統缺省值為0，正常定義范圍為0～36，根據任務的多少，可以配置不同的數值。第二行定義系統每隔N秒喚醒該進程一次。系統缺省值為60秒，正常范圍為1～3600秒。事實上，該進程執行完當前任務後，就進入睡眠狀態，睡眠一段時間後，由系統的總控負責將其喚醒。如果修改了以上這幾個參數，需要重新啟動數據庫以使參數生效。
做完了初步的准備，我們來實現數據庫同步復制。
假設在Internet上有兩個數據庫：一個叫中國(China)，一個叫日本(Japan)。
具體配置如下：
數據庫名：China、Japan
數據庫域名 test.com.cn
數據庫sid號 China、Japan
Listener端口號 1521
服務器ip地址 10.1.0.100 10.1.0.200
確認兩個數據庫之間可以互相訪問，在tnsnames.ora裡設置數據庫連接字符串。
中國這邊的數據庫連接字符串是以下的格式：
Japan =
(DESCRIPTION =
(ADDRESS_LIST =
(ADDRESS = (PROTOCOL = TCP)(HOST = 10.1.1.200)(PORT = 1521))
)
(CONNECT_DATA =
(SERVICE_NAME = Japan)
)
)
運行$tnsping Japan，出現以下提示符：
Attempting to contact (ADDRESS=(PROTOCOL=TCP)(HOST=10.1.1.200)(PORT=1521))
OK（n毫秒）
表明中國數據庫可以訪問日本數據庫。在日本那邊也同樣配置，確認$tnsping China 是通的。
改數據庫全局名稱，建公共的數據庫鏈接。
用system身份登錄China數據庫
SQL>alter database rename global_name to China.test.com.cn;
用system身份登錄Japan數據庫：
SQL>alter database rename global_name to Japan.test.com.cn;
用system身份登錄China數據庫。
SQL>create public database link Japan.test.com.cn using 'Japan';
測試數據庫全局名稱和公共的數據庫鏈接。
SQL>select * from [email protected];
返回結果為Japan.test.com.cn就對了。
用system身份登錄Japan數據庫：
SQL>create public database link China.test.com.cn using 'China';
測試數據庫全局名稱和公共的數據庫鏈接。
SQL>select * from [email protected];
返回結果為China.test.com.cn就對了。
建立管理數據庫復制的用戶repadmin，並賦權。
用system身份登錄China數據庫：
SQL>create user repadmin identifIEd by repadmin default tablespace users temporary tablespace temp;
SQL>execute dbms_defer_sys.register_propagator('repadmin');
SQL>grant execute any procedure to repadmin;
SQL>execute dbms_repcat_admin.grant_admin_any_repgroup('repadmin');
SQL>grant comment any table to repadmin;
SQL>grant lock any table to repadmin;
同樣用system身份登錄Japan數據庫，運行以上的命令，管理數據庫復制的用戶repadmin，並賦權。
在數據庫復制的用戶repadmin下創建私有的數據庫鏈接。
用repadmin身份登錄China數據庫。
SQL>create database link Japan.test.com.cn connect to repadmin identifIEd 試這個私有的數據庫鏈接：
SQL>select * from [email protected];
返回結果為Japan.test.com.cn就對了。
用repadmin身份登錄Japan數據庫。
SQL>create database link China.test.com.cn connect to repadmin identifIEd by repadmin;
測試這個私有的數據庫鏈接：
SQL>select * from [email protected];
返回結果為China.test.com.cn就對了。
創建或選擇實現數據庫復制的用戶和對象，給用戶賦權，數據庫對象必須有主關鍵字。
用internal身份登錄China數據庫，創建scott用戶並賦權：
SQL>create user scott identifIEd by tiger default tablespace users temporary tablespace temp;
SQL>grant connect, resource to scott;
SQL>grant execute on sys.dbms_defer to scott;
用scott身份登錄China數據庫，創建表dept ：
SQL>create table dept
(deptno number(2) primary key,
dname varchar2(14),
loc varchar2(13) );
如果數據庫對象沒有主關鍵字，可以運行以下SQL命令添加：
SQL>alter table dept add (constraint dept_deptno_pk primary key (deptno));
在China數據庫scott用戶下創建主關鍵字的序列號，范圍避免和Japan的沖突。
SQL> create sequence dept_no increment by 1 start with 1 maxvalue 44 cycle nocache;
在China數據庫scott用戶下插入初始化數據
SQL>insert into dept values (dept_no.nextval,'accounting','new york');
SQL>insert into dept values (dept_no.nextval,'research','dallas');
SQL>commit;
在Japan數據庫那邊同樣運行以上①，②，③。
在Japan數據庫scott用戶下創建主關鍵字的序列號，范圍避免和China的沖突。
SQL> create sequence dept_no increment by 1 start with 45 maxvalue 99 cycle nocache;
在Japan數據庫scott用戶下插入初始化數據。
SQL>insert into dept values (dept_no.nextval,'sales','chicago');
SQL>insert into dept values (dept_no.nextval,'Operations','boston');
SQL>commit;
在Japan數據庫那邊同樣運行以上①，②，③。
在Japan數據庫scott用戶下創建主關鍵字的序列號，范圍避免和China的沖突。
SQL> create sequence dept_no increment by 1 start with 45 maxvalue 99 cycle nocache;
在Japan數據庫scott用戶下插入初始化數據。
SQL>insert into dept values (dept_no.nextval,'sales','chicago');
SQL>insert into dept values (dept_no.nextval,'Operations','boston');
SQL>commit;
創建要復制的組scott_mg，加入數據庫對象，產生對象的復制支持。
用repadmin身份登錄China數據庫，創建主復制組scott_mg：
SQL> execute dbms_repcat.create_master_repgroup('scott_mg');
在復制組scott_mg裡加入數據庫對象：
SQL>execute dbms_repcat.create_master_repobject(sname=>'scott',oname=>'dept', type=>'table',use_existing_object=>true,gname=>'scott_mg');
參數說明：
sname 實現數據庫復制的用戶名稱；
oname 實現數據庫復制的數據庫對象名稱；
type 實現數據庫復制的數據庫對象類別；
use_existing_object true表示用主復制節點已經存在的數據庫對象；
gname 主復制組名；
對數據庫對象產生復制支持：
SQL>execute dbms_repcat.generate_replication_support('scott','dept','table');
確認復制的組和對象已經加入數據庫的數據字典：
SQL>select gname, master, status from dba_repgroup;
SQL>select * from dba_repobject;
創建主復制節點：
用repadmin身份登錄China數據庫，創建主復制節點：
SQL>execute dbms_repcat.add_master_database
(gname=>'scott_mg',master=>'Japan.test.com.cn',use_existing_objects=>true, copy_rows=>false, propagation_mode => 'asynchronous');
參數說明：
gname 主復制組名；
master 加入主復制節點的另一個數據庫；
use_existing_object true表示用主復制節點已經存在的數據庫對象；
copy_rows false表示第一次開始復制時不用和主復制節點保持一致；
propagation_mode 異步地執行；
確認復制的任務隊列已經加入數據庫的數據字典：
SQL>select * from user_jobs;
使同步組的狀態由停頓(quIEsced )改為正常(normal)：
用repaa數據庫，運行以下命令：
SQL> execute dbms_repcat.resume_master_activity('scott_mg',false);
確認同步組的狀態為正常(normal)：
SQL> select gname, master, status from dba_repgroup;
如果這個①命令不能使同步組的狀態為正常(normal)，可能有一些停頓的復制，運行以下命令再試試(建議在緊急的時候才用)：
SQL> execute dbms_repcat.resume_master_activity('scott_mg',true);
創建復制數據庫的時間表，10分鐘復制一次。
用repadmin身份登錄China數據庫，運行以下命令：
SQL>begin
dbms_defer_sys.schedule_push (
destination => 'Japan.test.com.cn',
interval => 'sysdate + 10/1440',
next_date => sysdate);
end;
/
SQL>begin
dbms_defer_sys.schedule_purge (
next_date => sysdate,
interval => 'sysdate + 10/1440',
delay_seconds => 0,
rollback_segment => '');
end;
/
用repadmin身份登錄Japan數據庫，運行以下命令：
SQL>begin
dbms_defer_sys.schedule_push (
destination => ' China.test.com.cn ',
interval => 'sysdate + 10 / 1440',
next_date => sysdate);
end;
/
SQL>begin
dbms_defer_sys.schedule_purge (
next_date => sysdate,
interval => 'sysdate + 10/1440',
delay_seconds => 0,
rollback_segment => '');
end;
/
添加或修改兩邊數據庫的記錄，跟蹤復制過程。如果你想立刻看到添加或修改後數據庫的記錄的變化，可以在兩邊repadmin用戶下找到push的job_number，然後運行：
SQL>exec dbms_job.run(job_number);
異常情況的處理：
檢查復制工作正常否，可以在repadmin 用戶下查詢user_jobs
SQL>select job,this_date,next_date,what, broken from user_jobs;
正常的狀態有兩種：任務閒——this_date為空，next_date為當前時間後的一個時間值；任務忙——this_date不為空，next_date為當前時間後的一個時間值。異常狀態也有兩種：任務死鎖——next_date為當前時間前的一個時間值；任務死鎖——next_date為非常大的一個時間值，例如：4001-01-01。這可能因為網絡中斷照成的死鎖。解除死鎖的辦法：
$ps –ef|grep orale
找到死鎖的刷新快照的進程號ora_snp*，用kill –9 命令刪除此進程，然後進入repadmin 用戶SQL>操作符下，運行命令：
SQL>exec dbms_job.run(job_number);
說明：job_number 為用select job,this_date,next_date,what from user_jobs;命令查出的job編號。
增加或減少復制組的復制對象：
停止主數據庫節點的復制動作，使同步組的狀態由正常(normal)改為停頓(quIEsced )。用repadmin身份登錄China數據庫，運行以下命令：
SQL>execute dbms_repcat.suspend_master_activity (gname => 'scott_mg');
在復制組scott_mg裡加入數據庫對象，保證數據庫對象必須有主關鍵字。
SQL>execute dbms_repcat.create_master_repobject(sname=>'scott',oname=>'emp', type=>'table',use_existing_object=>true,gname=>'scott_mg');
對加入的數據庫對象產生復制支持：
SQL>execute dbms_repcat.generate_replication_support('scott','emp','table');
在復制組scott_mg裡刪除數據庫對象：
SQL>execute dbms_repcat.drop_master_repobject ('scott','dept','table');
重新使同步組的狀態由停頓(quIEsced )改為正常(normal)。
SQL> execute dbms_repcat.resume_master_activity('scott_mg',false);
