如何循环创建和删除 Entity Framework 中的记录

How do I create and delete records in Entity Framework in a loop

我们有一个 postgres 数据库来存储 Event 个对象并使用 Entity Framework 作为我们的 ORM。

在定期运行的后台服务中,我们想要获取所有过期事件,将它们从 Event table 中删除并将它们移动到 EventArchive table.

我们有一项服务 class ExpiredEventService,它检索所有过期事件并将它们传递到存储库 class 以删除和创建 EventArchive 项。

通过日志记录,我们注意到确实检索到了过期事件,并且删除和创建存档项的代码没有导致异常。

但是项目没有被删除,也没有创建 EventArchive 个项目。

我们使用以下代码将这些项目移动到存档中:

public async Task MoveEventsToArchive(IList<Event> events, CancellationToken cancellationToken)
{
    using (var dbContextTrans = _dbContext.Database.BeginTransactionAsync(IsolationLevel.ReadUncommitted, cancellationToken))
    {
        foreach(var event in events)
        {
            var archiveItem = new ArchiveEvent(event);
            archiveItem.Status = EventStatus.Archived;
            _dbContext.ArchiveEvents.Add(archiveItem);
            _dbContext.Events.Remove(event);
        }
        await _dbContext.SaveChangesAsync(cancellationToken);
    }
}

正确的做法是什么?

您必须提交交易。此外,我建议使用 AddRange 和 RemoveRange 方法来提高性能。

using (var transaction = _dbContext.Database.BeginTransactionAsync())
{
  var archives = new List<ArchiveEvent>();
  foreach(var event in events)
  {
    var archiveItem = new ArchiveEvent(event);
    archiveItem.Status = EventStatus.Archived;
    archives.Add(archiveItem);              
  }
  _dbContext.ArchiveEvents.AddRange(archives);
  _dbContext.Events.RemoveRange(events);
  await _dbContext.SaveChangesAsync();
  await transaction.CommitAsync();
}

注意:如果 AddRange 导致 PK 插入问题并且您可以更改模型,请在您的 PK 中添加:

public class ArchiveEvent
{ 
  [Key]
  [DatabaseGenerated(DatabaseGeneratedOption.Identity)]
  public long id { get; set; }
  //...
}