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