[FLINK-17826] Add missing custom query support on new jdbc connector

• Type: Bug
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Fix Version/s: 1.20.0
• Component/s: Connectors / JDBC
• Labels: auto-deprioritized-major auto-unassigned pull-request-available
• Assignee: Unassigned
• Reporter: Jark Wu
• Created: 20/May/20 07:03
• Updated: 11/Mar/24 12:44

Description

In FLINK-17361, we added custom query on JDBC tables, but missing to add the same ability on new jdbc connector (i.e. JdbcDynamicTableSourceSinkFactory).

In the new jdbc connector, maybe we should call it scan.query to keep consistent with other scan options, besides we need to make "table-name" optional, but add validation that "table-name" and "scan.query" shouldn't both be empty, and "table-name" must not be empty when used as sink.

Issue Links

• links to: GitHub Pull Request #13245