overwrite the row if it already exists

db/db_utils.py

@@ -185,8 +185,30 @@ def store_result_to_db(cursor, conn, run_key, result):
 def store_results_batch(cursor, conn, run_key, results_batch):
     logging.info(f"Storing batch of length {len(results_batch)}")
     cursor.executemany('''
-        INSERT INTO results (run_key, run_row, date, input_word, dictionary_word, is_food, wweia_category, dry_matter_content, leakage, weight, weight_metric_tonnes, donor, similarity_score, food_nonfood_score, distance, ef, mt_lb_mile, baseline_emissions, leakage_emissions, project_emissions, total_emissions_reduction)
-        VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)
+        INSERT INTO results (
+            run_key, run_row, date, input_word, dictionary_word, is_food, wweia_category, dry_matter_content, leakage, weight, weight_metric_tonnes, donor, similarity_score, food_nonfood_score, distance, ef, mt_lb_mile, baseline_emissions, leakage_emissions, project_emissions, total_emissions_reduction
+        ) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)
+        ON CONFLICT (run_key, run_row)
+        DO UPDATE SET
+            date = EXCLUDED.date,
+            input_word = EXCLUDED.input_word,
+            dictionary_word = EXCLUDED.dictionary_word,
+            is_food = EXCLUDED.is_food,
+            wweia_category = EXCLUDED.wweia_category,
+            dry_matter_content = EXCLUDED.dry_matter_content,
+            leakage = EXCLUDED.leakage,
+            weight = EXCLUDED.weight,
+            weight_metric_tonnes = EXCLUDED.weight_metric_tonnes,
+            donor = EXCLUDED.donor,
+            similarity_score = EXCLUDED.similarity_score,
+            food_nonfood_score = EXCLUDED.food_nonfood_score,
+            distance = EXCLUDED.distance,
+            ef = EXCLUDED.ef,
+            mt_lb_mile = EXCLUDED.mt_lb_mile,
+            baseline_emissions = EXCLUDED.baseline_emissions,
+            leakage_emissions = EXCLUDED.leakage_emissions,
+            project_emissions = EXCLUDED.project_emissions,
+            total_emissions_reduction = EXCLUDED.total_emissions_reduction
     ''', [
         (
             run_key,