Fix: execute() should return rows affected by operation.

Author: gnat

databases/backends/mysql.py

@@ -131,7 +131,7 @@ async def execute(self, query: ClauseElement) -> typing.Any:
         cursor = await self._connection.cursor()
         try:
             await cursor.execute(query, args)
-            return cursor.lastrowid
+            return cursor.rowcount
         finally:
             await cursor.close()
 

databases/backends/sqlite.py

@@ -112,8 +112,9 @@ async def execute(self, query: ClauseElement) -> typing.Any:
         assert self._connection is not None, "Connection is not acquired"
         query, args, context = self._compile(query)
         cursor = await self._connection.execute(query, args)
+        rowcount = cursor.rowcount
         await cursor.close()
-        return cursor.lastrowid
+        return rowcount
 
     async def execute_many(self, queries: typing.List[ClauseElement]) -> None:
         assert self._connection is not None, "Connection is not acquired"