Merge pull request #574 from julien-duponchelle/deprecated-disutils

deprecate disutils

Author: sean-k1

pymysqlreplication/binlogstream.py

@@ -1,6 +1,6 @@
 import struct
 import logging
-from distutils.version import LooseVersion
+from packaging.version import Version
 
 import pymysql
 from pymysql.constants.COMMAND import COM_BINLOG_DUMP, COM_REGISTER_SLAVE
@@ -329,7 +329,7 @@ def _register_slave(self):
 
         packet = self.report_slave.encoded(self.__server_id)
 
-        if pymysql.__version__ < LooseVersion("0.6"):
+        if Version(pymysql.__version__) < Version("0.6"):
             self._stream_connection.wfile.write(packet)
             self._stream_connection.wfile.flush()
             self._stream_connection.read_packet()
@@ -501,7 +501,7 @@ def __connect_to_stream(self):
                 # encoded_data
                 prelude += gtid_set.encoded()
 
-        if pymysql.__version__ < LooseVersion("0.6"):
+        if Version(pymysql.__version__) < Version("0.6"):
             self._stream_connection.wfile.write(prelude)
             self._stream_connection.wfile.flush()
         else:
@@ -587,7 +587,7 @@ def fetchone(self):
                 self.__connect_to_ctl()
 
             try:
-                if pymysql.__version__ < LooseVersion("0.6"):
+                if Version(pymysql.__version__) < Version("0.6"):
                     pkt = self._stream_connection.read_packet()
                 else:
                     pkt = self._stream_connection._read_packet()