| Steps To Reproduce | 1. Exists two tables in oracle:
CREATE TABLE DATA.SYMTESTMAIN
( ID NUMBER(5,0) NOT NULL ENABLE,
DATA VARCHAR2(200 BYTE),
CONSTRAINT "SYMTESTMAIN_PK" PRIMARY KEY ("ID")
);
CREATE TABLE DATA.SYMTESTPROTO
( ID DATE NOT NULL ENABLE,
CONSTRAINT "SYMTESTPROTO_PK" PRIMARY KEY ("ID")
);
2. And in PostgreSQL
CREATE TABLE data.symtestmain
(
id numeric(5,0) NOT NULL,
data character varying(200),
CONSTRAINT symtestmain_pkey PRIMARY KEY (id)
);
CREATE TABLE data.symtestproto
(
id timestamp(0) without time zone NOT NULL,
CONSTRAINT symtestproto_pkey PRIMARY KEY (id)
);
Both tables are included in syncronization
3. Trigger in Oracle:
CREATE OR REPLACE TRIGGER DATA.SYMTESTMAINTRG
before delete or insert or update on data.symtestmain
for each row
begin
insert into data.symtestproto (id) values (sysdate);
end;
This trigger adds row in symtestproto table on every insert, update and delete row in symtestmain table. Trigger exists only in Oracle.
4. Add row in symtestmain of PostgreSQL database
id data
1 qwe
5. This row is successfully captured.
sym_data in PostgreSQL:
data_id table_name event_type row_data pk_data old_data trigger_hist_id channel_id transaction_id source_node_id external_data node_list create_time is_prerouted
268 symtestmain I "1","qwe" 305 dev-main-channel 1955924 2021-07-06 11:07:33.899489 0
6. Data transferred in oracle, trigger SYMTESTMAINTRG fired, row added into SYMTESTPROTO table. Data captured.
sym_data in Oracle:
DATA_ID TABLE_NAME EVENT_TYPE ROW_DATA PK_DATA OLD_DATA TRIGGER_HIST_ID CHANNEL_ID TRANSACTION_ID SOURCE_NODE_ID EXTERNAL_DATA NODE_LIST CREATE_TIME IS_PREROUTED
12021 SYMTESTPROTO I "2021-07-06 11:07:50" 134 dev-main-channel 7.62.1576616 000 06.07.2021 11:07:50,503222000 0
12022 SYMTESTMAIN I "1","qwe" 133 dev-main-channel 7.62.1576616 000 06.07.2021 11:07:50,585466000 0
SOURCE_NODE_ID of both rows is set to 000, however only row in SYMTESTMAIN comes from 000 node. Row in SYMTESTPROTO table will not be transferred to 000 node (PostgreSQL) and table symtestproto in PostgreSQL will remain empty.
|
|---|