[Feature][Connector-V2][mysql cdc] Conversion of tinyint(1) to bool i…

…s supported (#5105) Co-authored-by: zhouyao <yao.zhou@marketingforce.com>
apache · Jul 20, 2023 · 86b1b7e · 86b1b7e
1 parent 2e92c98
commit 86b1b7e
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...c/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlTypeUtils.java b/...c/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlTypeUtils.java
@@ -87,6 +87,7 @@ public static SeaTunnelDataType<?> convertFromColumn(Column column) {
             case MYSQL_BIT:
                 return BasicType.BOOLEAN_TYPE;
             case MYSQL_TINYINT:
+                return column.length() == 1 ? BasicType.BOOLEAN_TYPE : BasicType.INT_TYPE;
             case MYSQL_TINYINT_UNSIGNED:
             case MYSQL_SMALLINT:
             case MYSQL_SMALLINT_UNSIGNED: