Fix negative pk. (#2)

Author: long2ice

CHANGELOG.md

@@ -2,6 +2,10 @@
 
 ## 0.1
 
+### 0.1.7
+
+- Fix negative pk. (#2)
+
 ### 0.1.6
 
 - Bug fix.

asyncmy/protocol.pyx

@@ -105,8 +105,8 @@ cdef class MysqlPacket:
         self._position += 4
         return result
 
-    cpdef int read_uint64(self):
-        cdef int result = struct.unpack_from("<Q", self._data, self._position)[0]
+    cpdef unsigned long read_uint64(self):
+        cdef unsigned long result = struct.unpack_from("<Q", self._data, self._position)[0]
         self._position += 8
         return result
 
@@ -265,8 +265,9 @@ cdef class OKPacketWrapper:
     """
     cdef:
         MysqlPacket packet
-        public int affected_rows, insert_id, server_status, warning_count, has_next
+        public int affected_rows, server_status, warning_count, has_next
         public bytes message
+        public unsigned long insert_id
 
     def __init__(self, MysqlPacket from_packet):
         if not from_packet.is_ok_packet():
@@ -281,6 +282,7 @@ cdef class OKPacketWrapper:
 
         self.affected_rows = self.packet.read_length_encoded_integer()
         self.insert_id = self.packet.read_length_encoded_integer()
+
         self.server_status, self.warning_count = self.read_struct("<HH")
         self.message = self.packet.read_all()
         self.has_next = self.server_status & SERVER_MORE_RESULTS_EXISTS

asyncmy/version.py

@@ -1 +1 @@
-__VERSION__ = "0.1.6"
+__VERSION__ = "0.1.7"

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "asyncmy"
-version = "0.1.6"
+version = "0.1.7"
 description = "A fast asyncio MySQL driver"
 authors = ["long2ice <[email protected]>"]
 license = "Apache-2.0"

tests/test_cursor.py

@@ -31,8 +31,9 @@ async def test_dict_cursor(connection):
 async def test_insert(connection):
     async with connection.cursor(cursor=DictCursor) as cursor:
         rows = await cursor.execute(
-            """INSERT INTO test.asyncmy(`decimal`, date, datetime, `float`, string, `tinyint`) VALUES (%s,%s,%s,%s,%s,%s)""",
+            """INSERT INTO test.asyncmy(id,`decimal`, date, datetime, `float`, string, `tinyint`) VALUES (%s,%s,%s,%s,%s,%s,%s)""",
             (
+                -1,
                 1,
                 "2020-08-08",
                 "2020-08-08 00:00:00",