From 669b1a8b926ffe39c98c20fce5b750a3d08a9e88 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Louis=20V=C3=A9zina?=
 <5130500+morpheus65535@users.noreply.github.com>
Date: Mon, 4 Dec 2017 22:54:08 -0500
Subject: [PATCH] Commit change to db after each insert or update

---
 get_episodes.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/get_episodes.py b/get_episodes.py
index c8c5b16cf..c9b8e198e 100644
--- a/get_episodes.py
+++ b/get_episodes.py
@@ -42,8 +42,10 @@ def update_all_episodes():
 
                 try:
                     c.execute('''INSERT INTO table_episodes(sonarrSeriesId, sonarrEpisodeId, title, path, season, episode) VALUES (?, ?, ?, ?, ?, ?)''', (episode['seriesId'], episode['id'], episode['title'], episode['episodeFile']['path'], episode['seasonNumber'], episode['episodeNumber']))
+                	db.commit()
                 except sqlite3.Error:
                     c.execute('''UPDATE table_episodes SET sonarrSeriesId = ?, sonarrEpisodeId = ?, title = ?, path = ?, season = ?, episode = ? WHERE sonarrEpisodeId = ?''', (episode['seriesId'], episode['id'], episode['title'], episode['episodeFile']['path'], episode['seasonNumber'], episode['episodeNumber'], episode['id']))
+            		db.commit()
             else:
                 continue
         continue
@@ -54,8 +56,6 @@ def update_all_episodes():
         if item not in current_episodes_sonarr:
             deleted_items.append(tuple([item]))
     c.executemany('DELETE FROM table_episodes WHERE sonarrEpisodeId = ?',deleted_items)
-    
-    # Commit changes to database table
     db.commit()
 
     # Close database connection