Skip to content

Commit 0e707e1

Browse files
fix
1 parent b4a8d23 commit 0e707e1

File tree

1 file changed

+0
-42
lines changed

1 file changed

+0
-42
lines changed

replication/row_event.go

Lines changed: 0 additions & 42 deletions
Original file line numberDiff line numberDiff line change
@@ -1363,48 +1363,6 @@ func supportsSmartQuotes(enc encoding.Encoding) bool {
13631363
return false
13641364
}
13651365

1366-
func replaceUnsupportedCharacters(data []byte, length int) []byte {
1367-
if len(data) == 0 {
1368-
return data
1369-
}
1370-
1371-
var content []byte
1372-
var prefix []byte
1373-
var contentLength int
1374-
var prefixLen int
1375-
1376-
if length > 255 {
1377-
// 2-byte length prefix (LittleEndian)
1378-
prefixLen = 2
1379-
contentLength = int(binary.LittleEndian.Uint16(data[:2]))
1380-
if contentLength > len(data)-prefixLen {
1381-
contentLength = len(data) - prefixLen
1382-
}
1383-
content = data[prefixLen : prefixLen+contentLength]
1384-
} else {
1385-
// 1-byte length prefix
1386-
prefixLen = 1
1387-
contentLength = int(data[0])
1388-
if contentLength > len(data)-prefixLen {
1389-
contentLength = len(data) - prefixLen
1390-
}
1391-
content = data[prefixLen : prefixLen+contentLength]
1392-
}
1393-
1394-
// Replace unsupported characters
1395-
content = normalizeSmartQuotes(content)
1396-
1397-
// Rebuild prefix with new length
1398-
if prefixLen == 2 {
1399-
prefix = make([]byte, 2)
1400-
binary.LittleEndian.PutUint16(prefix, uint16(len(content)))
1401-
} else {
1402-
prefix = []byte{byte(len(content))}
1403-
}
1404-
1405-
return append(prefix, content...)
1406-
}
1407-
14081366
func decodeStringWithEncoder(data []byte, length int, enc encoding.Encoding) (v string, n int) {
14091367
decoder := enc.NewDecoder()
14101368
if length < 256 {

0 commit comments

Comments
 (0)