保存更改在Encapsulated UnitOFWork类中不起作用
本文关键字:不起作用 UnitOFWork Encapsulated 保存更改 | 更新日期: 2023-09-27 18:24:00
嗨,我正试图首先使用实体框架代码创建一个通用存储库,并将所有内容封装在UnitOfWork中,但肯定出了问题,因为当我尝试添加并使用封装的SaveChanges时,它不起作用。这是我的存储库代码:
public class Repository<T> : IRepository<T> where T : class
{
private DbContext Context { get; set; }
private DbSet<T> DbSet
{
get { return Context.Set<T>(); }
}
public Repository(DbContext context)
{
Context = context;
}
public virtual IEnumerable<T> GetAll()
{
return DbSet;
}
public virtual T GetById(int id)
{
return DbSet.Find(id);
}
public virtual void Add(T entity)
{
DbEntityEntry dbEntityEntry = Context.Entry(entity);
if (dbEntityEntry.State != EntityState.Detached)
{
dbEntityEntry.State = EntityState.Added;
}
else
{
DbSet.Add(entity);
}
}
public virtual void Update(T entity)
{
DbEntityEntry dbEntityEntry = Context.Entry(entity);
if (dbEntityEntry.State == EntityState.Detached)
{
DbSet.Attach(entity);
}
DbSet.Attach(entity);
}
public virtual void Remove(T entity)
{
DbEntityEntry dbEntityEntry = Context.Entry(entity);
if (dbEntityEntry.State != EntityState.Deleted)
{
dbEntityEntry.State = EntityState.Deleted;
}
else
{
DbSet.Attach(entity);
DbSet.Remove(entity);
}
}
public virtual void Remove(int id)
{
var entity = GetById(id);
if (entity == null)
{
return;
}
Remove(entity);
}
}
这是我的UnitOfWork代码:
public class UnitOfWork
{
private readonly RepositoryFactory repositoryFactory;
private DatabaseContext DbContext
{
get { return new DatabaseContext(); }
}
public IRepository<Product> Products
{
get
{
return repositoryFactory.GetRepository<Product>(DbContext);
}
}
public UnitOfWork()
{
repositoryFactory = new RepositoryFactory();
}
public void SavaChanges()
{
DbContext.SaveChanges();
}
}
这是我调用的添加数据和获取数据的代码:
var sa = new UnitOfWork();
var repository = sa.Products;;
var result = repository.GetAll();
var resultbyId = repository.GetById(3);
var product = new Product()
{
Name = "sddasd",
CategoryId = 1,
SubcategoryId = 1,
Price = 21,
Description = "dsadasfas",
ImagePath = "Dsadas",
NumberOfProducts = 29
};
repository.Add(product);
sa.SavaChanges()
运行完这段代码后,由于某种原因,UnitOfWork类中封装的SaveChanges似乎不起作用。
但是,例如,如果我将在DbSet.add(实体)之后添加这一行
Context.SaveChanges()
对象get似乎已添加到数据库中。
如何使我的UnitOfWork SaveChanges方法工作?
代码中的问题就在这里:
private DatabaseContext DbContext
{
get { return new DatabaseContext(); }
}
每次访问您的属性时,您有效地创建了一个新的上下文。虽然Repository<T>
正确地保存了一个上下文并重复使用同一个上下文,但当您调用UnitOfWork.SaveChanges
时,您正在保存一个新创建的上下文,没有任何更改。
本着UnitOfWork的精神,您希望您的上下文在封闭类(UnitOfWork
)的整个生命周期中都存在。试试这个:
private DatabaseContext dbContext;
private DatabaseContext DbContext
{
get { return dbContext ?? (dbContext = new DatabaseContext()); }
}
这样,在首次访问DbContext
属性时,您的DatabaseContext
在UnitOfWork
的生命周期中将只创建一次。