oracle数据同步实例

创建dblink ：
create database link db117 --实例
connect to test_u identified by test_u
using '(DESCRIPTION =
(ADDRESS_LIST =
(ADDRESS = (PROTOCOL = TCP)(HOST = 192.168.1.117)(PORT = 1521))
)
(CONNECT_DATA =
(SERVICE_NAME = plmlk)
)
)';

--drop database link db117;
commit;

创建存储过程
CREATE OR REPLACE PROCEDURE SYNC_DATA_FROM_DBLINK_DB AS

BEGIN

DECLARE

CURSOR c_TabNames IS

SELECT TABLE_NAME FROM user_tables;

v_TabName c_TabNames%ROWTYPE;

v_SQL VARCHAR2(4000);

v_rowcount NUMBER;

v_rc NUMBER:=0;

v_tab NUMBER :=0;

BEGIN

--禁用脚本
BEGIN
for c in (select 'ALTER TABLE '||TABLE_NAME||' DISABLE CONSTRAINT '||constraint_name||' ' as v_sql from user_constraints where CONSTRAINT_TYPE='R') loop
DBMS_OUTPUT.PUT_LINE(C.V_SQL);
begin
EXECUTE IMMEDIATE c.v_sql;
exception when others then
dbms_output.put_line(sqlerrm);
end;
end loop;

end;

FOR v_TabName in c_TabNames LOOP

v_SQL := 'DELETE '||v_TabName.TABLE_NAME;
Dbms_Output.put_line(v_SQL);
EXECUTE IMMEDIATE v_sql;

v_sql := 'INSERT INTO '|| v_tabname.TABLE_NAME||' SELECT * FROM '|| v_tabname.TABLE_NAME||'@db117';
Dbms_Output.put_line(v_SQL);
EXECUTE IMMEDIATE v_sql;

COMMIT;

v_SQL :='SELECT COUNT(*) FROM '|| v_tabname.TABLE_NAME;

Dbms_Output.put_line(v_SQL);
EXECUTE IMMEDIATE v_sql INTO v_rowcount;

v_tab := v_tab +1;

v_rc := v_rc + v_rowcount;

END LOOP;

Dbms_Output.put_line(to_char(SYSDATE,'yy-mm-dd hh24:mi:ss')||' 导入完成，共导入表'||to_char(v_tab)||'张，总记录数'||to_char(v_rc)||'条记录。');
END;
--启用脚本
--SET SERVEROUTPUT ON SIZE 10000 --sqlplus用的
BEGIN
for c in (select 'ALTER TABLE '||TABLE_NAME||' ENABLE CONSTRAINT '||constraint_name||' ' as v_sql from user_constraints where CONSTRAINT_TYPE='R') loop
DBMS_OUTPUT.PUT_LINE(C.V_SQL);
begin
EXECUTE IMMEDIATE c.v_sql;
exception when others then
dbms_output.put_line(sqlerrm);
end;
end loop;
end;

END SYNC_DATA_FROM_DBLINK_DB;

创建任务：
declare
jobupdate number;
begin
dbms_job.submit(jobupdate,'sync_data_from_dblink_db;',sysdate,'sysdate+3/1440');
end;

select * from user_jobs;

--步骤三：运行刚才创建的job
begin
dbms_job.run(44);
end;

--步骤四：查询该job下次执行的时间
select job,next_date,what from dba_jobs where job=44;

--步骤五：删除该job
begin
dbms_job.remove(44);
end;

oracle数据同步实例相关推荐

基于OGG Datahub插件将Oracle数据同步上云
摘要:随着数据规模的不断扩大,传统的RDBMS难以满足OLAP的需求,本文将介绍如何将Oracle的数据实时同步到阿里云的大数据处理平台当中,并利用大数据工具对数据进行分析. 一.背景介绍随着数据规 ...
Oracle数据同步解决方案之databus
[list][*][b]概述[/b][/list] 目前了解到基于Oracle的开源数据同步项目有yugong.databus.SymmetricDS,之前尝试了yugong,很容易上手.使用时需要注 ...
SQL 与oracle数据同步之链接服务器
很多时候,大一些的单位都有好几个系统,而这几个系统可能来自己不同的厂商,它们采用的开发技术可能很不一样,底层数据库也很能有可能是出于不同的平台,这就造成了同一个企业而在信息数据方面不"同 ...
（进阶篇_01）Oracle数据同步3种场景
文章目录一.场景分析二.实战 2.1. 创建原表表结构+初始化数据 2.2. 创建目标表表结构 2.3. 同步前效果图 2.4. 连接串 2.5. 执行同步 2.6.执行后效果图 2.7.操作记录 ...
Oracle数据同步接口，增量数据从ERP系统到本地临时表封装解决方案
项目的许多基础数据需要从ERP系统中同步基础数据,例如:物料.客户.供应商.仓库等等. 之前做过一次比较死板的标准流程: 1.通过JDBC取ERP系统的增量数据; 2.解析; 3.然后用自己项目的DB ...
oracle 上搭建ogg文档,ogg搭建配置实现oracle数据同步到mysql）
在线QQ客服:1922638 专业的SQL Server.MySQL数据库同步软件参考博客文章:https://www.jianshu.com/p/53882229b70e ? 1)根据不同的数据库 ...
Oracle数据同步
温习一下Oracle中常说的HA.RAC.Datagurad的区别简单的说 rac侧重于负载均衡 dg侧重于容灾 datagourd 双机侧重于业务的自动接管关键看你的应用要求是什么样的来进行 ...
oracle数据同步异常,案例：DataGuard同步异常问题处理记录
本帖最后由 yuanqk 于 2018-8-11 20:28 编辑真实案例,记录一下,都是小白,非常理解小白在遇到问题时的无奈,希望能帮助到一些人.过程非常简单,主要是处理问题的思路. 1.早上收到 ...
ORACLE 数据同步时，批量进行新增和更新操作的SQL写法
场景模拟:比如自己项目的一张EMP员工信息表,数据来源需要从第三方系统获取,随时可手动同步更新,也可以定时自动同步.一般情况下,通过创建时间或者最后更新时间,获取自上次同步后的数据增量,全部插入本地的 ...

oracle数据同步实例

oracle数据同步实例相关推荐

最新文章

热门文章