我已经尝试用上面的技术建立了一些基础项目。我想要最大限度的灵活性和可测试性,所以我尝试使用模式,使其成为未来项目的基础。然而,似乎出了什么问题,我真的需要帮助。所以我有两个问题:
我相信这也可以帮助其他人,因为我还没有找到足够的信息来正确地编造一些东西。我非常确定很多人试图以正确的方式来做这件事,并且不像我一样确定我所做的事情是否正确。
我有两个实体:评论和评论
评论
public class Comment
{
[Key]
public virtual int Id { get; set; }
public virtual string Name { get; set; }
public virtual string Author { get; set; }
public virtual string Body { get; set; }
}
审阅
public class Review
{
[Key]
public virtual int Id { get; set; }
public virtual string Name { get; set; }
public virtual string Author { get; set; }
public virtual string Body { get; set; }
public virtual bool Visible { get; set; }
public IEnumerable<Comment> Comments { get; set; }
}
我以这种方式为他们中的每一个建立了一个基础存储库:
通用存储库
public abstract class EFRepositoryBase<T> : IRepository<T> where T : class
{
private Database _database;
private readonly IDbSet<T> _dbset;
protected IDatabaseFactory DatabaseFactory { get; private set; }
protected Database Database { get { return _database ?? (_database = DatabaseFactory.Get()); } }
public EFRepositoryBase(IDatabaseFactory databaseFactory)
{
DatabaseFactory = databaseFactory;
_dbset = Database.Set<T>();
}
public virtual void Add(T entity)
{
_dbset.Add(entity);
}
public virtual void Delete(T entity)
{
_dbset.Remove(entity);
}
public virtual T GetById(long id)
{
return _dbset.Find(id);
}
public virtual IEnumerable<T> All()
{
return _dbset.ToList();
}
}
对于特定于的操作,我使用一个接口:
public interface IReviewRepository : IRepository<Review> {
// Add specific review operations
IEnumerable<Review> FindByAuthor(string author);
}
因此,我从抽象类中获取泛型操作,再加上特定操作:
public class EFReviewRepository : EFRepositoryBase<Review>, IReviewRepository
{
public EFReviewRepository(IDatabaseFactory databaseFactory)
: base(databaseFactory)
{ }
public IEnumerable<Review> FindByAuthor(string author)
{
return base.Database.Reviews.Where(r => r.Author.StartsWith(author))
.AsEnumerable<Review>();
}
}
正如您所了解的,我还使用了一个数据库工厂来生成数据库上下文:
数据库工厂
public class DatabaseFactory : Disposable, IDatabaseFactory
{
private Database _database;
public Database Get()
{
return _database ?? (_database = new Database(@"AppDb"));
}
protected override void DisposeCore()
{
if (_database != null)
_database.Dispose();
}
}
DISPOSABLE (一些扩展方法...)
public class Disposable : IDisposable
{
private bool isDisposed;
~Disposable()
{
Dispose(false);
}
public void Dispose()
{
Dispose(true);
GC.SuppressFinalize(this);
}
private void Dispose(bool disposing)
{
if (!isDisposed && disposing)
{
DisposeCore();
}
isDisposed = true;
}
protected virtual void DisposeCore()
{
}
}
数据库
public class Database : DbContext
{
private IDbSet<Review> _reviews;
public IDbSet<Review> Reviews
{
get { return _reviews ?? (_reviews = DbSet<Review>()); }
}
public virtual IDbSet<T> DbSet<T>() where T : class
{
return Set<T>();
}
public Database(string connectionString)
: base(connectionString)
{
//_reviews = Reviews;
}
public virtual void Commit()
{
base.SaveChanges();
}
/*
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
// TODO: Use Fluent API Here
}
*/
}
最后,我有我的工作单位……
工作单元
public class UnitOfWork : IUnitOfWork
{
private readonly IDatabaseFactory _databaseFactory;
private Database _database;
public UnitOfWork(IDatabaseFactory databaseFactory)
{
_databaseFactory = databaseFactory;
}
protected Database Database
{
get { return _database ?? (_database = _databaseFactory.Get()); }
}
public void Commit()
{
Database.Commit();
}
}
我还使用Ninject绑定了接口:
NINJECT控制器工厂
public class NinjectControllerFactory : DefaultControllerFactory
{
// A Ninject "Kernel" is the thing that can supply object instances
private IKernel kernel = new StandardKernel(new ReviewsDemoServices());
// ASP.NET MVC calls this to get the controller for each request
protected override IController GetControllerInstance(RequestContext requestContext, Type controllerType)
{
if (controllerType == null)
return null;
return (IController)kernel.Get(controllerType);
}
private class ReviewsDemoServices : NinjectModule
{
public override void Load()
{
// Bindings...
Bind<IReviewRepository>().To<EFReviewRepository>();
Bind<IUnitOfWork>().To<UnitOfWork>();
Bind<IDatabaseFactory>().To<DatabaseFactory>();
Bind<IDisposable>().To<Disposable>();
}
}
}
但是,当我调用构造函数(默认操作)时...
public class ReviewController : Controller
{
private readonly IReviewRepository _reviewRepository;
private readonly IUnitOfWork _unitOfWork;
public ReviewController(IReviewRepository postRepository, IUnitOfWork unitOfWork)
{
_reviewRepository = postRepository;
_unitOfWork = unitOfWork;
}
public ActionResult Index()
{
Review r = new Review { Id = 1, Name = "Test", Visible = true, Author = "a", Body = "b" };
_reviewRepository.Add(r);
_unitOfWork.Commit();
return View(_reviewRepository.All());
}
}
这似乎创建了数据库,但并没有在EF4中的数据库中插入任何内容。看起来我也许能找到问题所在。在查看数据库对象时..连接状态为closed,服务器版本抛出此类异常:
ServerVersion = '(((System.Data.Entity.DbContext (_database)).Database.Connection).ServerVersion' threw an exception of type 'System.InvalidOperationException'
我做的事情是对的吗?我构建的东西有什么问题吗?
另外,如果你对我发布的代码有建议,我会很高兴。我只是想学习在MVC3中构建任何类型的应用程序的正确方法,我想有一个好的开始。
我使用:
采用Code-First
发布于 2011-01-25 07:34:35
哇哦。这个很鬼鬼怪的。实际上,我知道的东西不多,所以我不能马上弄明白。
我找到了与错误相关的第二个问题的解决方案,因为我发现ninject实际上捕获了DatabaseFactory的两个实例,一个用于存储库,另一个用于工作单元。实际上,错误并不是问题所在。这是对象数据库中的一个内部错误,但我认为这是正常的,因为我使用的是实体框架。
真正的问题是,Ninject绑定了两个不同的IDatabaseFactory实例,导致2个连接打开。
评论被添加到使用数据库的第一个实例的_reviewRepostory中的第一个集合中。
在工作单元上调用commit时..由于审查不在此数据库实例上,因此没有保存任何内容。事实上,工作单元称为数据库工厂,它导致创建一个新实例,因为ninject发送了它的一个新实例。
要修复它,只需使用:
Bind<IDatabaseFactory>().To<DatabaseFactory>().InSingletonScope();
而不是
Bind<IDatabaseFactory>().To<DatabaseFactory>();
现在所有的系统都能正常工作了!
现在,我想要一些关于第一个问题的答案,如果我当前的代码有任何问题?我是否正确地应用了模式?有什么建议或建议可以把我引向正确的方向吗?
发布于 2012-03-15 10:49:48
一个小的注意事项:通过让EFRepositoryBase
和IReviewRepository
具有返回IEnumerable<>
而不是IQueryable<>
的方法,可以防止后续方法向查询添加过滤器表达式/约束或投影等。相反,通过使用IEnumerable<>
,您将对整个结果集进行任何后续筛选(例如,使用LINQ扩展方法),而不是允许这些操作影响和简化对数据存储运行的SQL语句。
换句话说,如果可能的话,您是在where服务器级别进行进一步的过滤,而不是在数据库级别进行过滤。
当然,这也可能是有意为之--有时,如果您确实想要阻止函数的调用者修改生成的SQL,那么使用IEnumerable<>
是有效的。
https://stackoverflow.com/questions/4782364
复制相似问题