Oracle使用dblink同步数据

两台Oracle之间进行数据同步，可以借助Oracle的dblink完成，如果是Oracle与其他数据库之间，则可以使用Oracle提供的Database Gateways+dblink实现，当然，也可以使用开源ETL工具如kettle完成。

这里提供两种在Oracle之间同步数据的简单解决方案。

0 需求

A（192.168.68.129）、B（192.168.68.143）两个数据库，当 A 中的表 T_TEST 数据发生改变时，B 数据库中的表 T_TEST 自动更新，实现数据主动推送或者主动拉取

1 dblink + 触发器

1.1 源库 A 创建dblink

在源数据库 A 中创建 dblink，指向目标库 B

CREATE database link DBLINK_TEST CONNECT TO SCOTT IDENTIFIED BY "123456" using '(DESCRIPTION = (ADDRESS_LIST = (ADDRESS = (PROTOCOL = TCP)(HOST = 192.168.68.143)(PORT = 1521)) ) (CONNECT_DATA = (SERVER = DEDICATED) (SID = ORCL) ) )';

查询是否创建成功

SELECT * FROM T_TEST @DBLINK_TEST;

1.2 源库 A 创建触发器

在源数据库 A 中创建触发器，更新目标库 B

CREATE OR REPLACE TRIGGER TRIGGER_SYN_TEST
AFTER INSERT OR UPDATE OR DELETE ON T_TEST FOR each ROW
BEGINIF INSERTING THENINSERT INTO T_TEST @DBLINK_TESTVALUES( : new.ID,: new.ROLE_NAME,: new.NOTE );ELSIF UPDATING THENUPDATE T_TEST @DBLINK_TEST SET ROLE_NAME = : new.ROLE_NAME,NOTE = : new.NOTEWHEREID = : new.ID;ELSIF DELETING THENDELETE FROMT_TEST @DBLINK_TEST WHEREID = : old.ID;END IF;
END;

测试是否生效

INSERT INTO T_TEST VALUES(2, '测试角色','测试角色');UPDATE T_TEST SET ROLE_NAME = '测试角色更新' WHERE ID = 2;DELETE FROM T_TEST WHERE ID = 2;

2 dblink + 物化视图

2.1 源库 A 创建物化视图日志表

在源库中创建物化视图日志表

CREATE MATERIALIZED VIEW LOG ON "T_TEST" WITH ROWID;

2.2 目标库 B 创建dblink

在目标库 B 中创建指向源库 A 的dblink

CREATE PUBLIC database link DBLINK_TEST CONNECT TO SCOTT IDENTIFIED BY "123456" using '(DESCRIPTION = (ADDRESS_LIST = (ADDRESS = (PROTOCOL = TCP)(HOST = 192.168.68.129)(PORT = 1521)) ) (CONNECT_DATA = (SERVER = DEDICATED) (SID = ORCL) ) )';

2.3 目标库 B 创建物化视图

# 创建，不会自动刷新
CREATE MATERIALIZED VIEW MV_TEST refresh fast ON demand WITH ROWID AS
SELECT * FROM T_TEST @DBLINK_TEST;# 每分钟刷新一次
CREATE MATERIALIZED VIEW MV_TEST refresh fast ON demand WITH ROWID NEXT to_date( to_char( SYSDATE + 1/1440, 'dd-mm-yyyy hh24:mi:ss' ), 'dd-mm-yyyy hh24:mi:ss' ) AS
SELECT * FROM T_TEST @DBLINK_TEST;# 删除
DROP MATERIALIZED VIEW mv_name

一天为24个小时 1440分钟 86400秒
故：
一个小时后时间为 sysdate+1/24
select sysdate + 1/24 from dual
一分钟后时间为 sysdate+1/1440
select sysdate + 1/1440 from dual
一秒钟后时间为 sysdate+1/86400
select sysdate + 1/86400 from dual

2.4 手动同步数据

call dbms_mview.refresh ( 'MV_TEST' );

Oracle使用dblink同步数据相关推荐

ORACLE通过dblink同步SDO_ORDINATE_ARRAY_STR的数据
请教一下,有哪位大神知道如何通过dblink同步SDO_ORDINATE_ARRAY_STR类型的数据,我再两个库之间建立了dblink,常见数据类型查询是没有问题的,但查询SDO_ORDINATE_ ...
Oracle通过kafka同步数据到MySQL
场景 Oracle同步数据最佳的解决方案是自家的ogg,但是考虑到成本,需要找到其他的解决方案.如果是MySQL通过kafka同步,问题简单的多,因为阿里巴巴的开源数据同步方案--canel是最佳的解 ...
dblink 同步数据_使用DBLINK同步TC数据库
TC系统通常会有三种环境,PRD环境.QA环境和DEV环境.这三种环境的数据往往是不同步的,甚至存在QA和DEV数据与PRD是完全不一致的情况.导致在QA环境进行测试还需要重新搭建数据模拟用户真实场景 ...
oracle两表同步java代码,利用DBLink+JOB实现两个Oracle数据库之间的数据同步
该楼层疑似违规已被系统折叠隐藏此楼查看此楼第三步:建立JOB任务,定时同步数据在PL/SQL的command window输入以下语句: begin sys.dbms_job.submit(job ...
两个oracle数据库外网同步,利用DBLink+JOB实现两个Oracle数据库之间的数据同步
该楼层疑似违规已被系统折叠隐藏此楼查看此楼第三步:建立JOB任务,定时同步数据在PL/SQL的command window输入以下语句: begin sys.dbms_job.submit(job ...
利用oracle快照dblink解决数据库表同步问题
单向,双向同步都可使用. --名词说明:源--被同步的数据库目的--要同步到的数据库前6步必须执行,第6以后是一些辅助信息. --1.在目的数据库上,创建dblink dr ...
如何实现Oracle数据库之间的数据同步？
我们都知道,在Oracle数据库的管理与开发工作中,总会存在着一些表数据和基础资料数据,这时需要有效的将这些数据库进行同步合并,有没有什么简单的方法可以实现Oracle数据库之间的数据同步呢?在此诚恺 ...
oracle rollup分组没有数据时为0_数据库周刊19│GBASE适配鲲鹏;MySQL窗口函数;OGG双向数据同步……...
摘要:墨天轮数据库周刊第19期发布啦,每周1次推送本周数据库相关热门资讯.精选文章.干货文档.本周分享GBASE适配鲲鹏: 疫情激活COBOL语言:TiDB数据库的未来:Oracle与double w ...
这样做，免费从Oracle同步数据
点击▲关注 "数据和云" 给公众号标星置顶更多精彩第一时间直达刘伟刘伟,云和恩墨软件开发部研究院研究员:前微博DBA,主要研究方向为开源数据库,分布式数据库,擅长自动化 ...