You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2022/09/07 08:09:33 UTC

[flink] branch master updated (481ed78bec4 -> a8ca381c577)

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

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


    from 481ed78bec4 [FLINK-29096][table] Keep backward compatibility of JdbcCatalog constructor
     add a8ca381c577 [FLINK-14101][jdbc-connector] Support SQLServer dialect in the jdbc connector.

No new revisions were added by this update.

Summary of changes:
 docs/content.zh/docs/connectors/table/jdbc.md      |  35 ++++
 docs/content/docs/connectors/table/jdbc.md         |  53 +++--
 flink-connectors/flink-connector-jdbc/pom.xml      |  16 ++
 .../SqlServerDialect.java}                         | 148 +++++++------
 .../SqlServerDialectFactory.java}                  |  10 +-
 ...owConverter.java => SqlServerRowConverter.java} |  19 +-
 ...flink.connector.jdbc.dialect.JdbcDialectFactory |   1 +
 .../sqlserver/SqlServerPreparedStatementTest.java  |  94 +++++++++
 .../SqlServerTableSinkITCase.java}                 |  94 ++++++---
 .../sqlserver/SqlServerTableSourceITCase.java      | 229 +++++++++++++++++++++
 10 files changed, 577 insertions(+), 122 deletions(-)
 copy flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/{oracle/OracleDialect.java => sqlserver/SqlServerDialect.java} (50%)
 copy flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/{mysql/MySqlDialectFactory.java => sqlserver/SqlServerDialectFactory.java} (80%)
 copy flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/{DerbyRowConverter.java => SqlServerRowConverter.java} (69%)
 create mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/sqlserver/SqlServerPreparedStatementTest.java
 copy flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/{oracle/OracleTableSinkITCase.java => sqlserver/SqlServerTableSinkITCase.java} (84%)
 create mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/sqlserver/SqlServerTableSourceITCase.java