實現Oracle數據庫復制
2024-08-29 13:44:06
供稿：網友
我們經常希望把各地的數據入庫后進行統一的應用。現在可以用復制技術來解決這個問題。但實現數據庫復制也是要有一些條件的。
首先，數據庫要具備高級復制功能（用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 global_name@Japan.test.com.cn;
返回結果為Japan.test.com.cn就對了。
用system身份登錄Japan數據庫：
SQL>create public database link China.test.com.cn using 'China';
測試數據庫全局名稱和公共的數據庫鏈接。
SQL>select * from global_name@China.test.com.cn;
返回結果為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 在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)：
用repa
