From 49f1b2fa06da54d2f839ef6d4ca3061b92883417 Mon Sep 17 00:00:00 2001
From: Frederick Muriuki Muriithi
Date: Mon, 14 Apr 2025 12:33:27 -0500
Subject: Update existing linked publication(s) rather than creating new.

---
 uploader/publications/models.py | 25 ++++++++++++++++++++++++-
 1 file changed, 24 insertions(+), 1 deletion(-)

(limited to 'uploader')

diff --git a/uploader/publications/models.py b/uploader/publications/models.py
index 37c1df6..3fc9542 100644
--- a/uploader/publications/models.py
+++ b/uploader/publications/models.py
@@ -1,7 +1,11 @@
 """Module to handle persistence and retrieval of publication to/from MariaDB"""
+import logging
+
 from MySQLdb.cursors import DictCursor
 
-from gn_libs.mysqldb import Connection
+from gn_libs.mysqldb import Connection, debug_query
+
+logger = logging.getLogger(__name__)
 
 
 def fetch_phenotype_publications(
@@ -48,3 +52,22 @@ def create_new_publications(
                 **row, "PublicationId": row["Id"]
             } for row in cursor.fetchall())
         return tuple()
+
+
+def update_publications(conn: Connection , publications: tuple[dict, ...]) -> tuple[dict, ...]:
+    """Update details for multiple publications"""
+    if len(publications) > 0:
+        with conn.cursor(cursorclass=DictCursor) as cursor:
+            logger.debug("UPDATING PUBLICATIONS: %s", publications)
+            cursor.executemany(
+                ("UPDATE Publication SET "
+                 "PubMed_ID=%(pubmed_id)s, Abstract=%(abstract)s, "
+                 "Authors=%(authors)s, Title=%(title)s, Journal=%(journal)s, "
+                 "Volume=%(volume)s, Pages=%(pages)s, Month=%(month)s, "
+                 "Year=%(year)s "
+                 "WHERE Id=%(publication_id)s"),
+                publications)
+            debug_query(cursor, logger)
+            return publications
+        return tuple()
+    return tuple()
-- 
cgit v1.2.3