added fix for non utf8 query event

Author: mastak

pymysqlreplication/event.py

@@ -137,7 +137,8 @@ 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)
+        self.query = self._decode_query(self.query)
         #string[EOF]    query
 
     def _dump(self):
@@ -146,6 +147,9 @@ def _dump(self):
         print("Execution time: %d" % (self.execution_time))
         print("Query: %s" % (self.query))
 
+    def _decode_query(self, query):
+        return query.decode("utf-8")
+
 
 class BeginLoadQueryEvent(BinLogEvent):
     """