0

複数のデータベース間でのエンティティのコピーに問題があります。私はこの問題に頭を悩ませているように見えず、実装に関して本当に助けが必要です。

私の現在の実装はここで説明されています：

HTTP モジュール

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Web;
using ISMSControl.Infrastructure.Sessions;
using NHibernate;
using NHibernate.Context;

namespace ISMSControl.Infrastructure.Modules
{
    public class SessionModule : IHttpModule
    {
        public void Init(HttpApplication context)
        {
            context.BeginRequest += OpenSession;
            context.EndRequest += CloseSession;
        }
        private void CloseSession(object sender, EventArgs e)
        {
            ISession session = ManagedWebSessionContext.Unbind(HttpContext.Current, SessionManager.GetCurrentSession().SessionFactory);

            if (session != null)
            {
                if (session.Transaction != null && session.Transaction.IsActive)
                    session.Transaction.Rollback();
                else
                    session.Flush();

                session.Close();
            }
        }
        private void OpenSession(object sender, EventArgs e)
        {
            ManagedWebSessionContext.Bind(HttpContext.Current,
                SessionManager.GetCurrentSession());
        }
        public void Dispose()
        {
        }
    }
}

SessionManager の実装

using System;
using System.Collections.Generic;
using System.Configuration;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Web;
using FluentNHibernate.Cfg;
using FluentNHibernate.Cfg.Db;
using ISMSControl.Infrastructure.Mappings;
using NHibernate;
using NHibernate.Cache;

namespace ISMSControl.Infrastructure.Sessions
{
    public sealed class SessionManager
    {
        private const string CurrentSessionKey = "nhibernate.current_session";
        private static readonly ISessionFactory sessionFactory;

        static SessionManager()
        {
            sessionFactory = CreateSessionFactory("source");
        }

        private static ISessionFactory CreateSessionFactory(string connectionStringName)
        {
            return Fluently.Configure()
                .Database(MsSqlConfiguration.MsSql2008.ShowSql().ConnectionString(c => c.FromConnectionStringWithKey(connectionStringName)))
                .CurrentSessionContext("managed_web")
                .Cache(c =>
                {
                    c.UseQueryCache();
                    c.ProviderClass<HashtableCacheProvider>();
                })
                .Diagnostics(d =>
                {
                    d.Enable();
                    d.OutputToConsole();
                })
                .Mappings(m => m.FluentMappings.AddFromAssemblyOf<StandardMapping>())
                .BuildSessionFactory();
        }

        public static ISession GetCurrentSession()
        {
            HttpContext context = HttpContext.Current;
            ISession currentSession = context.Items[CurrentSessionKey] as ISession;

            if (currentSession == null)
            {
                currentSession = sessionFactory.OpenSession();
                context.Items[CurrentSessionKey] = currentSession;
            }

            return currentSession;
        }
        public static void CloseSession()
        {
            HttpContext context = HttpContext.Current;
            ISession currentSession = context.Items[CurrentSessionKey] as ISession;

            if (currentSession == null)
            {
                // No current session
                return;
            }
            currentSession.Close();
            context.Items.Remove(CurrentSessionKey);
        }
        public static void CloseSessionFactory(string sessionFactoryName = null)
        {
            if (sessionFactory != null)
            {
                sessionFactory.Close();
            }
        }
    }
}

リポジトリ

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Transactions;
using System.Web;
using ISMSControl.Domain;
using ISMSControl.Domain.Contracts;
using ISMSControl.Infrastructure.Sessions;
using NHibernate;
using NHibernate.Context;

namespace ISMSControl.Infrastructure.Repositories
{
    public class StandardRepository : IStandardRepository
    {
        public void SaveOrUpdate(Standard standard)
        {
            var session = SessionManager.GetCurrentSession();

            using (var transaction = session.BeginTransaction())
            {
                session.SaveOrUpdate(standard);
                transaction.Commit();
            }
        }
        public IEnumerable<Standard> RetrieveList()
        {
            return SessionManager.GetCurrentSession().CreateCriteria<Standard>().List<Standard>();
        }
        public void CopyTo(string database, Standard standard)
        {
            //how do i implement this method, so it will copy the standard entity to the other database?
        }
    }
}

問題は、「セッションが閉じられています。」、「エンティティが別のトランザクションまたは何かの下にある」などのさまざまな種類のエラーがすべて発生することです。「コレクションを 2 つの開いているセッションに関連付ける不正な試みです」。

誰かが私を正しい方向に向けるのを手伝ってくれることを本当に願っています.

  1. チュートリアル
  2. 例
  3. 等

CopyTo の実装

public void CopyTo(string sessionFactoryName, Standard standard)
    {
        //gets a new session for the destination database from the destination sessionfactory.
        using (var destinationSession = SessionFactoryContainer.Current.Get(sessionFactoryName).OpenSession())
        {
            //error: no persister for...
            var newStandard = new Standard();
            newStandard.Code = standard.Code;
            newStandard.Description = standard.Description;
            newStandard.Explanation = standard.Explanation;

            destinationSession.Save(newStandard);
        }
    }
4

1 に答える 1

1

「CopyTo」メソッドでは、2 番目のデータベースでセッションを作成し、メソッドの 2 番目のパラメーターをディープ クローンしてから、クローンしたオブジェクトを開いたセッションにアタッチする必要があります。

于 2012-04-05T11:58:56.163 に答える