Sink 表 数据

FlinkX SQL script

CREATE TABLE source
(
ID bigint,
TTIME DATE ,
TTIMESTAMP TIMESTAMP
) WITH (
'connector' = 'oraclelogminer-x'
,'url' = 'jdbc:oracle:thin:@xxx:1521:helowin'
,'username' = 'xxx'
,'password' = 'xxx'
,'cat' = 'insert,delete,update'
,'table' = 'xxx'
-- ,'timestamp-format.standard' = 'SQL'
);

CREATE TABLE sink
(
ID bigint primary key,
TTIME DATE ,
TTIMESTAMP TIMESTAMP
) WITH (
'connector' = 'oracle-x',
'url' = 'jdbc:oracle:thin:@xxx:1521:helowin',
'table-name' = 'xxx',
'username' = 'xxx',
'password' = 'xxx'
);

insert into sink
select *
from source u;

INSERT INTO "xxx"."DEMO" VALUES ('1', TO_DATE('2022-03-15 14:17:23', 'SYYYY-MM-DD HH24:MI:SS'), TO_TIMESTAMP('2022-03-15 14:17:25.000000', 'SYYYY-MM-DD HH24:MI:SS:FF6'));