制作付款网站,黑马网站建设,兰州北山生态建设局网站,在线网站建设系统主库为Oracle 11g数据库#xff0c;针对需要同步的表建立增量数据临时表以及反向并通过水壶定时同步到PostgreSQL数据库。1#xff0c;主库创建快照表和快照注意#xff1a;快照表结构和源表结构必须一致#xff01;--创建插入快照表
CREATE TABLE SPWUSER.WEB_CUSTOMER_IN…主库为Oracle 11g数据库针对需要同步的表建立增量数据临时表以及反向并通过水壶定时同步到PostgreSQL数据库。1主库创建快照表和快照注意快照表结构和源表结构必须一致--创建插入快照表
CREATE TABLE SPWUSER.WEB_CUSTOMER_INSERT_TMP
(ID NUMBER NOT NULL,NAME VARCHAR2(128 BYTE) NOT NULL,CREATED TIMESTAMP(6) WITH LOCAL TIME ZONE DEFAULT (current_timestamp) NOT NULL,MODIFIED TIMESTAMP(6) WITH LOCAL TIME ZONE DEFAULT (current_timestamp) NOT NULL
);
--创建更新快照表
CREATE TABLE SPWUSER.WEB_CUSTOMER_UPDATE_TMP
(ID NUMBER NOT NULL,NAME VARCHAR2(128 BYTE) NOT NULL,CREATED TIMESTAMP(6) WITH LOCAL TIME ZONE DEFAULT (current_timestamp) NOT NULL,MODIFIED TIMESTAMP(6) WITH LOCAL TIME ZONE DEFAULT (current_timestamp) NOT NULL
);
--创建删除快照表
CREATE TABLE SPWUSER.WEB_CUSTOMER_DELETE_TMP
(ID NUMBER NOT NULL,NAME VARCHAR2(128 BYTE) NOT NULL,CREATED TIMESTAMP(6) WITH LOCAL TIME ZONE DEFAULT (current_timestamp) NOT NULL,MODIFIED TIMESTAMP(6) WITH LOCAL TIME ZONE DEFAULT (current_timestamp) NOT NULL
);
--创建插入触发器
CREATE OR REPLACE TRIGGER SPWUSER.WEB_CUSTOMER_INSERT_TRIAFTER INSERTON SPWUSER.WEB_CUSTOMERFOR EACH ROW
BEGININSERT INTO WEB_CUSTOMER_INSERT_TMP (ID,NAME,CREATED,MODIFIED)VALUES (:new.id,:new.name,:new.created,:new.modified);
END;
/
--创建删除触发器
CREATE OR REPLACE TRIGGER SPWUSER.WEB_CUSTOMER_DELETE_TRIAFTER DELETEON SPWUSER.WEB_CUSTOMERFOR EACH ROW
BEGININSERT INTO WEB_CUSTOMER_DELETE_TMP (ID,NAME,CREATED,MODIFIED)VALUES (:old.ID,:old.NAME,:old.created,:old.modified);
END;
/
--创建更新触发器
CREATE OR REPLACE TRIGGER SPWUSER.WEB_CUSTOMER_UPDATE_TRIAFTER UPDATEON SPWUSER.WEB_CUSTOMERFOR EACH ROW
BEGININSERT INTO WEB_CUSTOMER_UPDATE_TMP (ID,NAME,CREATED,MODIFIED)VALUES (:old.ID,:old.NAME,:old.created,:old.modified);
END;
/2创建一个针对表增删改改的转换从kettle菜单中依次选择“文件”-“新建”-“转换”或按ctrl N快捷键创建。然后依次选择“输入”-“表输入”“输出”-“插入/更新”和“输出”-“删除”执行三次如下图所示3“表输入”控件查询主库Oracle的快照表4“插入/更新”控件插入数据到从库PostgreSQL的表查询的关键字要求唯一5“删除”控件将主库的快照表中的数据删除6新建“作业”控件新建作业控件将三个转换引用起来总览如下图所示插入转换更新转换删除转换发送邮件
