304792747 commented on issue #9392:
URL: https://github.com/apache/seatunnel/issues/9392#issuecomment-2964856201
{
"env" : {
"job.mode" : "batch"
},
"source" : [
{
"plugin_output" : "tt1",
"plugin_name" : "Jdbc",
"url" : "jdbc:oracle:thin:@192.168.2.26:1521:spring",
"driver" : "oracle.jdbc.OracleDriver",
"user" : "bos",
"password" : "******",
"query" : "select * from d_department"
}
],
"transform" : [
{
"plugin_input" : [
"tt1"
],
"plugin_output" : "tt2",
"prefix" : "CDC_",
"suffix" : "",
"replacements_with_regex" : [
{
"replace_from" : "",
"replace_to" : ""
}
],
"plugin_name" : "TableRename"
}
],
"sink" : [
{
"plugin_input" : [
"tt2"
],
"plugin_name" : "Jdbc",
"url" : "jdbc:oracle:thin:@192.168.2.13:1521:orcl",
"driver" : "oracle.jdbc.OracleDriver",
"user" : "ods_bmis",
"password" : "******",
"generate_sink_sql" : true,
"database" : "orcl",
"table" : "${database_name}.${table_name}" ,
// 需要使用变量。${database_name}表示source的 user的bos用户，
// ${table_name}表示 source 中 query 的 d_department 表名，并且经过
transform 处理
// 最终表名为 CDC_D_DEPARTMENT
"schema_save_mode" : "RECREATE_SCHEMA"
}
]
}
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
