From ae81f33254a0d186eb26dddd4f11e9d8ee3bfff5 Mon Sep 17 00:00:00 2001 From: Yastrebov Denis Date: Fri, 22 Feb 2019 17:29:50 +0300 Subject: [PATCH] fix for non utf8 query event --- pymysqlreplication/event.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pymysqlreplication/event.py b/pymysqlreplication/event.py index 97ff5817..027b5fb8 100644 --- a/pymysqlreplication/event.py +++ b/pymysqlreplication/event.py @@ -174,7 +174,7 @@ def __init__(self, from_packet, event_size, table_map, ctl_connection, **kwargs) self.packet.advance(1) self.query = self.packet.read(event_size - 13 - self.status_vars_length - - self.schema_length - 1).decode("utf-8") + - self.schema_length - 1).decode(ctl_connection.charset) #string[EOF] query def _dump(self):