Skip to content

Commit dc44dd6

Browse files
committed
fix when binary decode
1 parent 32d4175 commit dc44dd6

File tree

1 file changed

+1
-10
lines changed

1 file changed

+1
-10
lines changed

pymysqlreplication/row_event.py

+1-10
Original file line numberDiff line numberDiff line change
@@ -1056,15 +1056,6 @@ def _is_numeric_column(column_type):
10561056
return False
10571057

10581058

1059-
def find_encoding(charset: CHARSET.Charset):
1060-
encode = None
1061-
if charset.is_binary:
1062-
encode = "utf8"
1063-
else:
1064-
encode = charset.encoding
1065-
return encode
1066-
1067-
10681059
def find_charset(charset_id, dbms="mysql"):
10691060
encode = None
10701061
collation_name = None
@@ -1074,7 +1065,7 @@ def find_charset(charset_id, dbms="mysql"):
10741065
encode = "utf8"
10751066
charset_name = "utf8"
10761067
else:
1077-
encode = find_encoding(charset)
1068+
encode = charset.encoding
10781069
collation_name = charset.collation
10791070
charset_name = charset.name
10801071
return encode, collation_name, charset_name

0 commit comments

Comments
 (0)