[flink] branch master updated (9f406a6 -> bdaf1db)

[ja...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 9f406a6  [FLINK-13872][docs-zh] Translate Operations Playground to Chinese
     add f86cb1a  [FLINK-18579][jdbc] Remove deprecated classes in flink-connector-jdbc
     add bdaf1db  [FLINK-15728][jdbc] Introduce FieldNamedPreparedStatement to support fields are bound multiple times in update statement

No new revisions were added by this update.

Summary of changes:
 .../flink/api/java/io/jdbc/JDBCInputFormat.java    | 202 -----------
 .../flink/api/java/io/jdbc/JDBCOutputFormat.java   | 226 -------------
 .../jdbc/split/GenericParameterValuesProvider.java |  43 ---
 .../split/NumericBetweenParametersProvider.java    |  65 ----
 .../io/jdbc/split/ParameterValuesProvider.java     |  34 --
 .../flink/connector/jdbc/dialect/JdbcDialect.java  |  14 +-
 .../jdbc/internal/JdbcBatchingOutputFormat.java    |   7 +-
 .../jdbc/internal/TableJdbcUpsertOutputFormat.java |  18 +-
 .../converter/AbstractJdbcRowConverter.java        |  33 +-
 .../jdbc/internal/converter/JdbcRowConverter.java  |   4 +-
 .../executor/InsertOrUpdateJdbcExecutor.java       |   3 +
 ...va => TableBufferReducedStatementExecutor.java} |  14 +-
 ...or.java => TableBufferedStatementExecutor.java} |  55 ++-
 .../TableInsertOrUpdateStatementExecutor.java      | 115 +++++++
 ...utor.java => TableSimpleStatementExecutor.java} |  54 ++-
 .../statement/FieldNamedPreparedStatement.java     | 264 +++++++++++++++
 .../statement/FieldNamedPreparedStatementImpl.java | 240 +++++++++++++
 .../connector/jdbc/statement/StatementFactory.java |  16 +-
 .../jdbc/table/JdbcDynamicOutputFormatBuilder.java | 155 +++++----
 .../connector/jdbc/table/JdbcLookupFunction.java   |   9 +-
 .../jdbc/table/JdbcRowDataLookupFunction.java      |   8 +-
 .../connector/jdbc/table/JdbcTableSource.java      |   9 +-
 .../api/java/io/jdbc/JDBCInputFormatTest.java      | 372 ---------------------
 .../api/java/io/jdbc/JDBCOutputFormatTest.java     | 259 --------------
 .../FieldNamedPreparedStatementImplTest.java       | 174 ++++++++++
 .../jdbc/table/JdbcDynamicOutputFormatTest.java    |   8 +-
 .../jdbc/table/JdbcDynamicTableSinkITCase.java     |   6 +-
 .../jdbc/table/JdbcLookupTableITCase.java          |  10 +-
 28 files changed, 1018 insertions(+), 1399 deletions(-)
 delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
 delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java
 delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/split/GenericParameterValuesProvider.java
 delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/split/NumericBetweenParametersProvider.java
 delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/split/ParameterValuesProvider.java
 rename flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/{BufferReduceStatementExecutor.java => TableBufferReducedStatementExecutor.java} (89%)
 copy flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/{SimpleBatchStatementExecutor.java => TableBufferedStatementExecutor.java} (51%)
 create mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableInsertOrUpdateStatementExecutor.java
 copy flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/{KeyedBatchStatementExecutor.java => TableSimpleStatementExecutor.java} (51%)
 create mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/statement/FieldNamedPreparedStatement.java
 create mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/statement/FieldNamedPreparedStatementImpl.java
 copy flink-clients/src/main/java/org/apache/flink/client/program/ClusterClientProvider.java => flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/statement/StatementFactory.java (66%)
 delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormatTest.java
 delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormatTest.java
 create mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/statement/FieldNamedPreparedStatementImplTest.java