首页
学习
活动
专区
工具
TVP
发布
社区首页 >问答首页 >使用Ninject的ASP.NET MVC3应用程序,实体框架4代码优先CTP5,模式

使用Ninject的ASP.NET MVC3应用程序,实体框架4代码优先CTP5,模式
EN

Stack Overflow用户
提问于 2011-01-24 21:12:57
回答 2查看 7.7K关注 0票数 17

我已经尝试用上面的技术建立了一些基础项目。我想要最大限度的灵活性和可测试性,所以我尝试使用模式,使其成为未来项目的基础。然而,似乎出了什么问题,我真的需要帮助。所以我有两个问题:

  1. 我当前的代码有什么问题吗?我正确地应用了模式吗?
  2. 为什么这段代码实际上连接到数据库,创建它,但即使我执行更正操作,也不支持insert?(有关此错误的详细信息,请查看帖子的末尾) FIXED

我相信这也可以帮助其他人,因为我还没有找到足够的信息来正确地编造一些东西。我非常确定很多人试图以正确的方式来做这件事,并且不像我一样确定我所做的事情是否正确。

我有两个实体:评论和评论

评论

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

  • ASP.NET MVC 3的
  • Entity Framework4作为DI Container
  • SQL
  • Express (非R2)
  • 2010 Web Express
EN

回答 2

Stack Overflow用户

回答已采纳

发布于 2011-01-25 07:34:35

哇哦。这个很鬼鬼怪的。实际上,我知道的东西不多,所以我不能马上弄明白。

我找到了与错误相关的第二个问题的解决方案,因为我发现ninject实际上捕获了DatabaseFactory的两个实例,一个用于存储库,另一个用于工作单元。实际上,错误并不是问题所在。这是对象数据库中的一个内部错误,但我认为这是正常的,因为我使用的是实体框架。

真正的问题是,Ninject绑定了两个不同的IDatabaseFactory实例,导致2个连接打开。

评论被添加到使用数据库的第一个实例的_reviewRepostory中的第一个集合中。

在工作单元上调用commit时..由于审查不在此数据库实例上,因此没有保存任何内容。事实上,工作单元称为数据库工厂,它导致创建一个新实例,因为ninject发送了它的一个新实例。

要修复它,只需使用:

 Bind<IDatabaseFactory>().To<DatabaseFactory>().InSingletonScope();

而不是

Bind<IDatabaseFactory>().To<DatabaseFactory>();

现在所有的系统都能正常工作了!

现在,我想要一些关于第一个问题的答案,如果我当前的代码有任何问题?我是否正确地应用了模式?有什么建议或建议可以把我引向正确的方向吗?

票数 11
EN

Stack Overflow用户

发布于 2012-03-15 10:49:48

一个小的注意事项:通过让EFRepositoryBaseIReviewRepository具有返回IEnumerable<>而不是IQueryable<>的方法,可以防止后续方法向查询添加过滤器表达式/约束或投影等。相反,通过使用IEnumerable<>,您将对整个结果集进行任何后续筛选(例如,使用LINQ扩展方法),而不是允许这些操作影响和简化对数据存储运行的SQL语句。

换句话说,如果可能的话,您是在where服务器级别进行进一步的过滤,而不是在数据库级别进行过滤。

当然,这也可能是有意为之--有时,如果您确实想要阻止函数的调用者修改生成的SQL,那么使用IEnumerable<>是有效的。

票数 5
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/4782364

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档