PyMySQL
diff --git a/‎pymysql/connections.py
Lines changed: 11 additions & 11 deletions b/‎pymysql/connections.py
Lines changed: 11 additions & 11 deletions
@@ -726,7 +726,7 @@ def __del__(self):
     def autocommit(self, value):
         self.autocommit_mode = bool(value)
         current = self.get_autocommit()
-        self.next_packet = 1
+        self._next_packet = 1
         if value != current:
             self._send_autocommit_mode()
 
@@ -816,15 +816,15 @@ def query(self, sql, unbuffered=False):
                 "You may not close previous cursor.")
         # if DEBUG:
         #     print("DEBUG: sending query:", sql)
-        self.next_packet = 1
+        self._next_packet = 1
         if isinstance(sql, text_type) and not (JYTHON or IRONPYTHON):
             if PY2:
                 sql = sql.encode(self.encoding)
             else:
                 sql = sql.encode(self.encoding, 'surrogateescape')
         self._execute_command(COMMAND.COM_QUERY, sql)
         self._affected_rows = self._read_query_result(unbuffered=unbuffered)
-        self.next_packet = 1
+        self._next_packet = 1
         return self._affected_rows
 
     def next_result(self, unbuffered=False):
@@ -892,7 +892,7 @@ def connect(self, sock=None):
                 sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1)
             self.socket = sock
             self._rfile = _makefile(sock, 'rb')
-            self.next_packet = 0
+            self._next_packet = 0
 
             self._get_server_information()
             self._request_authentication()
@@ -938,11 +938,11 @@ def write_packet(self, data):
         addings its length and sequence number. Intended for use by plugins
         only.
         """
-        data = pack_int24(len(data)) + int2byte(self.next_packet) + data
+        data = pack_int24(len(data)) + int2byte(self._next_packet) + data
         if DEBUG: dump_packet(data)
 
         self._write_bytes(data)
-        self.next_packet = (self.next_packet + 1) % 256
+        self._next_packet = (self._next_packet + 1) % 256
 
     def _read_packet(self, packet_type=MysqlPacket):
         """Read an entire "mysql packet" in its entirety from the network
@@ -962,13 +962,13 @@ def _read_packet(self, packet_type=MysqlPacket):
                 continue
             if bytes_to_read < MAX_PACKET_LEN:
                 break
-        if packet_number != self.next_packet:
+        if packet_number != self._next_packet:
             pass
             #TODO: check sequence id
             #raise err.InternalError("Packet sequence number wrong - got %d expected %d" %
-            #    (packet_number, self.next_packet))
+            #    (packet_number, self._next_packet))
 
-        self.next_packet = (packet_number + 1) % 256
+        self._next_packet = (packet_number + 1) % 256
         packet = packet_type(buff, self.encoding)
         packet.check_error()
         return packet
@@ -1037,7 +1037,7 @@ def _execute_command(self, command, sql):
         self._write_bytes(prelude + sql[:chunk_size-1])
         if DEBUG: dump_packet(prelude + sql)
 
-        self.next_packet = 1
+        self._next_packet = 1
         if chunk_size < self.max_allowed_packet:
             return
 
@@ -1053,7 +1053,7 @@ def _execute_command(self, command, sql):
             if not sql and chunk_size < self.max_allowed_packet:
                 break
             seq_id += 1
-        self.next_packet = seq_id%256
+        self._next_packet = seq_id % 256
 
     def _request_authentication(self):
         # https://dev.mysql.com/doc/internals/en/connection-phase-packets.html#packet-Protocol::HandshakeResponse