fix pymysql version compare bug

Author: maralla

pymysqlreplication/binlogstream.py

@@ -114,7 +114,7 @@ def __connect_to_stream(self):
         prelude += struct.pack('<I', self.__server_id)
         prelude += self.log_file.encode()
 
-        if pymysql.VERSION < (0, 6, None):
+        if pymysql.__version__ < "0.6":
             self._stream_connection.wfile.write(prelude)
             self._stream_connection.wfile.flush()
         else:
@@ -130,7 +130,7 @@ def fetchone(self):
                 self.__connect_to_ctl()
 
             try:
-                if pymysql.VERSION < (0, 6, None):
+                if pymysql.__version__ < "0.6":
                     pkt = self._stream_connection.read_packet()
                 else:
                     pkt = self._stream_connection._read_packet()