@@ -45,13 +45,14 @@ See how to link with it for cluster execution [here]({{< ref "docs/dev/configura
4545
4646A driver dependency is also required to connect to a specified database. Here are drivers currently supported:
4747
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 ) |
5556
5657
5758JDBC 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
614615 <th class="text-left"><a href="https://docs.oracle.com/database/121/SQLRF/sql_elements001.htm#SQLRF30020">Oracle type</a></th>
615616 <th class="text-left"><a href="https://www.postgresql.org/docs/12/datatype.html">PostgreSQL type</a></th>
616617 <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>
617619 <th class="text-left"><a href="{{< ref "docs/dev/table/types" >}}">Flink SQL type</a></th>
618620 </tr>
619621 </thead>
@@ -623,6 +625,7 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
623625 <td></td>
624626 <td></td>
625627 <td><code>TINYINT</code></td>
628+ <td><code>BYTE</code></td>
626629 <td><code>TINYINT</code></td>
627630 </tr>
628631 <tr>
@@ -636,6 +639,7 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
636639 <code>SMALLSERIAL</code><br>
637640 <code>SERIAL2</code></td>
638641 <td><code>SMALLINT</code></td>
642+ <td><code>SHORT</code></td>
639643 <td><code>SMALLINT</code></td>
640644 </tr>
641645 <tr>
@@ -648,6 +652,7 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
648652 <code>INTEGER</code><br>
649653 <code>SERIAL</code></td>
650654 <td><code>INT</code></td>
655+ <td><code>INTEGER</code></td>
651656 <td><code>INT</code></td>
652657 </tr>
653658 <tr>
@@ -659,13 +664,17 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
659664 <code>BIGINT</code><br>
660665 <code>BIGSERIAL</code></td>
661666 <td><code>BIGINT</code></td>
667+ <td>
668+ <code>LONG</code><br>
669+ <code>UNSIGNED_LONG</code></td>
662670 <td><code>BIGINT</code></td>
663671 </tr>
664672 <tr >
665673 <td><code>BIGINT UNSIGNED</code></td>
666674 <td></td>
667675 <td></td>
668676 <td></td>
677+ <td></td>
669678 <td><code>DECIMAL(20, 0)</code></td>
670679 </tr>
671680 <tr>
@@ -676,6 +685,9 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
676685 <code>REAL</code><br>
677686 <code>FLOAT4</code></td>
678687 <td><code>REAL</code></td>
688+ <td>
689+ <code>FLOAT</code><br>
690+ <code>HALF_FLOAT</code></td>
679691 <td><code>FLOAT</code></td>
680692 </tr>
681693 <tr>
@@ -687,6 +699,9 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
687699 <code>FLOAT8</code><br>
688700 <code>DOUBLE PRECISION</code></td>
689701 <td><code>FLOAT</code></td>
702+ <td>
703+ <code>DOUBLE</code><br>
704+ <code>SCALED_FLOAT</code></td>
690705 <td><code>DOUBLE</code></td>
691706 </tr>
692707 <tr>
@@ -703,6 +718,7 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
703718 <code>NUMERIC(p, s)</code><br>
704719 <code>DECIMAL(p, s)</code></td>
705720 <td><code>DECIMAL(p, s)</code></td>
721+ <td></td>
706722 <td><code>DECIMAL(p, s)</code></td>
707723 </tr>
708724 <tr>
@@ -713,19 +729,22 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
713729 <td><code>BOOLEAN</code></td>
714730 <td><code>BIT</code></td>
715731 <td><code>BOOLEAN</code></td>
732+ <td><code>BOOLEAN</code></td>
716733 </tr>
717734 <tr>
718735 <td><code>DATE</code></td>
719736 <td><code>DATE</code></td>
720737 <td><code>DATE</code></td>
721738 <td><code>DATE</code></td>
739+ <td></td>
722740 <td><code>DATE</code></td>
723741 </tr>
724742 <tr>
725743 <td><code>TIME [(p)]</code></td>
726744 <td><code>DATE</code></td>
727745 <td><code>TIME [(p)] [WITHOUT TIMEZONE]</code></td>
728746 <td><code>TIME(0)</code></td>
747+ <td></td>
729748 <td><code>TIME [(p)] [WITHOUT TIMEZONE]</code></td>
730749 </tr>
731750 <tr>
@@ -736,6 +755,7 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
736755 <code>DATETIME</code>
737756 <code>DATETIME2</code>
738757 </td>
758+ <td><code>TIMESTAMP</code></td>
739759 <td><code>TIMESTAMP [(p)] [WITHOUT TIMEZONE]</code></td>
740760 </tr>
741761 <tr>
@@ -760,6 +780,11 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
760780 <code>NVARCHAR(n)</code><br>
761781 <code>TEXT</code><br>
762782 <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>
763788 <td><code>STRING</code></td>
764789 </tr>
765790 <tr>
@@ -774,13 +799,15 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
774799 <td>
775800 <code>BINARY(n)</code><br>
776801 <code>VARBINARY(n)</code><br></td>
802+ <td><code>BINARY</code></td>
777803 <td><code>BYTES</code></td>
778804 </tr>
779805 <tr>
780806 <td></td>
781807 <td></td>
782808 <td><code>ARRAY</code></td>
783809 <td></td>
810+ <td></td>
784811 <td><code>ARRAY</code></td>
785812 </tr>
786813 </tbody>
0 commit comments