使用Entity Framework Core更新相关数据

20

我正在使用Entity Framework Core构建一个简单的Web API。我使用模型和视图模型来管理客户端实际接收到的数据。以下是我创建的模型和视图模型:

public class Team : BaseEntity
{
    [Key]
    public int TeamId { get; set; }
    [Required]
    public string TeamName { get; set; }
    public List<TeamAgent> TeamAgents { get; set; }
}

public class TeamViewModel
{
    [Required]
    public int TeamId { get; set; }
    [Required]
    public string TeamName { get; set; }
    [DataType(DataType.Date)]
    public DateTime DateCreated { get; set; }
    [DataType(DataType.Date)]
    public DateTime DateModified { get; set; }
    public List<TeamAgent> TeamAgents { get; set; }
}

public class TeamAgent : BaseEntity
{
    [Key]
    public int TeamAgentId { get; set; }
    [ForeignKey("Agent")]
    public int AgentId { get; set; }
    [JsonIgnore]
    public virtual Agent Agent { get; set; }
    [ForeignKey("Team")]
    public int TeamId { get; set; }
    [JsonIgnore]
    public virtual Team Team { get; set; }
    [Required]
    public string Token { get; set; }
}

public class TeamAgentViewModel
{
    [Required]
    public virtual AgentViewModel Agent { get; set; }
    [Required]
    public string Token { get; set; }
}

现在,为了更新,我在我的控制器中创建了一个更新方法:
[HttpPut("{id}")]
public async Task<IActionResult> Update(int id, [FromBody]TeamViewModel teamVM)
{
    if (ModelState.IsValid)
    {
        var team = await _context.Teams
                            .Include(t => t.TeamAgents)
                            .SingleOrDefaultAsync(c => c.TeamId == id);

        team.TeamName = teamVM.TeamName;

        // HOW TO HANDLE IF SOME TEAMAGENTS GOT ADDED OR REMOVED???

        _context.Teams.Update(team);
        await _context.SaveChangesAsync();

        return new NoContentResult();
    }
    return BadRequest(ModelState);
}

我陷入了如何更新与团队连接的TeamAgents的问题。我尝试过一种有效的方法,就是每次更新团队数据时删除所有的TeamAgents,然后重新创建它们。具体操作如下:

team.TeamAgents.Clear();
await _context.SaveChangesAsync();
team.TeamAgents.AddRange(teamVM.TeamAgents);

_context.Teams.Update(team);
await _context.SaveChangesAsync();

但是显然这不是一个很好的方法。使用Entity Framework Core更新相关项目的正确方法是什么?


EF Core中的“保存数据 - 断开的实体”部分仍然是空的。这意味着没有好的(正确的)通用方法来做到这一点。 - Ivan Stoev
@IvanStoev,请将您的评论添加为答案,我会接受它。 - hs2d
1
谢谢,但这绝对不是我想要的答案。希望在某个时候,微软或第三方包(如EF6的GraphDiff)能够解决这种情况。 - Ivan Stoev
1
我已经为这个问题创建了一个通用解决方案。您可以在这里查看我的答案 https://dev59.com/Vrjna4cB1Zd3GeqP_X6B#63919095 - Wahid Bitar
2个回答

22

Julie Lerman在2016年4月的文章“处理EF中脱离实体的状态”中解决了这个问题。如果你还没看过这篇文章,它是非常值得一读的。不幸的是,截至EF Core 2.0,仍然没有内置的方法来更新对象图。

Julie文章中提到的方法是通过添加属性来跟踪分离实体的状态,并将状态发送到客户端。客户端可以修改状态并将其发送回服务器,然后您可以使用该信息来执行正确的操作。

在我最近的项目中,由于只有一个操作需要更新子集合,所以我采取了略微不同的方法。当我再次遇到这种情况时,我可能会认真考虑Julie���建议并进行重构。

基本上这只是一个手动对象图更新,看起来很类似于使用EF 6.0的方法。有一件事要注意的是,现在使用EF Core,您可以调用Remove()传递实体,而无需关心它属于哪个dbSet。

/// <param name="entity"></param>
public override void Update(Group entity) {
    // entity as it currently exists in the db
    var group = DbContext.Groups.Include(c => c.Contacts)
        .FirstOrDefault(g => g.Id == entity.Id);
    // update properties on the parent
    DbContext.Entry(group).CurrentValues.SetValues(entity);
    // remove or update child collection items
    var groupContacts = group.Contacts.ToList();
    foreach (var groupContact in groupContacts) {
        var contact = entity.Contacts.SingleOrDefault(i => i.ContactId == groupContact.ContactId);
        if (contact != null)
            DbContext.Entry(groupContact).CurrentValues.SetValues(contact);
        else
            DbContext.Remove(groupContact);
    }
    // add the new items
    foreach (var contact in entity.Contacts) {
        if (groupContacts.All(i => i.Id != contact.Id)) {
            group.Contacts.Add(contact);
        }
    }
    DbContext.SaveChanges();
}

非常感谢您提供的这个简单解决方案,我遇到了几天与自引用表保存数据相关的问题。 - Jim K

1

感谢@Slauma提供此代码。

public void Update(UpdateParentModel model)
{
    var existingParent = _dbContext.Parents
        .Where(p => p.Id == model.Id)
        .Include(p => p.Children)
        .SingleOrDefault();

    if (existingParent != null)
    {
        // Update parent
        _dbContext.Entry(existingParent).CurrentValues.SetValues(model);

        // Delete children
        foreach (var existingChild in existingParent.Children.ToList())
        {
            if (!model.Children.Any(c => c.Id == existingChild.Id))
                _dbContext.Children.Remove(existingChild);
        }

        // Update and Insert children
        foreach (var childModel in model.Children)
        {
            var existingChild = existingParent.Children
                .Where(c => c.Id == childModel.Id && c.Id != default(int))
                .SingleOrDefault();

            if (existingChild != null)
                // Update child
                _dbContext.Entry(existingChild).CurrentValues.SetValues(childModel);
            else
            {
                // Insert child
                var newChild = new Child
                {
                    Data = childModel.Data,
                    //...
                };
                existingParent.Children.Add(newChild);
            }
        }

        _dbContext.SaveChanges();
    }
}

来源:

https://dev59.com/RV4d5IYBdhLWcg3wG_WH#27177623


网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接