[MySQL] Support Linestring (#412)

integration_tests/mysql/main.go

@@ -106,7 +106,8 @@ CREATE TABLE %s (
 	c_set SET('one', 'two', 'three'),
 	c_json JSON,
 	c_point POINT,
-	c_geom GEOMETRY NOT NULL
+	c_geom GEOMETRY NOT NULL,
+    c_linestring LINESTRING NOT NULL
 )
 `
 
@@ -177,7 +178,9 @@ INSERT INTO %s VALUES (
 	-- c_point
 		POINT(12.34, 56.78),
 	-- c_geom
-		ST_GeomFromText('POINT(1 1)')
+		ST_GeomFromText('POINT(1 1)'),
+	-- c_linestring
+		ST_GeomFromText('LINESTRING(0 0, 1 1, 2 2)')
 )
 `
 
@@ -457,6 +460,14 @@ const expectedPayloadTemplate = `{
 						"field": "c_geom",
 						"name": "io.debezium.data.geometry.Geometry",
 						"parameters": null
+					},
+					{
+						"type": "struct",
+						"optional": false,
+						"default": null,
+						"field": "c_linestring",
+						"name": "io.debezium.data.geometry.Geometry",
+						"parameters": null
 					}
 				],
 				"optional": false,
@@ -487,6 +498,10 @@ const expectedPayloadTemplate = `{
 			"c_int": 4,
 			"c_int_unsigned": 55,
 			"c_json": "{\"key1\": \"value1\", \"key2\": \"value2\"}",
+			"c_linestring": {
+				"srid": 0,
+				"wkb": "AQIAAAADAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAPA/AAAAAAAA8D8AAAAAAAAAQAAAAAAAAABA"
+			},
 			"c_mediumint": 3,
 			"c_mediumint_unsigned": 4,
 			"c_numeric": "AN3M",

lib/mysql/schema/convert.go

@@ -144,8 +144,8 @@ func ConvertValue(value any, colType DataType) (any, error) {
 			return nil, fmt.Errorf("expected []byte got %T for value: %v", value, value)
 		}
 
-		if len(bytes) != 25 {
-			return nil, fmt.Errorf("expected []byte with length 25, length is %d", len(bytes))
+		if len(bytes) < 25 {
+			return nil, fmt.Errorf("expected []byte with at least length 25, length is %d", len(bytes))
 		}
 
 		var byteOrder binary.ByteOrder