由于错误信息指示实体已经被从先前的查询中进行跟踪,因此您不需要调用_dbSet.Update
。
尝试通过从FindByCondition
方法中移除"AsNoTracking"语句,并在"Update"方法中简单地调用保存来解决问题:
public void Update(T entity)
{
_dbContext.SaveChanges();
}
public IQueryable<T> FindByCondition(Expression<Func<T, bool>> expression)
{
return _dbSet.Where(expression);
}
这里有一个很好的通用仓储模式实现,您可能希望重复使用:
public class GenericRepository<TEntity> : IRepository<TEntity> where TEntity : class
{
private DbContext _context;
private DbSet<TEntity> _dbSet;
public GenericRepository(DbContext context)
{
_context = context;
_dbSet = _context.Set<TEntity>();
}
public IQueryable<TEntity> GetQuery()
{
return _dbSet;
}
public IQueryable<TEntity> AsNoTracking()
{
return _dbSet.AsNoTracking<TEntity>();
}
public IEnumerable<TEntity> GetAll()
{
return GetQuery().AsEnumerable();
}
public IEnumerable<TEntity> Find(Expression<Func<TEntity, bool>> predicate)
{
return _dbSet.Where<TEntity>(predicate);
}
public Task<TEntity> FindAsync(params object[] keyValues)
{
return _dbSet.FindAsync(keyValues);
}
public TEntity Single(Expression<Func<TEntity, bool>> predicate)
{
return _dbSet.Single<TEntity>(predicate);
}
public TEntity First(Expression<Func<TEntity, bool>> predicate)
{
return _dbSet.First<TEntity>(predicate);
}
public TEntity FirstOrDefault(Expression<Func<TEntity, bool>> predicate)
{
return _dbSet.FirstOrDefault<TEntity>(predicate);
}
public void Delete(TEntity entity)
{
if (entity == null)
{
throw new ArgumentNullException("entity");
}
_dbSet.Remove(entity);
}
public void Add(TEntity entity)
{
if (entity == null)
{
throw new ArgumentNullException("entity");
}
_dbSet.Add(entity);
}
public void Attach(TEntity entity)
{
_dbSet.Attach(entity);
}
public void Detach(TEntity entity)
{
_context.Entry(entity).State = EntityState.Detached;
}
public void MarkModified(TEntity entity)
{
_context.Entry(entity).State = EntityState.Modified;
}
public DbEntityEntry<TEntity> GetEntry(TEntity entity)
{
return _context.Entry(entity);
}
public void SaveChanges()
{
_context.SaveChanges();
}
public void Dispose()
{
Dispose(true);
GC.SuppressFinalize(this);
}
protected virtual void Dispose(bool disposing)
{
if (disposing)
{
if (_context != null)
{
_context.Dispose();
_context = null;
}
}
}
}
这是接口:
public interface IRepository<TEntity> : IDisposable where TEntity : class
{
IQueryable<TEntity> GetQuery();
IEnumerable<TEntity> GetAll();
IQueryable<TEntity> AsNoTracking();
IEnumerable<TEntity> Find(Expression<Func<TEntity, bool>> predicate);
TEntity Single(Expression<Func<TEntity, bool>> predicate);
TEntity First(Expression<Func<TEntity, bool>> predicate);
TEntity FirstOrDefault(Expression<Func<TEntity, bool>> predicate);
void Add(TEntity entity);
void Delete(TEntity entity);
void Attach(TEntity entity);
void Detach(TEntity entity);
void MarkModified(TEntity entity);
void SaveChanges();
}
请注意,只有在实体未被跟踪时才需要调用 "Attach" 或 "MarkModified",在大多数情况下,您可以简单地查询一个已被跟踪的实体,修改一些属性,然后调用 "SaveChanges"。
您还可以将存储库与工作单元组合使用,以便更好地控制事务等内容。以下是一个示例:
public class UnitOfWork : IUnitOfWork
{
private readonly YouDatabaseContext _context = new YouDatabaseContext();
private DbContextTransaction _dbContextTransaction;
private GenericRepository<ExpenseReport> _expenseReportRepository;
private GenericRepository<ExpenseItem> _expenseItemRepository;
public GenericRepository<ExpenseReport> ExpenseReportRepository
{
get
{
if (_expenseReportRepository == null)
{
_expenseReportRepository = new GenericRepository<ExpenseReport>(_context);
}
return _expenseReportRepository;
}
set
{
_expenseReportRepository = value;
}
}
public GenericRepository<ExpenseItem> ExpenseItemRepository
{
get
{
if (_expenseItemRepository == null)
{
_expenseItemRepository = new GenericRepository<ExpenseItem>(_context);
}
return _expenseItemRepository;
}
set
{
_expenseItemRepository = value;
}
}
public void BeginTransaction()
{
_dbContextTransaction = _context.Database.BeginTransaction();
}
public void BeginTransaction(IsolationLevel isolationLevel)
{
_dbContextTransaction = _context.Database.BeginTransaction(isolationLevel);
}
public int Save()
{
return _context.SaveChanges();
}
public Task<int> SaveAsync()
{
return _context.SaveChangesAsync();
}
public void Commit()
{
if (_dbContextTransaction!=null)
{
_dbContextTransaction.Commit();
}
}
public void RollBack()
{
if (_dbContextTransaction != null)
{
_dbContextTransaction.Rollback();
}
}
private bool _disposed;
protected virtual void Dispose(bool disposing)
{
if (!_disposed)
{
if (disposing)
{
_context.Dispose();
_dbContextTransaction?.Dispose();
}
}
_disposed = true;
}
public void Dispose()
{
Dispose(true);
GC.SuppressFinalize(this);
}
}
接口如下:
public interface IUnitOfWork : IDisposable
{
void BeginTransaction();
void BeginTransaction(IsolationLevel isolationLevel);
int Save();
}