Committing Database Transaction

4 years ago · 5a1684189e
parent 044b6305ae
commit 5a1684189e
1 changed files with 1 additions and 0 deletions
--- a/main.py
+++ b/main.py
@ -71,6 +71,7 @@ async def on_message(message):
            cursor = conn.cursor()
            # Execute the SQL Query
            cursor.execute(insert_query, val)
+            conn.commit()
            print(cursor.rowcount, "Record inserted successfully into Logs")

        except mariadb.Error as ex: