@@ -47,17 +47,18 @@ JDBC 连接器不是二进制发行版的一部分,请查阅[这里]({{< ref "
47
47
48
48
在连接到具体数据库时,也需要对应的驱动依赖,目前支持的驱动如下:
49
49
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 ) |
61
62
62
63
当前,JDBC 连接器和驱动不在 Flink 二进制发布包中,请参阅[ 这里] ({{< ref "docs/dev/configuration/overview" >}})了解在集群上执行时如何连接它们。
63
64
@@ -709,7 +710,7 @@ SELECT * FROM given_database.test_table2;
709
710
710
711
数据类型映射
711
712
----------------
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 表更加简单。
713
714
714
715
<table class =" table table-bordered " >
715
716
<thead>
@@ -723,6 +724,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
723
724
<th class="text-left"><a href="https://trino.io/docs/current/language/types.html">Trino type</a></th>
724
725
<th class="text-left"><a href="https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000000222199">OceanBase MySQL mode type</a></th>
725
726
<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>
726
728
<th class="text-left"><a href="{{< ref "docs/dev/table/types" >}}">Flink SQL type</a></th>
727
729
</tr>
728
730
</thead>
@@ -737,6 +739,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
737
739
<td><code>TINYINT</code></td>
738
740
<td><code>TINYINT</code></td>
739
741
<td></td>
742
+ <td></td>
740
743
<td><code>TINYINT</code></td>
741
744
</tr>
742
745
<tr>
@@ -759,6 +762,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
759
762
<code>SMALLINT</code><br>
760
763
<code>TINYINT UNSIGNED</code></td>
761
764
<td></td>
765
+ <td></td>
762
766
<td><code>SMALLINT</code></td>
763
767
</tr>
764
768
<tr>
@@ -781,6 +785,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
781
785
<code>MEDIUMINT</code><br>
782
786
<code>SMALLINT UNSIGNED</code></td>
783
787
<td></td>
788
+ <td></td>
784
789
<td><code>INT</code></td>
785
790
</tr>
786
791
<tr>
@@ -801,6 +806,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
801
806
<code>BIGINT</code><br>
802
807
<code>INT UNSIGNED</code></td>
803
808
<td></td>
809
+ <td>INT64</td>
804
810
<td><code>BIGINT</code></td>
805
811
</tr>
806
812
<tr >
@@ -813,6 +819,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
813
819
<td></td>
814
820
<td><code>BIGINT UNSIGNED</code></td>
815
821
<td></td>
822
+ <td>NUMERIC</td>
816
823
<td><code>DECIMAL(20, 0)</code></td>
817
824
</tr>
818
825
<tr>
@@ -831,6 +838,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
831
838
<td><code>FLOAT</code></td>
832
839
<td>
833
840
<code>BINARY_FLOAT</code></td>
841
+ <td><code>FLOAT32</code></td>
834
842
<td><code>FLOAT</code></td>
835
843
</tr>
836
844
<tr>
@@ -849,6 +857,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
849
857
<td><code>DOUBLE</code></td>
850
858
<td><code>DOUBLE</code></td>
851
859
<td><code>BINARY_DOUBLE</code></td>
860
+ <td><code>FLOAT64</code></td>
852
861
<td><code>DOUBLE</code></td>
853
862
</tr>
854
863
<tr>
@@ -877,6 +886,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
877
886
<td>
878
887
<code>FLOAT(s)</code><br>
879
888
<code>NUMBER(p, s)</code></td>
889
+ <td><code>NUMERIC</code></td>
880
890
<td><code>DECIMAL(p, s)</code></td>
881
891
</tr>
882
892
<tr>
@@ -894,6 +904,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
894
904
<code>TINYINT(1)</code></td>
895
905
<td></td>
896
906
<td><code>BOOLEAN</code></td>
907
+ <td><code>BOOLEAN</code></td>
897
908
</tr>
898
909
<tr>
899
910
<td><code>DATE</code></td>
@@ -906,6 +917,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
906
917
<td><code>DATE</code></td>
907
918
<td><code>DATE</code></td>
908
919
<td><code>DATE</code></td>
920
+ <td><code>DATE</code></td>
909
921
</tr>
910
922
<tr>
911
923
<td><code>TIME [(p)]</code></td>
@@ -917,6 +929,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
917
929
<td><code>TIME_WITHOUT_TIME_ZONE</code></td>
918
930
<td><code>TIME [(p)]</code></td>
919
931
<td><code>DATE</code></td>
932
+ <td><code></code></td>
920
933
<td><code>TIME [(p)] [WITHOUT TIMEZONE]</code></td>
921
934
</tr>
922
935
<tr>
@@ -932,6 +945,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
932
945
<td><code>TIMESTAMP_WITHOUT_TIME_ZONE</code></td>
933
946
<td><code>DATETIME [(p)]</code></td>
934
947
<td><code>TIMESTAMP [(p)] [WITHOUT TIMEZONE]</code></td>
948
+ <td><code>TIMESTAMP [(p)]</code></td>
935
949
<td><code>TIMESTAMP [(p)] [WITHOUT TIMEZONE]</code></td>
936
950
</tr>
937
951
<tr>
@@ -980,6 +994,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
980
994
<code>NCHAR(n)</code><br>
981
995
<code>VARCHAR2(n)</code><br>
982
996
<code>CLOB</code></td>
997
+ <td><code>STRING(n)</code></td>
983
998
<td><code>STRING</code></td>
984
999
</tr>
985
1000
<tr>
@@ -1005,6 +1020,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
1005
1020
<td>
1006
1021
<code>RAW(s)</code><br>
1007
1022
<code>BLOB</code></td>
1023
+ <td><code>BYTES(n)</code></td>
1008
1024
<td><code>BYTES</code></td>
1009
1025
</tr>
1010
1026
<tr>
@@ -1018,6 +1034,7 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
1018
1034
<td></td>
1019
1035
<td></td>
1020
1036
<td><code>ARRAY</code></td>
1037
+ <td><code>ARRAY</code></td>
1021
1038
</tr>
1022
1039
</tbody>
1023
1040
</table >
0 commit comments