aboutsummaryrefslogtreecommitdiff
path: root/scripts/insert_data.py
diff options
context:
space:
mode:
authorFrederick Muriuki Muriithi2022-08-05 10:10:56 +0300
committerFrederick Muriuki Muriithi2022-08-05 10:10:56 +0300
commit19c376c4b60592f4bba0e26952faa3a71b6f5641 (patch)
tree0916ef296a57bb450102093429422953d92c009e /scripts/insert_data.py
parent3da6848381b6103fbb58eeab8d7051cba0bded58 (diff)
downloadgn-uploader-19c376c4b60592f4bba0e26952faa3a71b6f5641.tar.gz
Update job status. Display stdout and stderr outputs
* Display the status of the job, as it is running * Display STDERR output if an error occurs * Display STDOUT output as job is running and on successful completion of the job
Diffstat (limited to 'scripts/insert_data.py')
-rw-r--r--scripts/insert_data.py5
1 files changed, 4 insertions, 1 deletions
diff --git a/scripts/insert_data.py b/scripts/insert_data.py
index 6491b06..7bf20f1 100644
--- a/scripts/insert_data.py
+++ b/scripts/insert_data.py
@@ -122,7 +122,9 @@ def __format_query__(query, params):
for param in params)
values_str = ", ".join(
f"('{__param_str__(value_tup)}')" for value_tup in values)
- return f"{query[:idx]} VALUES{values_str};"
+ insert_str = query[:idx].replace(
+ "INSERT INTO ", "INSERT INTO\n\t")
+ return f"{insert_str}\nVALUES\n\t{values_str};"
def insert_means(
filepath: str, speciesid: int, datasetid: int, dbconn: mdb.Connection,
@@ -149,6 +151,7 @@ def insert_means(
if not bool(means):
break
print(__format_query__(means_query, means))
+ print()
print(__format_query__(xref_query, means))
cursor.executemany(means_query, means)
cursor.executemany(xref_query, means)