Backup_Repos/Sonarr
1
0
Fork 0
mirror of https://github.com/Sonarr/Sonarr synced 2025-12-06 08:28:37 +01:00
Code Issues Projects Releases Wiki Activity

correct migration number and fix for postgres

Browse source
This commit is contained in:
Stevie Robinson 2025-08-31 15:25:54 +02:00 committed by Mark McDowall
parent c40fbeed50
commit 1610e54650
1 changed files with 33 additions and 25 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
src/NzbDrone.Core/Datastore/Migration/220_enable_season_pack_seeding_goal.cs
View file

@ -9,7 +9,7 @@
namespace NzbDrone.Core.Datastore.Migration namespace NzbDrone.Core.Datastore.Migration
{ {
[Migration(229)] [Migration(220)]
public class enable_season_pack_seeding_goal : NzbDroneMigrationBase public class enable_season_pack_seeding_goal : NzbDroneMigrationBase
{ {
protected override void MainDbUpgrade() protected override void MainDbUpgrade()
@ -21,20 +21,26 @@ private void SetSeasonPackSeedingGoal(IDbConnection conn, IDbTransaction tran)
{ {
var updatedIndexers = new List<object>(); var updatedIndexers = new List<object>();
using var selectCommand = conn.CreateCommand(); using (var selectCommand = conn.CreateCommand())
{
selectCommand.Transaction = tran; selectCommand.Transaction = tran;
selectCommand.CommandText = "SELECT * FROM \"Indexers\""; selectCommand.CommandText = "SELECT * FROM \"Indexers\"";
using var reader = selectCommand.ExecuteReader(); using (var reader = selectCommand.ExecuteReader())
{
var indexerSettings = new List<(int Id, string Settings)>();
while (reader.Read()) while (reader.Read())
{ {
var idIndex = reader.GetOrdinal("Id"); var idIndex = reader.GetOrdinal("Id");
var settingsIndex = reader.GetOrdinal("Settings"); var settingsIndex = reader.GetOrdinal("Settings");
var id = reader.GetInt32(idIndex); indexerSettings.Add((reader.GetInt32(idIndex), reader.GetString(settingsIndex)));
var settings = Json.Deserialize<Dictionary<string, object>>(reader.GetString(settingsIndex)); }
foreach (var indexerSetting in indexerSettings)
{
var settings = Json.Deserialize<Dictionary<string, object>>(indexerSetting.Settings);
if (settings.TryGetValue("seedCriteria", out var seedCriteriaToken) && seedCriteriaToken is JObject seedCriteria) if (settings.TryGetValue("seedCriteria", out var seedCriteriaToken) && seedCriteriaToken is JObject seedCriteria)
{ {
@ -50,11 +56,13 @@ private void SetSeasonPackSeedingGoal(IDbConnection conn, IDbTransaction tran)
updatedIndexers.Add(new updatedIndexers.Add(new
{ {
Settings = settings.ToJson(), Settings = settings.ToJson(),
Id = id, Id = indexerSetting.Id,
}); });
} }
} }
} }
}
}
if (updatedIndexers.Any()) if (updatedIndexers.Any())
{ {