From c4a96e311cec1660aee5d7e2128b6c9cb39f58b0 Mon Sep 17 00:00:00 2001
From: tidusjar <jamierees@outlook.com>
Date: Fri, 5 Aug 2016 12:21:22 +0100
Subject: [PATCH] Changed the query slightly

---
 PlexRequests.Store/Repository/BaseGenericRepository.cs | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/PlexRequests.Store/Repository/BaseGenericRepository.cs b/PlexRequests.Store/Repository/BaseGenericRepository.cs
index 98a89ee15..82c2a52e2 100644
--- a/PlexRequests.Store/Repository/BaseGenericRepository.cs
+++ b/PlexRequests.Store/Repository/BaseGenericRepository.cs
@@ -60,7 +60,7 @@ namespace PlexRequests.Store.Repository
         private IDbConnection Connection => Config.DbConnection();
 
 
-        public IEnumerable<T> Custom(Func<IDbConnection , IEnumerable<T>> func)
+        public IEnumerable<T> Custom(Func<IDbConnection, IEnumerable<T>> func)
         {
             using (var cnn = Connection)
             {
@@ -291,9 +291,14 @@ namespace PlexRequests.Store.Repository
 
                     var format = values.AddPrefix("@", ",");
                     var processQuery = $"INSERT INTO {tableName} VALUES ({format})";
-                    var result = db.Execute(processQuery, entities);
+                    var result = 0;
+                    foreach (var e in enumerable)
+                    {
+                        result += db.Execute(processQuery, e);
+                    }
                     return result == enumerable.Length;
                 }
+
             }
             catch (SqliteException e) when (e.ErrorCode == SQLiteErrorCode.Corrupt)
             {
@@ -302,6 +307,7 @@ namespace PlexRequests.Store.Repository
             }
         }
 
+
         public void DeleteAll(string tableName)
         {
             try