implemented requested changes

Author: marekyggdrasil

sqlite_rx/server.py

@@ -220,7 +220,6 @@ def execute(self, message: dict, *args, **kwargs):
         execute_many = message['execute_many']
         execute_script = message['execute_script']
         error = None
-        lastrowid = None
         try:
             if execute_script:
                 LOG.debug("Query Mode: Execute Script")
@@ -230,10 +229,10 @@ def execute(self, message: dict, *args, **kwargs):
                 self._cursor.executemany(message['query'], message['params'])
             elif message['params']:
                 LOG.debug("Query Mode: Conditional Params")
-                ret = self._cursor.execute(message['query'], message['params'])
+                self._cursor.execute(message['query'], message['params'])
             else:
                 LOG.debug("Query Mode: Default No params")
-                ret = self._cursor.execute(message['query'])
+                self._cursor.execute(message['query'])
         except Exception:
             LOG.exception("Exception while executing query %s", message['query'])
             error = self.capture_exception()
@@ -248,9 +247,8 @@ def execute(self, message: dict, *args, **kwargs):
         if error:
             return zlib.compress(msgpack.dumps(result))
 
-        if ret is not None:
-            if ret.lastrowid is not None:
-                result['lastrowid'] = ret.lastrowid
+        if self._cursor.lastrowid:
+            result['lastrowid'] = self._cursor.lastrowid
 
         try:
             result['items'] = [row for row in self._cursor.fetchall()]