From ce90818e3d88ca29ada740ac26ffc4408dd86d10 Mon Sep 17 00:00:00 2001
From: Max <51083570+DRdrProfessor@users.noreply.github.com>
Date: Mon, 29 May 2023 21:26:37 +0200
Subject: [PATCH] Reworking DbAccess

---
 SharpRss/DbAccess.cs | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/SharpRss/DbAccess.cs b/SharpRss/DbAccess.cs
index 03eddd2..8e56700 100644
--- a/SharpRss/DbAccess.cs
+++ b/SharpRss/DbAccess.cs
@@ -130,6 +130,7 @@ namespace SharpRss
         }
         public static async Task<FeedModel?> SetFeedsAsync(IEnumerable<FeedModel> feedModels)
         {
+            //TODO: Implement fetching system!!!
             FeedModel? resultModel = null;
             await using SqliteConnection dbc = new SqliteConnection(ConnectionString);
             dbc.Open();
@@ -153,7 +154,8 @@ namespace SharpRss
                         new SqliteParameter("lastUpdated", feedModel.LastUpdated?.ToUnixTimeMilliseconds()),
                         new SqliteParameter("imageUrl", feedModel.ImageUrl ?? string.Empty),
                         new SqliteParameter("originalDoc", feedModel.OriginalDocument ?? string.Empty)
-                    }
+                    },
+                    Transaction = transaction
                 };
                 await cmd.ExecuteNonQueryAsync();
             }
@@ -225,7 +227,10 @@ namespace SharpRss
             dbc.Open();
             await using SqliteTransaction transaction = dbc.BeginTransaction();
             await using SqliteCommand cmd = new SqliteCommand($"INSERT OR REPLACE INTO {FeedItemTable} (id, feed_id, read, title, description, link, last_updated, publishing_date, author, categories, content)" +
-                                                              $"VALUES (IFNULL((SELECT id FROM {FeedItemTable} WHERE link=@link), @id), @feedId, @read, @title, @description, @link, @lastUpdated, @publishingDate, @author, @categories, @content)", dbc);
+                                                              $"VALUES (IFNULL((SELECT id FROM {FeedItemTable} WHERE link=@link), @id), @feedId, @read, @title, @description, @link, @lastUpdated, @publishingDate, @author, @categories, @content)", dbc)
+            {
+                Transaction = transaction
+            };
             foreach (FeedItemModel item in items)
             {
                 cmd.Parameters.Clear();