seatunnel doris导出到mysql示例

env { 
   execution.parallelism = 1 
   job.mode = "BATCH" 
   checkpoint.interval = 2000 
   checkpoint.timeout = 300000
} 
  
source{ 
 Jdbc {
    url = "jdbc:mysql://xxx:9030/db?serverTimezone=GMT%2b8"
    driver = "com.mysql.cj.jdbc.Driver"
    connection_check_timeout_sec = 100
    user = "xxx"
    password = "xxx"
    query = "SELECT field_1, field_2 FROM db.tbl"
  }
} 
sink { 
 Jdbc { 
  url = "jdbc:mysql://xxx:3306/db?serverTimezone=GMT%2b8"
  driver = "com.mysql.cj.jdbc.Driver" 
  user = "xxx" 
  password = "xxx" 
  database = "db" 
  table = "tbl" 
  generate_sink_sql=true 
  primary_keys = ["field_1"]
  support_upsert_by_query_primary_key_exist=true
  data_save_mode = DROP_DATA
 } 
}