1 files changed, 3 insertions, 2 deletions
diff --git a/Jellyfin.Server/Migrations/Routines/RemoveDuplicateExtras.cs b/Jellyfin.Server/Migrations/Routines/RemoveDuplicateExtras.cs
index 98017e3ef..6c34e1f5b 100644
--- a/Jellyfin.Server/Migrations/Routines/RemoveDuplicateExtras.cs
+++ b/Jellyfin.Server/Migrations/Routines/RemoveDuplicateExtras.cs
@@ -39,11 +39,11 @@ namespace Jellyfin.Server.Migrations.Routines
             var dataPath = _paths.DataPath;
             var dbPath = Path.Combine(dataPath, DbFilename);
             using (var connection = new SqliteConnection($"Filename={dbPath}"))
+            using (var transaction = connection.BeginTransaction())
             {
                 // Query the database for the ids of duplicate extras
                 var queryResult = connection.Query("SELECT t1.Path FROM TypedBaseItems AS t1, TypedBaseItems AS t2 WHERE t1.Path=t2.Path AND t1.Type!=t2.Type AND t1.Type='MediaBrowser.Controller.Entities.Video'");
-                // TODO does this LINQ execute before the reader is disposed?
-                var bads = string.Join(", ", queryResult.Select(x => x.GetString(0)).ToList());
+                var bads = string.Join(", ", queryResult.Select(x => x.GetString(0)));
 
                 // Do nothing if no duplicate extras were detected
                 if (bads.Length == 0)
@@ -75,6 +75,7 @@ namespace Jellyfin.Server.Migrations.Routines
                 // Delete all duplicate extras
                 _logger.LogInformation("Removing found duplicated extras for the following items: {DuplicateExtras}", bads);
                 connection.Execute("DELETE FROM TypedBaseItems WHERE rowid IN (SELECT t1.rowid FROM TypedBaseItems AS t1, TypedBaseItems AS t2 WHERE t1.Path=t2.Path AND t1.Type!=t2.Type AND t1.Type='MediaBrowser.Controller.Entities.Video')");
+                transaction.Commit();
             }
         }
     }