使用 NHibernate 和 Autofac 管理多个数据库

Question

我想我会在自己思考解决方案的同时提出这个问题。

在构建了大部分应用程序后，我在最后一刻要求支持读/写附加数据库（总共 2 个，没有已知的其他数据库）。我使用 NHibernate 构建了该应用程序，并使用 Autofac 提供 DI/IoC 组件。 FWIW，它驻留在 ASP.NET MVC 2 应用程序中。

我有一个通用的存储库类，它接受 NHibernate 会话。理论上，只要传递给它的会话是从适当的 SessionFactory 生成的，我就可以继续为第二个数据库使用这个通用存储库 (IRepository<>)，对吗？

好吧，当应用程序启动时，Autofac 就会做它的事情。关于 Session 和 SessionFactory，我有一个模块指出：

builder.Register(c => c.Resolve<ISessionFactory>().OpenSession())
    .InstancePerMatchingLifetimeScope(WebLifetime.Request)
    .OnActivated(e =>
    {
        e.Context.Resolve<TransactionManager>().CurrentTransaction = ((ISession)e.Instance).BeginTransaction();
    });

 builder.Register(c => ConfigureNHibernate())
    .SingleInstance();

其中返回基本 SessionFactory 的ConfigureNHibernate() 看起来像：

private ISessionFactory ConfigureNHibernate()
{
    Configuration cfg = new Configuration().Configure();
    cfg.AddAssembly(typeof(Entity).Assembly);
    return cfg.Configure().BuildSessionFactory();
}

目前，这仅限于一个数据库。在任何其他 NHib 场景中，我可能会将单独的 SessionFactories 的实例推入哈希中，并根据需要检索它们。我不想重新架构整个事情，因为我们已经非常接近主要版本了。所以，我猜我至少需要修改上面的方法，以便我可以独立配置两个SessionFactory。我的灰色区域是我将如何指定与特定存储库（或至少对于特定于第二个数据库的实体）一起使用的正确工厂。

任何人在以这种方式使用 IoC 容器和 NHibernate 时都有过这种情况的经验吗？

编辑 我已经删除了一个 GetSessionFactory 方法，该方法采用配置文件路径，检查 HttpRuntime.Cache 中是否存在匹配的 SessionFactory，如果尚不存在则创建一个新实例，然后返回该 SessionFactory。现在我仍然需要弄清楚如何告诉 Autofac 如何以及何时指定适当的配置路径。新方法如下所示（大量借用了 Billy 2006 年的帖子此处）：

private ISessionFactory GetSessionFactory(string sessionFactoryConfigPath)
    {
        Configuration cfg = null;
        var sessionFactory = (ISessionFactory)HttpRuntime.Cache.Get(sessionFactoryConfigPath);

        if (sessionFactory == null)
        {
            if (!File.Exists(sessionFactoryConfigPath))
                throw new FileNotFoundException("The nhibernate configuration file at '" + sessionFactoryConfigPath + "' could not be found.");

            cfg = new Configuration().Configure(sessionFactoryConfigPath);
            sessionFactory = cfg.BuildSessionFactory();

            if (sessionFactory == null)
            {
                throw new Exception("cfg.BuildSessionFactory() returned null.");
            }

            HttpRuntime.Cache.Add(sessionFactoryConfigPath, sessionFactory, null, DateTime.Now.AddDays(7), TimeSpan.Zero, System.Web.Caching.CacheItemPriority.High, null);
        }

        return sessionFactory;
    }

Answer 1

我假设您希望不同类型的实体进入每个数据库；如果您想在每个数据库中保留相同类型的实体，请查看 AutofacContrib.Multitenant。

有助于解决此方案的两个要素是：

• 命名服务 http://code.google。 com/p/autofac/wiki/TypedNamedAndKeyedServices
• 已解析参数 http://code. google.com/p/autofac/wiki/ResolveParameters（关于此的最少文档 - 即将发布的 Autofac 2.4 版本对此有一些语法改进...）

首先，使用命名服务来引用两个不同的数据库。我将它们称为“db1”和“db2”。与数据库相关的所有组件，一直到会话，都使用一个名称进行注册：

builder.Register(c => ConfigureDb1())
    .Named<ISessionFactory>("db1")
    .SingleInstance();

builder.Register(c => c.ResolveNamed<ISessionFactory>("db1").OpenSession())
    .Named<ISession>("db1")
    .InstancePerLifetimeScope();

// Same for "db2" and so-on.

现在，假设您有一个接受 ISessionNHibernateRepository类型code> 作为其构造函数参数，并且您可以编写一个返回 "db1" 或 "db2" 的函数 WhichDatabase(TypeEntityType)当给定实体的类型时。

我们使用 ResolvedParameter 根据实体类型动态选择会话。

builder.RegisterGeneric(typeof(NHibernateRepository<>))
    .As(typeof(IRepository<>))
    .WithParameter(new ResolvedParameter(
        (pi, c) => pi.ParameterType == typeof(ISession),
        (pi, c) => c.ResolveNamed<ISession>(
            WhichDatabase(pi.Member.DeclaringType.GetGenericArguments()[0])));

（警告 - 在 Google Chrome 中编译和测试；））

现在，解析 IRepository 将选择适当的会话，并且 Autofac 将继续延迟初始化并正确处置会话。

当然，您必须仔细考虑事务管理。

希望这能起到作用！
注意