[jira] [Created] (FLINK-27071) For jdbcsink function to support config table name in SQL parameter

["haixiaCao (Jira)" <ji...@apache.org>]

haixiaCao created FLINK-27071:
---------------------------------

             Summary: For jdbcsink function  to support config table name in SQL parameter
                 Key: FLINK-27071
                 URL: https://issues.apache.org/jira/browse/FLINK-27071
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / JDBC
    Affects Versions: 1.13.6
            Reporter: haixiaCao


Want to support config table name in jdbcSink. In current version, we can't config it. 

e.g. 

JdbcSink.sink(
s""" insert into ptagdata_?("time", tag_id, value, modified_value, quality, update_time) values(?,?,?,?,?,?); """.stripMargin,
new JdbcStatementBuilder[RawTagDataFinal] {
override def accept(ps: PreparedStatement, u: RawTagDataFinal) = {
ps.setLong(1, u.account_id.toLong)
ps.setTimestamp(2, new Timestamp(u.data_event_time * 1000L))

 In version 1.13.5, we got the error as following:

java.sql.BatchUpdateException: Batch entry 0 insert into ptagdata_643133("time", tag_id, value, modified_value, quality, update_time) values('2022-04-06 13:30:00+08',16264100,1.23E7,NULL,0,'2022-04-06 13:44:24.27+08') was aborted: ERROR: relation "ptagdata_$1" does not exist



--
This message was sent by Atlassian Jira
(v8.20.1#820001)