Entity Framework Core - связанная с обновлением коллекция

Question

Я пытаюсь обновить коллекцию ProjectEmployees внутри ProjectModel. Я хочу удалить все старые значения и установить новые.

Мои модели:

public class Project 
{ 
    ... 
    public ICollection<ProjectEmployee> ProjectEmployees { get; set; } 
} 

public class ProjectEmployee 
{ 
    public int ProjectId { get; set; } 
    public virtual Project Project { get; set; } 
    public int UserId { get; set; } 
    public virtual Employee Employee { get; set; } 
} 

public class Employee 
{ 
    public int UserId { get; set; } 
    public User User { get; set; } 
    ... 
} 
public class ProjectGroupModel //ViewModel 
{ 
    public int ProjectId { get; set; } 
    public ICollection<Employee> ProjectEmployees { get; set; } 
} 

Это типично многие-ко-многим.

Мои действия контроллера:

[HttpPost("group")] 
    public async Task<IActionResult> CreateGroup([FromBody] ProjectGroupModel pro) 
    { 
      var dbProject = await _context.Project 
       .Include(p=>p.ProjectEmployees) 
       .FirstAsync(p => p.ProjectId == pro.ProjectId); 
      dbProject.ProjectEmployees.Clear(); 

      foreach (var emp in pro.ProjectEmployees) 
      { 
       dbProject.ProjectEmployees.Add(new ProjectEmployee() 
       { 
        UserId = emp.UserId 
       }); 
      } 

      await _context.SaveChangesAsync(); 

      return Ok(); 
    } 

Когда pro.ProjectEmployees пуста все записи из dbProject.ProjectEmployees были удалены правильно, и если dbProject.ProjectEmployees пуста новые записи из модели были добавлены, но когда dbProject.ProjectEmployees не пусто Я не могу установить новые записи:

ОШИБКА:

"The instance of entity type 'ProjectEmployee' cannot be tracked because another instance of this type with the same key is already being tracked. When adding new entities, for most key types a unique temporary key value will be created if no key is set (i.e. if the key property is assigned the default value for its type). If you are explicitly setting key values for new entities, ensure they do not collide with existing entities or temporary values generated for other new entities. When attaching existing entities, ensure that only one entity instance with a given key value is attached to the context."

Я попытался исправить это действие в сотни но всегда это неправильно.

Answer 1

Это далеко от совершенства, но единственный способ, которым я был в состоянии сделать его работу, чтобы удалить элементы из соответствующего DbSet и вызвать SaveChanges перед добавлением новых:

var dbProject = await _context.Project 
    .Include(p=>p.ProjectEmployees) 
    .FirstAsync(p => p.ProjectId == pro.ProjectId); 

if (dbProject.ProjectEmployees.Any()) 
{ 
    _context.ProjectEmployee.RemoveRange(dbProject.ProjectEmployees); 
    await _context.SaveChangesAsync(); 
} 

foreach (var emp in pro.ProjectEmployees) 
{ 
    dbProject.ProjectEmployees.Add(new ProjectEmployee() 
    { 
     UserId = emp.UserId 
    }); 
} 

await _context.SaveChangesAsync(); 

Answer 2

Я думаю, что старые объекты на самом деле не удалены из базы данных. Вы вызываете только Clear(), которого недостаточно. Попробуйте сделать это:

[HttpPost("group")] 
public async Task<IActionResult> CreateGroup([FromBody] ProjectGroupModel pro) 
{ 
    var dbProject = await _context.Project 
     .Include(p=>p.ProjectEmployees) 
     .FirstAsync(p => p.ProjectId == pro.ProjectId); 

    foreach (var old in dbProject.ProjectEmployees) 
     { 
      _context.ProjectEmployee.Remove(old); 
     } 

    dbProject.ProjectEmployees.Clear(); 

    foreach (var emp in pro.ProjectEmployees) 
     { 
      dbProject.ProjectEmployees.Add(new ProjectEmployee() 
      { 
       UserId = emp.UserId 
      }); 
     } 

    await _context.SaveChangesAsync(); 

    return Ok(); 
} 

Здесь я предполагаю, что у вас есть соответствующий набор в вашем контексте (_context.ProjectEmployee). Если у вас нет этого набора явно в вашем контексте, просто добавьте его.

Answer 3

связанные с another SO question

Я могу ответить на этот вопрос с вашими классами.

Затем с помощью этого расширения я сделал, чтобы удалить невыделенная и добавить новый выбранный в списке

public static void TryUpdateManyToMany<T, TKey>(this DbContext db, IEnumerable<T> currentItems, IEnumerable<T> newItems, Func<T, TKey> getKey) where T : class 
    { 
     db.Set<T>().RemoveRange(currentItems.Except(newItems, getKey)); 
     db.Set<T>().AddRange(newItems.Except(currentItems, getKey)); 
    } 

    public static IEnumerable<T> Except<T, TKey>(this IEnumerable<T> items, IEnumerable<T> other, Func<T, TKey> getKeyFunc) 
    { 
     return items 
      .GroupJoin(other, getKeyFunc, getKeyFunc, (item, tempItems) => new { item, tempItems }) 
      .SelectMany(t => t.tempItems.DefaultIfEmpty(), (t, temp) => new { t, temp }) 
      .Where(t => ReferenceEquals(null, t.temp) || t.temp.Equals(default(T))) 
      .Select(t => t.t.item); 
    } 

используя это выглядит как этот

var model = db.Employees 
      .Include(x => x.ProjectEmployees) 
      .FirstOrDefault(x => x.EmployeeId == employee.EmployeeId); 

db.TryUpdateManyToMany(model.ProjectEmployees, listOfNewProjectIds 
.Select(x => new ProjectEmployee 
{ 
    ProjectId = x, 
    EmployeeId = employee.EmployeeId 
}), x => x.ProjectId);