使用 Entity framework 删除然后插入值

deleting and then inserting values using Entity framework

我的要求是我需要从 table 中删除一些行,然后在相同的 table 中插入一些行。我正在使用工作单元,因此删除和插入都是同一事务的一部分。但是当我试图保存数据时,entity framework 是重复键抛出错误。请在下面找到示例和代码:

示例:Table 名称 - Table1,列 - col1(c.K),col2(C.K),col3

要删除的行 - 78,1,1

RowTo 添加- 78,1,1 78,2,2

我的工作单位Class:

public class DataRepository<T> : IRepository<T> where T:class // IDisposable,
    {
        #region Variables

        private readonly CWSEntities _context;
        protected readonly IDbSet<T> _dbset;

        #endregion

        #region Constructors

        public DataRepository() 
       {
           _context = new CWSEntities();
           _dbset = _context.Set<T>();

       }
        public DataRepository(CWSEntities context) 
       {
           _context =context;
           _dbset = _context.Set<T>();

       }

        #endregion

        #region Methods

        public IQueryable<T> All() 
        {
            return _context.Set<T>();
        }

      //  public IQueryable<T> AllInclude(params Expression<Func<T,object>>[] include) 
        public IQueryable<T> Include(params Expression<Func<T, object>>[] include)
        {
            IQueryable<T> retValue = _context.Set<T>();

            foreach (var item in include)
            {
                retValue = retValue.Include(item);
            }
            return retValue;
        }

        public T GetById(object id)
        {
            return this._dbset.Find(id);
        }      

        public  IEnumerable<T> Get(Expression<Func<T, bool>> filter = null, Func<IQueryable<T>, IOrderedQueryable<T>> orderBy = null,
           string includeProperties = "")
        {
            IQueryable<T> query = _dbset;

            if (filter != null)
            {
                query = query.Where(filter);
            }

            foreach (var includeProperty in includeProperties.Split
                (new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries))
            {
                query = query.Include(includeProperty);
            }

            if (orderBy != null)
            {
                return orderBy(query).ToList();
            }
            else
            {
                return query.ToList();
            }
        }

        public  T Add(T entity)  
        {
            if (entity != null)
            {
                return _dbset.Add(entity);
            }
            return null;
        }

        public  void Delete(object id)
        {
            T entityToDelete = _dbset.Find(id);
                        
            Delete(id);
        }

        public  void Delete(T entityToDelete)
        {
            if (entityToDelete != null)
            {
                if (_context.Entry(entityToDelete).State == EntityState.Detached)
                {
                    _dbset.Attach(entityToDelete);
                }
                _dbset.Remove(entityToDelete);
            }
           
        }

        public  void Update(T entityToUpdate)
        {
            if (entityToUpdate != null)
            {
                _dbset.Attach(entityToUpdate);
                _context.Entry(entityToUpdate).State = EntityState.Modified;
                // _context.Entry(entity).State = System.Data.Entity.EntityState.Modified;
            }
        }

        public virtual void Save()
        {
            try
            {
                _context.SaveChanges();
            }
            catch(DbEntityValidationException exception)
            {

            }
        }

据我所知,您正在尝试添加具有相同主键的实体,正如您在示例中所说

RowTo Add- 78,1,1 78,2,2

您的 Add 方法似乎没有正确处理此问题。您可以首先通过传递实体的主键值来检查实体是否存在,如果不存在则进行添加,如果不存在则可能进行更新?

 public  T Add(T entity, params object[] keys)  
 {
    if (entity != null)
    {
        var existing = _dbset.Find(keys)
        if (existing == null)
            return _dbset.Add(entity);
        else
            Update(entity);
    }
    return null;
}