issue_2491.py

#!/usr/bin/python3

import datetime
import os
import psycopg2
import sys
import time


connection = psycopg2.connect("host=rapa.eaalab.hpi.uni-potsdam.de port=5432")
connection.autocommit = True
cursor = connection.cursor()

while True:
  print("Starting to run all queries of input file.")
  with open("Generated-TPCH-SQL-30.csv") as query_file:
    for query_id, query in enumerate(query_file):
      start_time = time.time()
      print(f"  {datetime.datetime.now()}: Starting query #{query_id}", end="")
      cursor.execute(query.strip())
      result = cursor.fetchall()
      print(f" ... done ({time.time() - start_time:.2f} s; {len(result)} rows).")