Fix

BUTR · Feb 24, 2024 · 5870c55 · 5870c55
1 parent 4ef3c7d
commit 5870c55
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/BUTR.CrashReportServer/Services/DatabaseMigrator.cs b/src/BUTR.CrashReportServer/Services/DatabaseMigrator.cs
@@ -40,13 +40,15 @@ protected override async Task ExecuteAsync(CancellationToken ct)
         {
             var data = await sqlite.Set<IdEntity>().OrderBy(x => x.FileId).Skip(i * take).Take(take).ToArrayAsync(ct);
             await postgres.Set<IdEntity>().AddRangeAsync(data, ct);
+            await postgres.SaveChangesAsync(ct);
         }
 
         var fileDataCount = sqlite.Set<FileEntity>().Count();
         for (var i = 0; i < fileDataCount % take; i+= take)
         {
             var data = await sqlite.Set<FileEntity>().OrderBy(x => x.Id.FileId).Skip(i * take).Take(take).ToArrayAsync(ct);
             await postgres.Set<FileEntity>().AddRangeAsync(data, ct);
+            await postgres.SaveChangesAsync(ct);
         }
 
         var jsonDataCount = sqlite.Set<OldJsonEntity>().Count();
@@ -59,6 +61,7 @@ protected override async Task ExecuteAsync(CancellationToken ct)
                     CrashReport = await new StreamReader(await _compressor.DecompressAsync(x.CrashReportCompressed, ct)).ReadToEndAsync(ct),
                 }).ToArrayAsync(ct);
             await postgres.Set<JsonEntity>().AddRangeAsync(data, ct);
+            await postgres.SaveChangesAsync(ct);
         }
     }
 }