diff --git a/docs/content.zh/docs/connectors/table/jdbc.md b/docs/content.zh/docs/connectors/table/jdbc.md index 8390c3525..e2be7a553 100644 --- a/docs/content.zh/docs/connectors/table/jdbc.md +++ b/docs/content.zh/docs/connectors/table/jdbc.md @@ -41,9 +41,25 @@ JDBC 连接器允许使用 JDBC 驱动向任意类型的关系型数据库读取 依赖 ------------ +使用 JDBC 连接器时, `flink-connector-jdbc-core`, `flink-connector-jdbc-${database}` 和对应的 JDBC 驱动需要添加到依赖中。 + {{< sql_connector_download_table "jdbc" >}} -JDBC 连接器不是二进制发行版的一部分，请查阅[这里]({{< ref "docs/dev/configuration/overview" >}})了解如何在集群运行中引用 JDBC 连接器。 +连接到对应的数据库时，需要使用对应的 `flink-connector-jdbc-${database}` 依赖和驱动依赖。 + +支持的 `flink-connector-jdbc-${database}` 依赖如下，其版本需要和 `flink-connector-jdbc-core` 依赖的版本相同： + +| Database | Group Id | Artifact Id | JAR | +|:-----------|:--------------------------|:---------------------------------|:--------------------------------------------------------------------------------------------| +| MySQL | `org.apache.flink` | `flink-connector-jdbc-mysql` | [下载](https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc-mysql/) | +| Oracle | `org.apache.flink` | `flink-connector-jdbc-oracle` | [下载](https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc-oracle/) | +| PostgreSQL | `org.apache.flink` | `flink-connector-jdbc-postgres` | [下载](https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc-postgres/) | +| Derby | `org.apache.flink` | `flink-connector-jdbc-core` | [下载](https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc-core/) | +| SQL Server | `org.apache.flink` | `flink-connector-jdbc-sqlserver` | [下载](https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc-sqlserver/) | +| CrateDB | `org.apache.flink` | `flink-connector-jdbc-cratedb` | [下载](https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc-cratedb/) | +| Db2 | `org.apache.flink` | `flink-connector-jdbc-db2` | [下载](https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc-db2/) | +| Trino | `org.apache.flink` | `flink-connector-jdbc-trino` | [下载](https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc-trino/) | +| OceanBase | `org.apache.flink` | `flink-connector-jdbc-oceanbase` | [下载](https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc-oceanbase/) | 在连接到具体数据库时，也需要对应的驱动依赖，目前支持的驱动如下： diff --git a/docs/content/docs/connectors/table/jdbc.md b/docs/content/docs/connectors/table/jdbc.md index b0ef84eb1..6e814016b 100644 --- a/docs/content/docs/connectors/table/jdbc.md +++ b/docs/content/docs/connectors/table/jdbc.md @@ -38,12 +38,27 @@ The JDBC sink operate in upsert mode for exchange UPDATE/DELETE messages with th Dependencies ------------ +When using the JDBC connector, `flink-connector-jdbc-core`, `flink-connector-jdbc-${database}` and the JDBC driver needs to be added to the dependencies. + {{< sql_connector_download_table "jdbc" >}} -The JDBC connector is not part of the binary distribution. -See how to link with it for cluster execution [here]({{< ref "docs/dev/configuration/overview" >}}). +The `flink-connector-jdbc-${database}` dependency and a driver dependency are required to connect to a specified database. + +The `flink-connector-jdbc-${database}` dependencies are as follows, whose version should be the same as the `flink-connector-jdbc-core`: + +| Database | Group Id | Artifact Id | JAR | +|:-----------|:--------------------------|:---------------------------------|:--------------------------------------------------------------------------------------------------| +| MySQL | `org.apache.flink` | `flink-connector-jdbc-mysql` | [Download](https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc-mysql/) | +| Oracle | `org.apache.flink` | `flink-connector-jdbc-oracle` | [Download](https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc-oracle/) | +| PostgreSQL | `org.apache.flink` | `flink-connector-jdbc-postgres` | [Download](https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc-postgres/) | +| Derby | `org.apache.flink` | `flink-connector-jdbc-core` | [Download](https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc-core/) | +| SQL Server | `org.apache.flink` | `flink-connector-jdbc-sqlserver` | [Download](https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc-sqlserver/) | +| CrateDB | `org.apache.flink` | `flink-connector-jdbc-cratedb` | [Download](https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc-cratedb/) | +| Db2 | `org.apache.flink` | `flink-connector-jdbc-db2` | [Download](https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc-db2/) | +| Trino | `org.apache.flink` | `flink-connector-jdbc-trino` | [Download](https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc-trino/) | +| OceanBase | `org.apache.flink` | `flink-connector-jdbc-oceanbase` | [Download](https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc-oceanbase/) | -A driver dependency is also required to connect to a specified database. Here are drivers currently supported: +Here are drivers currently supported: | Driver | Group Id | Artifact Id | JAR | |:-----------|:---------------------------|:-----------------------|:----------------------------------------------------------------------------------------------------------------------------------| @@ -58,7 +73,8 @@ A driver dependency is also required to connect to a specified database. Here ar | OceanBase | `com.oceanbase` | `oceanbase-client` | [Download](https://repo1.maven.org/maven2/com/oceanbase/oceanbase-client/) | -JDBC connector and drivers are not part of Flink's binary distribution. See how to link with them for cluster execution [here]({{< ref "docs/dev/configuration/overview" >}}). +JDBC connector and drivers are not part of Flink's binary distribution. +See how to link with them for cluster execution [here]({{< ref "docs/dev/configuration/overview" >}}). How to create a JDBC table diff --git a/docs/data/jdbc.yml b/docs/data/jdbc.yml index 1e23686cf..ee8eaaa7c 100644 --- a/docs/data/jdbc.yml +++ b/docs/data/jdbc.yml @@ -16,7 +16,7 @@ # limitations under the License. ################################################################################ -version: 3.3.0-SNAPSHOT +version: 4.1-SNAPSHOT variants: - - maven: flink-connector-jdbc - sql_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc/$full_version/flink-connector-jdbc-$full_version.jar + - maven: flink-connector-jdbc-core + sql_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc-core/$full_version/flink-connector-jdbc-core-$full_version.jar diff --git a/flink-connector-jdbc-architecture/pom.xml b/flink-connector-jdbc-architecture/pom.xml index fe6fa34b2..b004496a9 100644 --- a/flink-connector-jdbc-architecture/pom.xml +++ b/flink-connector-jdbc-architecture/pom.xml @@ -6,7 +6,7 @@ org.apache.flink flink-connector-jdbc-parent - 4.0-SNAPSHOT + 4.1-SNAPSHOT flink-connector-jdbc-architecture diff --git a/flink-connector-jdbc-backward-compatibility/pom.xml b/flink-connector-jdbc-backward-compatibility/pom.xml index ff6269dc1..cc9da3fde 100644 --- a/flink-connector-jdbc-backward-compatibility/pom.xml +++ b/flink-connector-jdbc-backward-compatibility/pom.xml @@ -7,7 +7,7 @@ org.apache.flink flink-connector-jdbc-parent - 4.0-SNAPSHOT + 4.1-SNAPSHOT org.apache.flink diff --git a/flink-connector-jdbc-core/pom.xml b/flink-connector-jdbc-core/pom.xml index 43d844496..a5a7e1f38 100644 --- a/flink-connector-jdbc-core/pom.xml +++ b/flink-connector-jdbc-core/pom.xml @@ -26,7 +26,7 @@ under the License. org.apache.flink flink-connector-jdbc-parent - 4.0-SNAPSHOT + 4.1-SNAPSHOT flink-connector-jdbc-core diff --git a/flink-connector-jdbc-cratedb/pom.xml b/flink-connector-jdbc-cratedb/pom.xml index 0233766d1..e042f11f7 100644 --- a/flink-connector-jdbc-cratedb/pom.xml +++ b/flink-connector-jdbc-cratedb/pom.xml @@ -6,7 +6,7 @@ org.apache.flink flink-connector-jdbc-parent - 4.0-SNAPSHOT + 4.1-SNAPSHOT flink-connector-jdbc-cratedb diff --git a/flink-connector-jdbc-db2/pom.xml b/flink-connector-jdbc-db2/pom.xml index 5b3aac6c5..69eca24a4 100644 --- a/flink-connector-jdbc-db2/pom.xml +++ b/flink-connector-jdbc-db2/pom.xml @@ -6,7 +6,7 @@ org.apache.flink flink-connector-jdbc-parent - 4.0-SNAPSHOT + 4.1-SNAPSHOT flink-connector-jdbc-db2 diff --git a/flink-connector-jdbc-mysql/pom.xml b/flink-connector-jdbc-mysql/pom.xml index 91f3c6072..10ff122d5 100644 --- a/flink-connector-jdbc-mysql/pom.xml +++ b/flink-connector-jdbc-mysql/pom.xml @@ -6,7 +6,7 @@ org.apache.flink flink-connector-jdbc-parent - 4.0-SNAPSHOT + 4.1-SNAPSHOT flink-connector-jdbc-mysql diff --git a/flink-connector-jdbc-oceanbase/pom.xml b/flink-connector-jdbc-oceanbase/pom.xml index 5a9830de4..bb1479929 100644 --- a/flink-connector-jdbc-oceanbase/pom.xml +++ b/flink-connector-jdbc-oceanbase/pom.xml @@ -6,7 +6,7 @@ org.apache.flink flink-connector-jdbc-parent - 4.0-SNAPSHOT + 4.1-SNAPSHOT flink-connector-jdbc-oceanbase diff --git a/flink-connector-jdbc-oracle/pom.xml b/flink-connector-jdbc-oracle/pom.xml index 45b596c47..c34da213c 100644 --- a/flink-connector-jdbc-oracle/pom.xml +++ b/flink-connector-jdbc-oracle/pom.xml @@ -7,7 +7,7 @@ org.apache.flink flink-connector-jdbc-parent - 4.0-SNAPSHOT + 4.1-SNAPSHOT flink-connector-jdbc-oracle diff --git a/flink-connector-jdbc-postgres/pom.xml b/flink-connector-jdbc-postgres/pom.xml index 94eafb729..be42e5778 100644 --- a/flink-connector-jdbc-postgres/pom.xml +++ b/flink-connector-jdbc-postgres/pom.xml @@ -6,7 +6,7 @@ org.apache.flink flink-connector-jdbc-parent - 4.0-SNAPSHOT + 4.1-SNAPSHOT flink-connector-jdbc-postgres diff --git a/flink-connector-jdbc-sqlserver/pom.xml b/flink-connector-jdbc-sqlserver/pom.xml index 175b3ce2e..6cf1969aa 100644 --- a/flink-connector-jdbc-sqlserver/pom.xml +++ b/flink-connector-jdbc-sqlserver/pom.xml @@ -6,7 +6,7 @@ org.apache.flink flink-connector-jdbc-parent - 4.0-SNAPSHOT + 4.1-SNAPSHOT flink-connector-jdbc-sqlserver diff --git a/flink-connector-jdbc-trino/pom.xml b/flink-connector-jdbc-trino/pom.xml index 37234b67d..3f81974ca 100644 --- a/flink-connector-jdbc-trino/pom.xml +++ b/flink-connector-jdbc-trino/pom.xml @@ -6,7 +6,7 @@ org.apache.flink flink-connector-jdbc-parent - 4.0-SNAPSHOT + 4.1-SNAPSHOT flink-connector-jdbc-trino diff --git a/pom.xml b/pom.xml index fe2fc778b..4affd1673 100644 --- a/pom.xml +++ b/pom.xml @@ -29,7 +29,7 @@ under the License. org.apache.flink flink-connector-jdbc-parent - 4.0-SNAPSHOT + 4.1-SNAPSHOT Flink : Connectors : JDBC : Parent pom 2022