Skip to content

Commit 682ee65

Browse files
Jackeyzhejackeyzhe
andauthored
[FLINK-38498] Support Mysql Timestamp and Postgres Timestamp_tz type. (#196)
Co-authored-by: jackeyzhe <jackeyzhe59@gmail.com>
1 parent 444707b commit 682ee65

2 files changed

Lines changed: 32 additions & 2 deletions

File tree

  • docs
    • content.zh/docs/connectors/table
    • content/docs/connectors/table

docs/content.zh/docs/connectors/table/jdbc.md

Lines changed: 16 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -920,7 +920,10 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
920920
<td><code>TIME [(p)] [WITHOUT TIMEZONE]</code></td>
921921
</tr>
922922
<tr>
923-
<td><code>DATETIME [(p)]</code></td>
923+
<td>
924+
<code>DATETIME [(p)]</code><br>
925+
<code>TIMESTAMP [(p)]</code>
926+
</td>
924927
<td><code>TIMESTAMP [(p)] [WITHOUT TIMEZONE]</code></td>
925928
<td><code>TIMESTAMP [(p)] [WITHOUT TIMEZONE]</code></td>
926929
<td><code>TIMESTAMP [(p)] [WITHOUT TIMEZONE]</code></td>
@@ -934,6 +937,18 @@ Flink 支持连接到多个使用方言(dialect)的数据库,如 MySQL、O
934937
<td><code>TIMESTAMP [(p)] [WITHOUT TIMEZONE]</code></td>
935938
<td><code>TIMESTAMP [(p)] [WITHOUT TIMEZONE]</code></td>
936939
</tr>
940+
<tr>
941+
<td></td>
942+
<td><code>TIMESTAMP [(p)] [WITH TIMEZONE]</code></td>
943+
<td><code>TIMESTAMP [(p)] [WITH TIMEZONE]</code></td>
944+
<td><code>TIMESTAMP [(p)] [WITH TIMEZONE]</code></td>
945+
<td><code>DATETIMEOFFSET</code></td>
946+
<td><code>TIMESTAMP [(p)]</code></td>
947+
<td><code>TIMESTAMP_WITH_TIME_ZONE</code></td>
948+
<td><code>TIMESTAMP [(p)]</code></td>
949+
<td><code>TIMESTAMP [(p)] [WITH TIMEZONE]</code></td>
950+
<td><code>TIMESTAMP [(p)] [WITH TIMEZONE]</code></td>
951+
</tr>
937952
<tr>
938953
<td>
939954
<code>CHAR(n)</code><br>

docs/content/docs/connectors/table/jdbc.md

Lines changed: 16 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -913,7 +913,10 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
913913
<td><code>TIME [(p)] [WITHOUT TIMEZONE]</code></td>
914914
</tr>
915915
<tr>
916-
<td><code>DATETIME [(p)]</code></td>
916+
<td>
917+
<code>DATETIME [(p)]</code><br>
918+
<code>TIMESTAMP [(p)]</code>
919+
</td>
917920
<td><code>TIMESTAMP [(p)] [WITHOUT TIMEZONE]</code></td>
918921
<td><code>TIMESTAMP [(p)] [WITHOUT TIMEZONE]</code></td>
919922
<td><code>TIMESTAMP [(p)] [WITHOUT TIMEZONE]</code></td>
@@ -927,6 +930,18 @@ Flink supports connect to several databases which uses dialect like MySQL, Oracl
927930
<td><code>TIMESTAMP [(p)] [WITHOUT TIMEZONE]</code></td>
928931
<td><code>TIMESTAMP [(p)] [WITHOUT TIMEZONE]</code></td>
929932
</tr>
933+
<tr>
934+
<td></td>
935+
<td><code>TIMESTAMP [(p)] [WITH TIMEZONE]</code></td>
936+
<td><code>TIMESTAMP [(p)] [WITH TIMEZONE]</code></td>
937+
<td><code>TIMESTAMP [(p)] [WITH TIMEZONE]</code></td>
938+
<td><code>DATETIMEOFFSET</code></td>
939+
<td><code>TIMESTAMP [(p)]</code></td>
940+
<td><code>TIMESTAMP_WITH_TIME_ZONE</code></td>
941+
<td><code>TIMESTAMP [(p)]</code></td>
942+
<td><code>TIMESTAMP [(p)] [WITH TIMEZONE]</code></td>
943+
<td><code>TIMESTAMP [(p)] [WITH TIMEZONE]</code></td>
944+
</tr>
930945
<tr>
931946
<td>
932947
<code>CHAR(n)</code><br>

0 commit comments

Comments
 (0)