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