Skip to content

Commit f65eb13

Browse files
committed
fix INET types handling
1 parent c0ea3e6 commit f65eb13

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

flow/connectors/mysql/cdc_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -411,8 +411,8 @@ func TestQkindFromMysSQLTypeForUnsupportedDDLTypes(t *testing.T) {
411411
{"clob", types.QValueKindString}, // LONGTEXT (Oracle mode)
412412
{"varchar2", types.QValueKindString}, // VARCHAR (Oracle mode)
413413
{"xmltype", types.QValueKindString}, // XML stored as text (MariaDB 12.3+)
414-
{"inet(4)", types.QValueKindINET},
415-
{"inet(6)", types.QValueKindINET},
414+
{"inet4", types.QValueKindINET},
415+
{"inet6", types.QValueKindINET},
416416
{"uuid", types.QValueKindUUID},
417417
} {
418418
t.Run(tc.ct, func(t *testing.T) {

flow/connectors/mysql/type_conversion.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ func QkindFromMysqlColumnType(ct string, binlogRowMetadataSupported bool, versio
7474
return types.QValueKindArrayFloat32, nil
7575
case "uuid": // maria
7676
return types.QValueKindUUID, nil
77-
case "inet": // maria
77+
case "inet4", "inet6": // maria
7878
return types.QValueKindINET, nil
7979
case "geometry", "point", "polygon", "linestring", "multipoint", "multilinestring", "multipolygon", "geomcollection", "geometrycollection":
8080
return types.QValueKindGeometry, nil

0 commit comments

Comments
 (0)