oracle数据库的高级复制

张兴康 · 发表于 2020-2-28 19:20:56

首先，数据库要具备高级复制功能（用system身份登录数据库，查看v$option视图，如果其中Advanced replication为TRUE，则支持高级复制功能；否则不支持）

一.数据库基本情况
数据库A　版本oracle 10.2.0.3 数据库名sid:shenzhen
数据库B　版本oracle 10.2.0.3 数据库名sid:beijing
主体定义站点:A shenzhen主体站点:B shenzhen
注:主体定义站点指配置复制工作的站点
本例涉及的用户. 复制管理员:repadmin 应用用户:cqm本例复制的对象:reptest 数据表本例的先决条件:你需要设置好相应的参数,job_queue_processes需要大于0,global_name=true,并且建立相应的db link.
alter system set global_names=true scope=both;

二.在两个数据库上分别创建应用用户CQM
CREATE USER CQM IDENTIFIED BY CQM DEFAULT TABLESPACE users TEMPORARY TABLESPACE TEMP;
GRANT DBA TO CQM;

三.在两个数据库上分别创建复制管事员用户REPADMIN
--创建repadmin用户管理复制环境
CREATE USER REPADMIN IDENTIFIED BY REPADMIN;
ALTER USER REPADMIN DEFAULT TABLESPACE USERS;
ALTER USER REPADMIN TEMPORARY TABLESPACE TEMP;
GRANT connect, resource TO REPADMIN;
--授予repadmin用户权限可以管理当前站点中任何主体组
EXECUTE dbms_repcat_admin.grant_admin_any_schema('REPADMIN');
--授予repadmin用户权限可以为任何表创建snapshot logs
GRANT comment any table TO REPADMIN;
GRANT lock any table TO REPADMIN;
--指定repadmin用户为propagator，并授予执行任何procedure的权限
EXECUTE dbms_defer_sys.register_propagator('REPADMIN');
GRANT execute any procedure TO REPADMIN;

四.更改两个数据库的全局名称
alter database rename global_name to beijing.TEST.COM.CN;
alter database rename global_name to shenzhen.TEST.COM.CN;

五.在两个数据库上建立数据库链接
create public database link beijing.TEST.COM.CN connect to REPADMIN identified by REPADMIN using 'beijing';
create public database link shenzhen.TEST.COM.CN connect to REPADMIN identified by REPADMIN using 'shenzhen';

六.在两个数据库的应用用户CQM下创建表
在数据库shenzhen上用户CQM下：注意，要进行复制的表必须有主键
CREATE TABLE TEST(ID NUMBER(10),TIMESTAMP DATE DEFAULT sysdate);
ALTER TABLE TEST ADD(CONSTRAINT TEST_PK PRIMARY KEY(ID));
在数据库beijing上用户CQM下：
CREATE TABLE TEST(ID NUMBER(10),TIMESTAMP DATE DEFAULT sysdate);
ALTER TABLE TEST ADD(CONSTRAINT TEST_PK PRIMARY KEY(ID));

七.在主体定义站点开始操作(数据库A:shenzhen)
以REPADMIN登录数据库shenzhen
创建复制组:
execute dbms_repcat.create_master_repgroup('repg');
在复制组里加入复制对象:
execute dbms_repcat.create_master_repobject(sname=>'cqm',oname=>'test',type=>'table',use_existing_object=>true,gname=>'repg',copy_rows=>false);
对复制对象产生复制支持:
execute dbms_repcat.generate_replication_support('cqm','test','table');
execute dbms_repcat.drop_master_repobject ('scott','dept','table');[取消同步]
添加主体复制节点:
execute dbms_repcat.add_master_database(gname=>'repg',master=>'beijing.test.com.cn',use_existing_objects=>true,copy_rows=>false, propagation_mode => 'asynchronous');
　　********************************************** 　　参数说明：　　gname 主复制组名　　master 加入主复制节点的另一个数据库　　use_existing_object true表示用主复制节点已经存在的数据库对象　　copy_rows false表示第一次开始复制时不用和主复制节点保持一致　　propagation_mode 同步地执行 synchronous（上边配置异步复制）　　***********************************************
在主体定义站点启动复制:
execute dbms_repcat.resume_master_activity('repg',true);
execute dbms_repcat.resume_master_activity('repg',false);
execute dbms_repcat.suspend_master_activity('repg')[停止复制]
至此配置完成