Fix query: Add missing field and parameter.

1 files changed, 9 insertions, 4 deletions

diff --git a/scripts/load_phenotypes_to_db.py b/scripts/load_phenotypes_to_db.py
index 3ead245..5ccb5c6 100644
--- a/scripts/load_phenotypes_to_db.py
+++ b/scripts/load_phenotypes_to_db.py
@@ -209,12 +209,17 @@ def cross_reference_phenotypes_publications_and_data(
     with conn.cursor(cursorclass=DictCursor) as cursor:
         cursor.execute("SELECT MAX(Id) CurrentMaxId FROM PublishXRef")
         _nextid = int(cursor.fetchone()["CurrentMaxId"]) + 1
-        cursor.execute(
-            ("INSERT INTO PublishXRef(Id, InbredSetId, PhenotypeId, PublicationId, DataId) "
-             "VALUES(%(xref_id)s, %(population_id)s, %(phenotype_id)s, %(data_id)s) "
+        cursor.executemany(
+            ("INSERT INTO PublishXRef("
+             "Id, InbredSetId, PhenotypeId, PublicationId, DataId, comments"
+             ") "
+             "VALUES ("
+             "%(xref_id)s, %(population_id)s, %(phenotype_id)s, "
+             "%(publication_id)s, %(data_id)s, 'Upload of new data.'"
+             ") "
              "RETURNING *"),
             tuple({**row, "xref_id": _id}
-                  for _id, row in enumerate(xref_data, start=_next_id)))
+                  for _id, row in enumerate(xref_data, start=_nextid)))
         return tuple(dict(row) for row in cursor.fetchall())
     return tuple()