added fix for non utf8 query event

julien-duponchelle · Jul 13, 2016 · 3fd7f38 · 3fd7f38
1 parent f175d2b
commit 3fd7f38
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/pymysqlreplication/event.py b/pymysqlreplication/event.py
@@ -137,7 +137,12 @@ 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)
+
+        try:
+            self.query = self.query.decode("utf-8")
+        except UnicodeDecodeError:
+            self.query = self.query.decode("latin-1")
         #string[EOF]    query
 
     def _dump(self):