@@ -45,13 +45,14 @@ See how to link with it for cluster execution [here]({{< ref "docs/dev/configura
45
45
46
46
A driver dependency is also required to connect to a specified database. Here are drivers currently supported:
47
47
48
- | Driver | Group Id | Artifact Id | JAR |
49
- | :-----------| :------------------| :----------------------| :----------------|
50
- | MySQL | ` mysql ` | ` mysql-connector-java ` | [ Download] ( https://repo.maven.apache.org/maven2/mysql/mysql-connector-java/ ) |
51
- | Oracle | ` com.oracle.database.jdbc ` | ` ojdbc8 ` | [ Download] ( https://mvnrepository.com/artifact/com.oracle.database.jdbc/ojdbc8 ) |
52
- | PostgreSQL | ` org.postgresql ` | ` postgresql ` | [ Download] ( https://jdbc.postgresql.org/download.html ) |
53
- | Derby | ` org.apache.derby ` | ` derby ` | [ Download] ( http://db.apache.org/derby/derby_downloads.html ) |
54
- | SQL Server | ` com.microsoft.sqlserver ` | ` mssql-jdbc ` | [ Download] ( https://docs.microsoft.com/en-us/sql/connect/jdbc/download-microsoft-jdbc-driver-for-sql-server?view=sql-server-ver16 ) |
48
+ | Driver | Group Id | Artifact Id | JAR |
49
+ | :--------------| :------------------| :----------------------| :----------------|
50
+ | MySQL | ` mysql ` | ` mysql-connector-java ` | [ Download] ( https://repo.maven.apache.org/maven2/mysql/mysql-connector-java/ ) |
51
+ | Oracle | ` com.oracle.database.jdbc ` | ` ojdbc8 ` | [ Download] ( https://mvnrepository.com/artifact/com.oracle.database.jdbc/ojdbc8 ) |
52
+ | PostgreSQL | ` org.postgresql ` | ` postgresql ` | [ Download] ( https://jdbc.postgresql.org/download.html ) |
53
+ | Derby | ` org.apache.derby ` | ` derby ` | [ Download] ( http://db.apache.org/derby/derby_downloads.html ) |
54
+ | SQL Server | ` com.microsoft.sqlserver ` | ` mssql-jdbc ` | [ Download] ( https://docs.microsoft.com/en-us/sql/connect/jdbc/download-microsoft-jdbc-driver-for-sql-server?view=sql-server-ver16 ) |
55
+ | Elasticsearch | ` org.elasticsearch.plugin ` | ` x-pack-sql-jdbc ` | [ Download] ( https://www.elastic.co/downloads/jdbc-client ) |
55
56
56
57
57
58
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" >}}).
@@ -614,6 +615,7 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
614
615
<th class="text-left"><a href="https://docs.oracle.com/database/121/SQLRF/sql_elements001.htm#SQLRF30020">Oracle type</a></th>
615
616
<th class="text-left"><a href="https://www.postgresql.org/docs/12/datatype.html">PostgreSQL type</a></th>
616
617
<th class="text-left"><a href="https://docs.microsoft.com/en-us/sql/t-sql/data-types/data-types-transact-sql?view=sql-server-ver16">SQL Server type</a></th>
618
+ <th class="text-left"><a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/sql-data-types.html">Elastic SQL type</a></th>
617
619
<th class="text-left"><a href="{{< ref "docs/dev/table/types" >}}">Flink SQL type</a></th>
618
620
</tr>
619
621
</thead>
@@ -623,6 +625,7 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
623
625
<td></td>
624
626
<td></td>
625
627
<td><code>TINYINT</code></td>
628
+ <td><code>BYTE</code></td>
626
629
<td><code>TINYINT</code></td>
627
630
</tr>
628
631
<tr>
@@ -636,6 +639,7 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
636
639
<code>SMALLSERIAL</code><br>
637
640
<code>SERIAL2</code></td>
638
641
<td><code>SMALLINT</code></td>
642
+ <td><code>SHORT</code></td>
639
643
<td><code>SMALLINT</code></td>
640
644
</tr>
641
645
<tr>
@@ -648,6 +652,7 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
648
652
<code>INTEGER</code><br>
649
653
<code>SERIAL</code></td>
650
654
<td><code>INT</code></td>
655
+ <td><code>INTEGER</code></td>
651
656
<td><code>INT</code></td>
652
657
</tr>
653
658
<tr>
@@ -659,13 +664,17 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
659
664
<code>BIGINT</code><br>
660
665
<code>BIGSERIAL</code></td>
661
666
<td><code>BIGINT</code></td>
667
+ <td>
668
+ <code>LONG</code><br>
669
+ <code>UNSIGNED_LONG</code></td>
662
670
<td><code>BIGINT</code></td>
663
671
</tr>
664
672
<tr >
665
673
<td><code>BIGINT UNSIGNED</code></td>
666
674
<td></td>
667
675
<td></td>
668
676
<td></td>
677
+ <td></td>
669
678
<td><code>DECIMAL(20, 0)</code></td>
670
679
</tr>
671
680
<tr>
@@ -676,6 +685,9 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
676
685
<code>REAL</code><br>
677
686
<code>FLOAT4</code></td>
678
687
<td><code>REAL</code></td>
688
+ <td>
689
+ <code>FLOAT</code><br>
690
+ <code>HALF_FLOAT</code></td>
679
691
<td><code>FLOAT</code></td>
680
692
</tr>
681
693
<tr>
@@ -687,6 +699,9 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
687
699
<code>FLOAT8</code><br>
688
700
<code>DOUBLE PRECISION</code></td>
689
701
<td><code>FLOAT</code></td>
702
+ <td>
703
+ <code>DOUBLE</code><br>
704
+ <code>SCALED_FLOAT</code></td>
690
705
<td><code>DOUBLE</code></td>
691
706
</tr>
692
707
<tr>
@@ -703,6 +718,7 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
703
718
<code>NUMERIC(p, s)</code><br>
704
719
<code>DECIMAL(p, s)</code></td>
705
720
<td><code>DECIMAL(p, s)</code></td>
721
+ <td></td>
706
722
<td><code>DECIMAL(p, s)</code></td>
707
723
</tr>
708
724
<tr>
@@ -713,19 +729,22 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
713
729
<td><code>BOOLEAN</code></td>
714
730
<td><code>BIT</code></td>
715
731
<td><code>BOOLEAN</code></td>
732
+ <td><code>BOOLEAN</code></td>
716
733
</tr>
717
734
<tr>
718
735
<td><code>DATE</code></td>
719
736
<td><code>DATE</code></td>
720
737
<td><code>DATE</code></td>
721
738
<td><code>DATE</code></td>
739
+ <td></td>
722
740
<td><code>DATE</code></td>
723
741
</tr>
724
742
<tr>
725
743
<td><code>TIME [(p)]</code></td>
726
744
<td><code>DATE</code></td>
727
745
<td><code>TIME [(p)] [WITHOUT TIMEZONE]</code></td>
728
746
<td><code>TIME(0)</code></td>
747
+ <td></td>
729
748
<td><code>TIME [(p)] [WITHOUT TIMEZONE]</code></td>
730
749
</tr>
731
750
<tr>
@@ -736,6 +755,7 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
736
755
<code>DATETIME</code>
737
756
<code>DATETIME2</code>
738
757
</td>
758
+ <td><code>TIMESTAMP</code></td>
739
759
<td><code>TIMESTAMP [(p)] [WITHOUT TIMEZONE]</code></td>
740
760
</tr>
741
761
<tr>
@@ -760,6 +780,11 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
760
780
<code>NVARCHAR(n)</code><br>
761
781
<code>TEXT</code><br>
762
782
<code>NTEXT</code></td>
783
+ <td>
784
+ <code>KEYWORD</code><br>
785
+ <code>IP</code><br>
786
+ <code>TEXT</code><br>
787
+ <code>VERSION</code></td>
763
788
<td><code>STRING</code></td>
764
789
</tr>
765
790
<tr>
@@ -774,13 +799,15 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
774
799
<td>
775
800
<code>BINARY(n)</code><br>
776
801
<code>VARBINARY(n)</code><br></td>
802
+ <td><code>BINARY</code></td>
777
803
<td><code>BYTES</code></td>
778
804
</tr>
779
805
<tr>
780
806
<td></td>
781
807
<td></td>
782
808
<td><code>ARRAY</code></td>
783
809
<td></td>
810
+ <td></td>
784
811
<td><code>ARRAY</code></td>
785
812
</tr>
786
813
</tbody>
0 commit comments