Skip to content

Commit 2ce0580

Browse files
committed
Made charset and error behaviour class members of QueryEvent.
Re-pushed because I forgot to add self. to charset and on_errors. Also added keywords to make it more explicit.
1 parent 5e3e1df commit 2ce0580

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

pymysqlreplication/event.py

+4-1
Original file line numberDiff line numberDiff line change
@@ -155,6 +155,8 @@ def _dump(self):
155155

156156

157157
class QueryEvent(BinLogEvent):
158+
charset = 'utf-8'
159+
on_errors = 'strict'
158160
'''This evenement is trigger when a query is run of the database.
159161
Only replicated queries are logged.'''
160162
def __init__(self, from_packet, event_size, table_map, ctl_connection, **kwargs):
@@ -174,7 +176,8 @@ def __init__(self, from_packet, event_size, table_map, ctl_connection, **kwargs)
174176
self.packet.advance(1)
175177

176178
self.query = self.packet.read(event_size - 13 - self.status_vars_length
177-
- self.schema_length - 1).decode("utf-8")
179+
- self.schema_length - 1).decode(
180+
encoding=self.charset, errors=self.on_errors)
178181
#string[EOF] query
179182

180183
def _dump(self):

0 commit comments

Comments
 (0)