From 9e61cb1422daf55a505d09a6a11f29225ead7b10 Mon Sep 17 00:00:00 2001
From: Lubimov Igor <infunt@gmail.com>
Date: Wed, 30 Dec 2015 16:49:57 +0200
Subject: [PATCH] added fix for non utf8 query event

---
 pymysqlreplication/event.py | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/pymysqlreplication/event.py b/pymysqlreplication/event.py
index 7f02e424..fe8d6e31 100644
--- a/pymysqlreplication/event.py
+++ b/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):
     """