Skip to content

Commit 68fe6c7

Browse files
Merge pull request julien-duponchelle#47 from dreid/check-checksum
Check if the checksum is enabled upon connection.
2 parents a0f5638 + 4b8c637 commit 68fe6c7

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

pymysqlreplication/binlogstream.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -82,6 +82,8 @@ def __connect_to_stream(self):
8282
# log_file (string.EOF) -- filename of the binlog on the master
8383
self._stream_connection = pymysql.connect(**self.__connection_settings)
8484

85+
self.__use_checksum = self.__checksum_enabled()
86+
8587
#If cheksum is enabled we need to inform the server about the that we support it
8688
if self.__use_checksum:
8789
cur = self._stream_connection.cursor()

0 commit comments

Comments
 (0)