fix int2byte() import.

Author: naihe2010

pymysqlreplication/binlogstream.py

@@ -6,7 +6,7 @@
 
 from pymysql.constants.COMMAND import COM_BINLOG_DUMP, COM_REGISTER_SLAVE
 from pymysql.cursors import DictCursor
-from pymysql.util import int2byte
+from six import int2byte
 
 from .packet import BinLogPacketWrapper
 from .constants.BINLOG import TABLE_MAP_EVENT, ROTATE_EVENT

pymysqlreplication/event.py

@@ -4,7 +4,7 @@
 import struct
 import datetime
 
-from pymysql.util import byte2int, int2byte
+from six import byte2int, int2byte
 
 
 class BinLogEvent(object):

pymysqlreplication/packet.py

@@ -2,7 +2,7 @@
 
 import struct
 
-from pymysql.util import byte2int
+from six import byte2int
 
 from pymysqlreplication import constants, event, row_event
 

pymysqlreplication/row_event.py

@@ -3,9 +3,9 @@
 import struct
 import decimal
 import datetime
-import json
+# import json
 
-from pymysql.util import byte2int
+from six import byte2int
 from pymysql.charset import charset_by_name
 
 from .event import BinLogEvent
@@ -617,7 +617,7 @@ def __init__(self, from_packet, event_size, table_map, ctl_connection, **kwargs)
                         'COLUMN_TYPE': 'BLOB',  # we don't know what it is, so let's not do anything with it.
                         'COLUMN_KEY': '',
                     }
-                col = Column(byte2int(column_type), column_schema, from_packet)
+                col = Column(column_type, column_schema, from_packet)
                 self.columns.append(col)
 
         self.table_obj = Table(self.column_schemas, self.table_id, self.schema,