如何使用 NHibernate 在单个应用程序中连接到多个数据库？

Question

我们需要连接到两个 Oracle 数据库和一个 DB2 数据库。我们将 NHibernate 5 与 Oracle Managed Data Access for Oracle 一起使用。虽然有一些可用的资源，但其中大部分已经很旧了。我们处理过单个数据库没有任何问题，但从未处理过多个数据库。我仍然不知道如何开始。如果有人可以分享一些见解或一些示例代码，将不胜感激。

Answer 1

为ISessionFactory每个数据库创建和维护单独的实例是可行的方法。因此，在您的情况下，您将拥有三个实例。我已经在我的一个应用程序中实现了这一点，在该应用程序中，我使用三个不同的 RDBMS 连接到三个数据库。

正如您所说，您已经使用过单个数据库和 NHibernate，我认为不需要任何特定代码。它相同，只是多个会话工厂实例。无论如何，我在答案末尾复制了我的代码。

创建ISession实例时，请确保从要连接的会话工厂实例创建它。应用程序的其余部分保持不变。

请注意，而像记录它可能会创建一个问题，一个我面对。但是，那只是一个。其他一切都很顺利，没有问题。

示例代码：

注意：下面代码中的一些类型不是 NHibernate 类型。那些是他们的包装。名称相似；所以理解代码应该没有问题。

public sealed class NHSessionFactory

{

    /*

     * This must be instance class.

     * New instance should be created for each Database Schema.

     * Maintain the instance in calling application.

     * This is useful if multiple databases are used in one application.

    */

    NHSessionFactoryInternal nhSessionFactoryInternal = null;

    public void Start(NHSessionFactoryStartParams startParams)

    {

        Configuration nhConfiguration;

        nhConfiguration = new Configuration();

        nhConfiguration.SetProperty(NHibernate.Cfg.Environment.Dialect, startParams.Dialect);

        nhConfiguration.SetProperty(NHibernate.Cfg.Environment.ConnectionString, startParams.ConnectionString);

        if(string.IsNullOrEmpty(startParams.DefaultSchema) == false)

            nhConfiguration.SetProperty(NHibernate.Cfg.Environment.DefaultSchema, startParams.DefaultSchema);

        nhConfiguration.SetProperty(NHibernate.Cfg.Environment.Isolation, "ReadCommitted");

        nhConfiguration.SetProperty(NHibernate.Cfg.Environment.BatchSize, NHSettings.DefaultBatchSize.ToString());

        if(string.IsNullOrEmpty(startParams.LogFilePath) == false)

        {

            nhConfiguration.SetProperty(NHibernate.Cfg.Environment.ShowSql, "true");

            nhConfiguration.SetProperty(NHibernate.Cfg.Environment.FormatSql, "true");

        }

        else

        {

            nhConfiguration.SetProperty(NHibernate.Cfg.Environment.ShowSql, "false");

            nhConfiguration.SetProperty(NHibernate.Cfg.Environment.FormatSql, "false");

        }

        nhConfiguration.AddMapping(startParams.HbmMappingInstance);

        try

        {

            nhSessionFactoryInternal = new NHSessionFactoryInternal();

            nhSessionFactoryInternal.CreateSessionFactory(nhConfiguration);

        }

        catch(Exception exception)

        {

            Stop();

            throw new NHWrapperException("Failed to create session factory.", exception);

        }

    }

    public void Stop()

    {

        if(nhSessionFactoryInternal == null)

            return;

        nhSessionFactoryInternal.CloseSessionFactory();

        nhSessionFactoryInternal = null;

    }

    public INHSession CreateSession(bool readOnly)

    {

        if(nhSessionFactoryInternal == null)

            throw new NHWrapperException("NHWrapper is not started.");

        return nhSessionFactoryInternal.CreateNHSession(readOnly);

    }

}

下面是NHSessionFactoryInternal上面代码中使用的类的实现。您可以毫无问题地组合这两个类。我在那里还有其他部分；所以我更喜欢把它分开。

internal sealed class NHSessionFactoryInternal

{

    ISessionFactory sessionFactory;

    internal ISessionFactory SessionFactory { get { return sessionFactory; } }

    internal void CreateSessionFactory(Configuration nhConfiguration)

    {

        if(sessionFactory != null)

            throw new NHWrapperException("SessionFactory is already created.");

        try

        {

            sessionFactory = nhConfiguration.BuildSessionFactory();

        }

        catch(Exception exception)

        {

            throw new NHWrapperException("Failed to build session factory.", exception);

        }

    }

    internal INHSession CreateNHSession(bool readOnly = false)

    {

        if(sessionFactory == null)

            throw new NHWrapperException("Session factory is not build.");

        return new NHSession(sessionFactory.OpenSession(), NHSettings.DefaultFlushMode, readOnly);

    }

    internal void CloseSessionFactory()

    {

        if(sessionFactory == null)

            return;

        if(sessionFactory.IsClosed == false)

            sessionFactory.Close();

        sessionFactory.Dispose();

        sessionFactory = null;

    }

}