Merge pull request #139 from xiezhenye/fix_seq_no

julien-duponchelle · julien-duponchelle · commit 979ee16b69a2 · 2016-01-22T09:47:46.000+01:00
fix: missing update _next_seq_no
diff --git a/pymysqlreplication/binlogstream.py b/pymysqlreplication/binlogstream.py
@@ -226,6 +226,7 @@ def __connect_to_stream(self):
             self._stream_connection.wfile.flush()
         else:
             self._stream_connection._write_bytes(prelude)
+            self._stream_connection._next_seq_id = 1
         self.__connected_stream = True
 
     def fetchone(self):
