如何在实体框架中循环创建和删除记录

Posted 2023-02-16

【中文标题】如何在实体框架中循环创建和删除记录

【英文标题】：How do I create and delete records in Entity Framework in a loop

【发布时间】：2022-01-09 16:50:26

【问题描述】：

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

在定期运行的后台服务中，我们希望获取所有过期事件，将它们从Event 表中删除，然后将它们移动到EventArchive 表中。

我们有一个服务类ExpiredEventService，它检索所有过期事件并将它们传递给存储库类以进行删除和创建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);
    

这样做的正确方法是什么？

【问题讨论】：

看起来您并没有提交您在 using 语句中打开的事务。

在上述语句中使用您在 using 语句中创建的相同 dbContext。

【参考方案1】：

您必须提交您的交易。我还建议使用 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; 
  //...