added exception handling

code/eval/queries/cypher/memgraph/memgraph_queries.py

@@ -63,6 +63,7 @@ def load_queries_from_file(file_path):
 #         logging.info(f"DBMS answered in: {execution_time} ms\n")
 
 def execute_and_log_query(query_key, query):
+    try:
         start_time = time.time()
         with driver.session() as session:
             result = session.run(query)
@@ -98,9 +99,6 @@ def execute_and_log_query(query_key, query):
             logging.info(f"DBMS answered in: {execution_time} ms\n")
             logging.info(f"App python answered in: {total_time} ms\n")
             logging.info(f"App db answered in: {total_time2} ms\n")
-
-
-
         # Open the CSV file in append mode and write the log information
         writer = csv.writer(csv_log_file)
         # Write a header if the file is newly created or empty, else append the data
@@ -108,6 +106,9 @@ def execute_and_log_query(query_key, query):
         if csv_log_file.tell() == 0:  # If file is empty, write a header
             writer.writerow(['Query Key', 'Start Time', 'End Time','Fetched nodes', 'Execution Time (ms)', 'Total Time (s)'])
         writer.writerow([query_key, start_time, end_time, row_count, execution_time, total_time])
+    except Exception as e:
+        logging.error(f"Failed to execute query {query_key}: {e}")
+        # Continue with the next query even if the current one fails
 
 # Function to schedule and execute all queries
 def schedule_and_execute_queries():

code/eval/queries/cypher/neo4j/neo4j_queries.py

@@ -64,6 +64,7 @@ def load_queries_from_file(file_path):
 #         logging.info(f"DBMS answered in: {execution_time} ms\n")
 
 def execute_and_log_query(query_key, query):
+    try:
         start_time = time.time()
         with driver.session() as session:
             result = session.run(query)
@@ -102,6 +103,9 @@ def execute_and_log_query(query_key, query):
         if csv_log_file.tell() == 0:  # If file is empty, write a header
             writer.writerow(['Query Key', 'Start Time', 'End Time','Fetched nodes', 'Execution Time (ms)', 'Total Time (s)'])
         writer.writerow([query_key, start_time, end_time, row_count, execution_time, total_time])
+    except Exception as e:
+        logging.error(f"Failed to execute query {query_key}: {e}")
+        # Continue with the next query even if the current one fails
 
 # Function to schedule and execute all queries
 def schedule_and_execute_queries():

code/eval/queries/cypher/ongdb/cypher_queries.py

@@ -64,6 +64,7 @@ def load_queries_from_file(file_path):
 #         logging.info(f"DBMS answered in: {execution_time} ms\n")
 
 def execute_and_log_query(query_key, query):
+    try:
         start_time = time.time()
         with driver.session() as session:
             result = session.run(query)
@@ -101,6 +102,9 @@ def execute_and_log_query(query_key, query):
         if csv_log_file.tell() == 0:  # If file is empty, write a header
             writer.writerow(['Query Key', 'Start Time', 'End Time','Fetched nodes', 'Execution Time (ms)', 'Total Time (s)'])
         writer.writerow([query_key, start_time, end_time, row_count, execution_time, total_time])
+    except Exception as e:
+        logging.error(f"Failed to execute query {query_key}: {e}")
+        # Continue with the next query even if the current one fails
 
 # Function to schedule and execute all queries
 def schedule_and_execute_queries():