github-forks
/
flink-cdc-connectors
mirror of https://github.com/ververica/flink-cdc-connectors.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[sqlserver] Add more supported(tested) SqlServer versions (#1049)

Browse Source
pull/1090/head
gongzhongqiang 3 years ago committed by GitHub
parent dadcfa79db
commit 2982bc0b71
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File

2
README.md
Unescape Escape View File

@ -14,7 +14,7 @@ This README is meant as a brief walkthrough on the core features of CDC Connecto
| [oceanbase-cdc](/docs/content/connectors/oceanbase-cdc.md) | <li> [OceanBase CE](https://open.oceanbase.com): 3.1.x | JDBC Driver: 5.7.4x |
| [oracle-cdc](docs/content/connectors/oracle-cdc.md) | <li> [Oracle](https://www.oracle.com/index.html): 11, 12, 19 | Oracle Driver: 19.3.0.0 |
| [postgres-cdc](docs/content/connectors/postgres-cdc.md) | <li> [PostgreSQL](https://www.postgresql.org): 9.6, 10, 11, 12 | JDBC Driver: 42.2.12 |
| [sqlserver-cdc](docs/content/connectors/sqlserver-cdc.md) | <li> [Sqlserver](https://www.microsoft.com/sql-server): 2017, 2019 | JDBC Driver: 7.2.2.jre8 |
| [sqlserver-cdc](docs/content/connectors/sqlserver-cdc.md) | <li> [Sqlserver](https://www.microsoft.com/sql-server): 2012, 2014, 2016, 2017, 2019 | JDBC Driver: 7.2.2.jre8 |
| [tidb-cdc](docs/content/connectors/tidb-cdc.md) | <li> [TiDB](https://www.pingcap.com): 5.1.x, 5.2.x, 5.3.x, 5.4.x | JDBC Driver: 8.0.27 |
## Features

2
docs/content/about.md
Unescape Escape View File

@ -14,7 +14,7 @@ The CDC Connectors for Apache Flink<sup>®</sup> integrate Debezium as the engin
| [oceanbase-cdc](connectors/oceanbase-cdc.md) | <li> [OceanBase CE](https://open.oceanbase.com): 3.1.x | JDBC Driver: 5.7.4x |
| [oracle-cdc](connectors/oracle-cdc.md) | <li> [Oracle](https://www.oracle.com/index.html): 11, 12, 19 | Oracle Driver: 19.3.0.0 |
| [postgres-cdc](connectors/postgres-cdc.md) | <li> [PostgreSQL](https://www.postgresql.org): 9.6, 10, 11, 12 | JDBC Driver: 42.2.12 |
| [sqlserver-cdc](connectors/sqlserver-cdc.md) | <li> [Sqlserver](https://www.microsoft.com/sql-server): 2017, 2019 | JDBC Driver: 7.2.2.jre8 |
| [sqlserver-cdc](connectors/sqlserver-cdc.md) | <li> [Sqlserver](https://www.microsoft.com/sql-server): 2012, 2014, 2016, 2017, 2019 | JDBC Driver: 7.2.2.jre8 |
| [tidb-cdc](connectors/tidb-cdc.md) | <li> [TiDB](https://www.pingcap.com/): 5.1.x, 5.2.x, 5.3.x, 5.4.x | JDBC Driver: 8.0.27 |
## Supported Flink Versions

6
flink-connector-sqlserver-cdc/src/main/java/com/ververica/cdc/connectors/sqlserver/SqlServerValidator.java
Unescape Escape View File

@ -69,11 +69,13 @@ public class SqlServerValidator implements Validator {
private void checkVersion(Connection connection) throws SQLException {
DatabaseMetaData metaData = connection.getMetaData();
if (metaData.getDatabaseMajorVersion() != 14 && metaData.getDatabaseMajorVersion() != 15) {
// For more information on sqlserver version, please refer to
// https://docs.microsoft.com/en-us/troubleshoot/sql/general/determine-version-edition-update-level.
if (metaData.getDatabaseMajorVersion() < 11) {
throw new ValidationException(
String.format(
"Currently Flink SqlServer CDC connector only supports SqlServer "
+ "whose version is either 14 or 15, but actual is %d.",
+ "whose version is larger or equal to 11, but actual is %d.",
metaData.getDatabaseMajorVersion()));
}
}

Write Preview
Loading…
Cancel
Save