1

首次使用：Asp.NET MVC、NHibernate(FNH)、DI 使用 Ninject。我能够使用一个数据库来完成所有工作，但现在我正在尝试使用两个数据库（例如，DB1 和 DB2）。我有一个 SessionFactory(s) 字典，它以数据库标识符为键。

我不知道如何根据构造函数注入的请求来选择正确的会话。我见过这个如何将不同的 NHibernate 会话（多数据库）注入到同一个存储库中，使用 Controller 控制 Ninject 的哪些会话，但我没有让它工作。 

public ProductController(DB1.Model.IRepository<Product> prodRepo, DB2.Model.IRepository<Account> acctRepo)
{
    [...]
}

NinjectWebCommon.cs 片段

private static void RegisterServices(IKernel kernel)
{            
    kernel.Bind<ISession>().ToMethod(ctx => NHibernateSessionModule.Provider.GetCurrentSession()).InRequestScope();             
    kernel.Bind(typeof(DB1.Model.IRepository<>)).To(typeof(NHibernateRepository<>));
    kernel.Bind(typeof(DB2.Model.IRepository<>)).To(typeof(NHibernateRepository<>));
}

NHibernateSessionModule.cs：通过开始/结束请求进行 UOW

public class NHibernateSessionModule : IHttpModule
{        
    public static ISessionFactoryProvider Provider = new MultipleSessionFactoryProvider();

    public void Dispose() { }

    public void Init(HttpApplication context)
    {
        context.BeginRequest += BeginRequest;
        context.EndRequest += EndRequest;
    }

    public void BeginRequest(object sender, EventArgs e)
    {
        Provider.BindNew();
    }

    public void EndRequest(object sender, EventArgs e)
    {
        Provider.Unbind();
    }
}

MultipleSessionFactoryProvider.cs：不太确定我在这里做的一切是否正确。

public class MultipleSessionFactoryProvider : ISessionFactoryProvider
{
    public Dictionary<string, ISessionFactory> SessionFactories { get; private set; }

    public static Func<Dictionary<string,ISessionFactory>> InitSessionFactories = GetFactories;

    public MultipleSessionFactoryProvider() : this(InitSessionFactories())
    {

    }

    public MultipleSessionFactoryProvider(Dictionary<string, ISessionFactory> factories)
    {
        SessionFactories = factories;            
    }

    public static Dictionary<string, ISessionFactory> GetFactories()
    {
        Dictionary<string, ISessionFactory> ret = new Dictionary<string, ISessionFactory>();
        Dictionary<string, string> connectionStrings = new Dictionary<string, string>();
        connectionStrings.Add(ConfigurationManager.ConnectionStrings["DB1"].Name, ConfigurationManager.ConnectionStrings["DB1"].ConnectionString.ToString());
        connectionStrings.Add(ConfigurationManager.ConnectionStrings["DB2"].Name, ConfigurationManager.ConnectionStrings["DB2"].ConnectionString.ToString());

        foreach (KeyValuePair<string, string> pair in connectionStrings)
        {
            //Better way to do the mapping?
            ISessionFactory factory = Fluently.Configure()
            .Database(MsSqlConfiguration.MsSql2008.ConnectionString(pair.Value))
            .Mappings(cfg => cfg.FluentMappings.Conventions.Setup(x => x.Add(AutoImport.Never()))
            .AddFromAssemblyOf<ProductMap>())
            .BuildConfiguration()
            .CurrentSessionContext<WebSessionContext>().BuildSessionFactory();               

            ret.Add(pair.Key, factory);
        }

        return ret;
    }

    public void BindNew()
    {
        foreach (KeyValuePair<string, ISessionFactory> factory in SessionFactories)
        {
            Bind(OpenSession(factory.Key));
        }            
    }

    public void Bind(ISession session)
    {
        CurrentSessionContext.Bind(session);
    }

    public void Unbind()
    {            
        foreach (KeyValuePair<string, ISessionFactory> factory in SessionFactories)
        {
            if (CurrentSessionContext.HasBind(factory.Value))
            {
                var sess = CurrentSessionContext.Unbind(factory.Value);
                sess.Dispose(); 
            }
        }
    }

    public ISession OpenSession(string factoryId)
    {
        return SessionFactories[factoryId].OpenSession();
    }


    public ISession GetCurrentSession()
    {

        string factoryId = GetIdentifier(); //<--- How to implement this

        return SessionFactories[factoryId].GetCurrentSession();
    }

    public String GetIdentifier()
    {
        return "DB1"; //Hardcoded for example

    }

那么，我该如何实现GetIdentifier()或更改我的 Ninject 绑定。我确实看过 Ninject Named binding，但在绑定 Session 时不明白如何使用它。

public ProductController([Name("DB1")]DB1.Model.IRepository<Product> prodRepo, [Name("DB2")]DB2.Model.IRepository<Account> acctRepo)

由于这是我第一次使用这些技术，请让我知道我是否在做任何超出实践的事情，或者可能会引起关注；我想继续使用 HttpModule。

4

1 回答 1

2

您需要两个会话绑定，每个数据库一个

kernel.Bind<ISession>().ToMethod(ctx => GetSessionForDB1()).WhenInjectedInto(typeof(DB1.Model.IRepository<>)).InRequestScope();

kernel.Bind<ISession>().ToMethod(ctx => GetSessionForDB2()).WhenInjectedInto(typeof(DB2.Model.IRepository<>)).InRequestScope();
于 2013-01-19T01:12:13.103 回答