fix

eitam · eitam · commit a8be9f69674c · 2025-09-01T10:31:25.000+03:00
diff --git a/replication/row_event.go b/replication/row_event.go
@@ -1415,7 +1415,7 @@ func decodeStringWithEncoder(data []byte, length int, enc encoding.Encoding) (v
 		n = length + 1
 		decodedBytes, _, _ := transform.Bytes(decoder, data[1:n])
 		if !supportsSmartQuotes(enc) {
-			decodedBytes = normalizeSmartQuotes(decodedBytes)
+			data = replaceUnsupportedCharacters(data, length)
 		}
 		v = string(decodedBytes)
 	} else {
@@ -1424,10 +1424,11 @@ func decodeStringWithEncoder(data []byte, length int, enc encoding.Encoding) (v
 		n = length + 2
 		decodedBytes, _, _ := transform.Bytes(decoder, data[2:n])
 		if !supportsSmartQuotes(enc) {
-			decodedBytes = normalizeSmartQuotes(decodedBytes)
+			data = replaceUnsupportedCharacters(data, length)
 		}
 		v = string(decodedBytes)
 	}
+
 	return
 }
 

Original file line number	Diff line number	Diff line change
`@@ -1415,7 +1415,7 @@ func decodeStringWithEncoder(data []byte, length int, enc encoding.Encoding) (v`
`1415`	`1415`	`n = length + 1`
`1416`	`1416`	`decodedBytes, _, _ := transform.Bytes(decoder, data[1:n])`
`1417`	`1417`	`if !supportsSmartQuotes(enc) {`
`1418`		`- decodedBytes = normalizeSmartQuotes(decodedBytes)`
	`1418`	`+ data = replaceUnsupportedCharacters(data, length)`
`1419`	`1419`	`}`
`1420`	`1420`	`v = string(decodedBytes)`
`1421`	`1421`	`} else {`
`@@ -1424,10 +1424,11 @@ func decodeStringWithEncoder(data []byte, length int, enc encoding.Encoding) (v`
`1424`	`1424`	`n = length + 2`
`1425`	`1425`	`decodedBytes, _, _ := transform.Bytes(decoder, data[2:n])`
`1426`	`1426`	`if !supportsSmartQuotes(enc) {`
`1427`		`- decodedBytes = normalizeSmartQuotes(decodedBytes)`
	`1427`	`+ data = replaceUnsupportedCharacters(data, length)`
`1428`	`1428`	`}`
`1429`	`1429`	`v = string(decodedBytes)`
`1430`	`1430`	`}`
	`1431`	`+`
`1431`	`1432`	`return`
`1432`	`1433`	`}`
`1433`	`1434`