create table xxx(
`ID` STRING ,
//建表语句
primary key (ID) not enforced
)
with
(
'connector' = 'jdbc',
'url' = 'jdbc:oracle:thin:@ip:1521/orcl',
'driver' = 'oracle.jdbc.driver.OracleDriver',
'username' = 'xxx',
'password' = ''xxx,
'table-name' = '表名'
);
//Doris建表
create table xxx(
`id` string ,
//建表语句
primary key (id) not enforced
)
WITH
(
'connector' = 'doris',
'fenodes' = '10.100.XXX:8030',
'table.identifier' = '表名',
'username' = 'root',
'password' = 'xxx,
'sink.properties.format' = 'json',
'sink.properties.read_json_by_line' = 'true',
'sink.label-prefix' = '5410923'
);
insert into xxx
select * from xxxx;