From 959e2c317ed93daea2665891d658f4da7078cfe6 Mon Sep 17 00:00:00 2001 From: Labrys of Knossos Date: Sat, 15 Dec 2018 19:45:49 -0500 Subject: [PATCH] Fix near operational error in upsert --- core/nzbToMediaDB.py | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/core/nzbToMediaDB.py b/core/nzbToMediaDB.py index bc498bd8..83761663 100644 --- a/core/nzbToMediaDB.py +++ b/core/nzbToMediaDB.py @@ -173,26 +173,27 @@ class DBConnection(object): genParams = lambda myDict: ["{key} = ?".format(key=k) for k in myDict.keys()] + items = list(valueDict.values()) + list(keyDict.values()) self.action( "UPDATE {table} " "SET {params} " "WHERE {conditions}".format( table=tableName, params=", ".join(genParams(valueDict)), - conditions=" AND ".join(genParams(keyDict))), - list(valueDict.values()) + list(keyDict.values()) + conditions=" AND ".join(genParams(keyDict)) + ), + items ) if self.connection.total_changes == changesBefore: - items = list(valueDict.values()) + list(keyDict.values()) self.action( "INSERT OR IGNORE INTO {table} ({columns}) " "VALUES ({values})".format( table=tableName, - columns=", ".join(map(text_type, items)), - values=", ".join(["?"] * len(items)) + columns=", ".join(map(text_type, valueDict.keys())), + values=", ".join(["?"] * len(valueDict.values())) ), - items, + list(valueDict.values()) ) def tableInfo(self, tableName):