diff options
Diffstat (limited to 'uploader')
| -rw-r--r-- | uploader/publications/models.py | 25 |
1 files changed, 24 insertions, 1 deletions
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() |