Update database.py

database.py

@@ -93,12 +93,10 @@ def end_session(session_id, end_time):
 
 def add_interaction(user_id, input_text, detected_language, translated_text,
                     nlu_summary, timestamp):
-    p = _placeholder()
-
     sql = (
-        f"INSERT INTO interaction "
-        f"(user_id, input_text, detected_language, translated_text, nlu_summary, timestamp) "
-        f"VALUES ({p}, {p}, {p}, {p}, {p}, {p})"
+        "INSERT INTO interaction "
+        "(user_id, input_text, detected_language, translated_text, nlu_summary, timestamp) "
+        "VALUES (?, ?, ?, ?, ?, ?)"
     )
 
     params = (
@@ -110,13 +108,8 @@ def add_interaction(user_id, input_text, detected_language, translated_text,
         timestamp
     )
 
-    with _connection() as conn:
-        if DATABASE_URL:
-            cursor = _run(conn, sql + " RETURNING id", params)
-            return cursor.fetchone()["id"]
-        else:
-            cursor = _run(conn, sql, params)
-            return cursor.lastrowid
+    with get_connection() as connection:
+        return _insert_and_get_id(connection, sql, params)
 
 
 def get_interactions_for_user(user_id):