@@ -47,17 +47,18 @@ JDBC 连接器不是二进制发行版的一部分,请查阅[这里]({{< ref "
4747
4848在连接到具体数据库时,也需要对应的驱动依赖,目前支持的驱动如下:
4949
50- | Driver | Group Id | Artifact Id | JAR |
51- | :-----------| :---------------------------| :-----------------------| :----------------------------------------------------------------------------------------------------------------------------|
52- | MySQL | ` mysql ` | ` mysql-connector-java ` | [ 下载] ( https://repo.maven.apache.org/maven2/mysql/mysql-connector-java/ ) |
53- | Oracle | ` com.oracle.database.jdbc ` | ` ojdbc8 ` | [ 下载] ( https://mvnrepository.com/artifact/com.oracle.database.jdbc/ojdbc8 ) |
54- | PostgreSQL | ` org.postgresql ` | ` postgresql ` | [ 下载] ( https://jdbc.postgresql.org/download/ ) |
55- | Derby | ` org.apache.derby ` | ` derby ` | [ 下载] ( http://db.apache.org/derby/derby_downloads.html ) |
56- | SQL Server | ` com.microsoft.sqlserver ` | ` mssql-jdbc ` | [ 下载] ( https://docs.microsoft.com/en-us/sql/connect/jdbc/download-microsoft-jdbc-driver-for-sql-server?view=sql-server-ver16 ) |
57- | CrateDB | ` io.crate ` | ` crate-jdbc ` | [ 下载] ( https://repo1.maven.org/maven2/io/crate/crate-jdbc/ ) |
58- | Db2 | ` com.ibm.db2.jcc ` | ` db2jcc ` | [ 下载] ( https://www.ibm.com/support/pages/download-db2-fix-packs-version-db2-linux-unix-and-windows ) |
59- | Trino | ` io.trino ` | ` trino-jdbc ` | [ 下载] ( https://repo1.maven.org/maven2/io/trino/trino-jdbc/ ) |
60- | OceanBase | ` com.oceanbase ` | ` oceanbase-client ` | [ 下载] ( https://repo1.maven.org/maven2/com/oceanbase/oceanbase-client/ ) |
50+ | Driver | Group Id | Artifact Id | JAR |
51+ | :-----------| :---------------------------| :----------------------------| :----------------------------------------------------------------------------------------------------------------------------|
52+ | MySQL | ` mysql ` | ` mysql-connector-java ` | [ 下载] ( https://repo.maven.apache.org/maven2/mysql/mysql-connector-java/ ) |
53+ | Oracle | ` com.oracle.database.jdbc ` | ` ojdbc8 ` | [ 下载] ( https://mvnrepository.com/artifact/com.oracle.database.jdbc/ojdbc8 ) |
54+ | PostgreSQL | ` org.postgresql ` | ` postgresql ` | [ 下载] ( https://jdbc.postgresql.org/download/ ) |
55+ | Derby | ` org.apache.derby ` | ` derby ` | [ 下载] ( http://db.apache.org/derby/derby_downloads.html ) |
56+ | SQL Server | ` com.microsoft.sqlserver ` | ` mssql-jdbc ` | [ 下载] ( https://docs.microsoft.com/en-us/sql/connect/jdbc/download-microsoft-jdbc-driver-for-sql-server?view=sql-server-ver16 ) |
57+ | CrateDB | ` io.crate ` | ` crate-jdbc ` | [ 下载] ( https://repo1.maven.org/maven2/io/crate/crate-jdbc/ ) |
58+ | Db2 | ` com.ibm.db2.jcc ` | ` db2jcc ` | [ 下载] ( https://www.ibm.com/support/pages/download-db2-fix-packs-version-db2-linux-unix-and-windows ) |
59+ | Trino | ` io.trino ` | ` trino-jdbc ` | [ 下载] ( https://repo1.maven.org/maven2/io/trino/trino-jdbc/ ) |
60+ | OceanBase | ` com.oceanbase ` | ` oceanbase-client ` | [ 下载] ( https://repo1.maven.org/maven2/com/oceanbase/oceanbase-client/ ) |
61+ | Spanner | ` com.google.cloud ` | ` google-cloud-spanner-jdbc ` | [ 下载] ( https://central.sonatype.com/artifact/com.google.cloud/google-cloud-spanner-jdbc ) |
6162
6263当前,JDBC 连接器和驱动不在 Flink 二进制发布包中,请参阅[ 这里] ({{< ref "docs/dev/configuration/overview" >}})了解在集群上执行时如何连接它们。
6364
@@ -709,7 +710,7 @@ SELECT * FROM given_database.test_table2;
709710
710711数据类型映射
711712----------------
712- Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、Oracle、PostgreSQL、CrateDB, Derby、Db2、 SQL Server、OceanBase 等。其中,Derby 通常是用于测试目的。下表列出了从关系数据库数据类型到 Flink SQL 数据类型的类型映射,映射表可以使得在 Flink 中定义 JDBC 表更加简单。
713+ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、Oracle、PostgreSQL、CrateDB, Derby、Db2、 SQL Server、OceanBase、Spanner 等。其中,Derby 通常是用于测试目的。下表列出了从关系数据库数据类型到 Flink SQL 数据类型的类型映射,映射表可以使得在 Flink 中定义 JDBC 表更加简单。
713714
714715<table class =" table table-bordered " >
715716 <thead>
@@ -723,6 +724,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
723724 <th class="text-left"><a href="https://trino.io/docs/current/language/types.html">Trino type</a></th>
724725 <th class="text-left"><a href="https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000000222199">OceanBase MySQL mode type</a></th>
725726 <th class="text-left"><a href="https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000000222012">OceanBase Oracle mode type</a></th>
727+ <th class="text-left"><a href="https://cloud.google.com/spanner/docs/reference/standard-sql/data-types">Spanner type</a></th>
726728 <th class="text-left"><a href="{{< ref "docs/dev/table/types" >}}">Flink SQL type</a></th>
727729 </tr>
728730 </thead>
@@ -737,6 +739,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
737739 <td><code>TINYINT</code></td>
738740 <td><code>TINYINT</code></td>
739741 <td></td>
742+ <td></td>
740743 <td><code>TINYINT</code></td>
741744 </tr>
742745 <tr>
@@ -759,6 +762,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
759762 <code>SMALLINT</code><br>
760763 <code>TINYINT UNSIGNED</code></td>
761764 <td></td>
765+ <td></td>
762766 <td><code>SMALLINT</code></td>
763767 </tr>
764768 <tr>
@@ -781,6 +785,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
781785 <code>MEDIUMINT</code><br>
782786 <code>SMALLINT UNSIGNED</code></td>
783787 <td></td>
788+ <td></td>
784789 <td><code>INT</code></td>
785790 </tr>
786791 <tr>
@@ -801,6 +806,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
801806 <code>BIGINT</code><br>
802807 <code>INT UNSIGNED</code></td>
803808 <td></td>
809+ <td>INT64</td>
804810 <td><code>BIGINT</code></td>
805811 </tr>
806812 <tr >
@@ -813,6 +819,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
813819 <td></td>
814820 <td><code>BIGINT UNSIGNED</code></td>
815821 <td></td>
822+ <td>NUMERIC</td>
816823 <td><code>DECIMAL(20, 0)</code></td>
817824 </tr>
818825 <tr>
@@ -831,6 +838,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
831838 <td><code>FLOAT</code></td>
832839 <td>
833840 <code>BINARY_FLOAT</code></td>
841+ <td><code>FLOAT32</code></td>
834842 <td><code>FLOAT</code></td>
835843 </tr>
836844 <tr>
@@ -849,6 +857,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
849857 <td><code>DOUBLE</code></td>
850858 <td><code>DOUBLE</code></td>
851859 <td><code>BINARY_DOUBLE</code></td>
860+ <td><code>FLOAT64</code></td>
852861 <td><code>DOUBLE</code></td>
853862 </tr>
854863 <tr>
@@ -877,6 +886,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
877886 <td>
878887 <code>FLOAT(s)</code><br>
879888 <code>NUMBER(p, s)</code></td>
889+ <td><code>NUMERIC</code></td>
880890 <td><code>DECIMAL(p, s)</code></td>
881891 </tr>
882892 <tr>
@@ -894,6 +904,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
894904 <code>TINYINT(1)</code></td>
895905 <td></td>
896906 <td><code>BOOLEAN</code></td>
907+ <td><code>BOOLEAN</code></td>
897908 </tr>
898909 <tr>
899910 <td><code>DATE</code></td>
@@ -906,6 +917,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
906917 <td><code>DATE</code></td>
907918 <td><code>DATE</code></td>
908919 <td><code>DATE</code></td>
920+ <td><code>DATE</code></td>
909921 </tr>
910922 <tr>
911923 <td><code>TIME [(p)]</code></td>
@@ -917,6 +929,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
917929 <td><code>TIME_WITHOUT_TIME_ZONE</code></td>
918930 <td><code>TIME [(p)]</code></td>
919931 <td><code>DATE</code></td>
932+ <td><code></code></td>
920933 <td><code>TIME [(p)] [WITHOUT TIMEZONE]</code></td>
921934 </tr>
922935 <tr>
@@ -932,6 +945,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
932945 <td><code>TIMESTAMP_WITHOUT_TIME_ZONE</code></td>
933946 <td><code>DATETIME [(p)]</code></td>
934947 <td><code>TIMESTAMP [(p)] [WITHOUT TIMEZONE]</code></td>
948+ <td><code>TIMESTAMP [(p)]</code></td>
935949 <td><code>TIMESTAMP [(p)] [WITHOUT TIMEZONE]</code></td>
936950 </tr>
937951 <tr>
@@ -980,6 +994,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
980994 <code>NCHAR(n)</code><br>
981995 <code>VARCHAR2(n)</code><br>
982996 <code>CLOB</code></td>
997+ <td><code>STRING(n)</code></td>
983998 <td><code>STRING</code></td>
984999 </tr>
9851000 <tr>
@@ -1005,6 +1020,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
10051020 <td>
10061021 <code>RAW(s)</code><br>
10071022 <code>BLOB</code></td>
1023+ <td><code>BYTES(n)</code></td>
10081024 <td><code>BYTES</code></td>
10091025 </tr>
10101026 <tr>
@@ -1018,6 +1034,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
10181034 <td></td>
10191035 <td></td>
10201036 <td><code>ARRAY</code></td>
1037+ <td><code>ARRAY</code></td>
10211038 </tr>
10221039 </tbody>
10231040</table >
0 commit comments