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
