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 SetFeedsAsync(IEnumerable 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();