def verifyExistence(query,bucket_name):
statement_type, table_name, columns, filename = parseSQL(query)
file_name = filename if filename is not None \
else table_name + ".parquet"
# Verify if the file exists in the duckdb else create a table in duckdb
con = getConnection(threading.get_ident())
try:
result = con.execute(query)
con.close()
except duckdb.CatalogException :
con=getWriteConn(threading.get_ident())
loadDataToDb(con, file_name=file_name,bucket_name=bucket_name)
result = con.execute(query)
con.close()
return result