问使用ISession包装器的IStatelessSession

EN

public class NHibernateDataContext : IDataContext {
    private readonly ISession _session;

    public NHibernateDataContext(ISession session) {
        _session = session;
        Begin();
    }

    public IRepository<T> Repository<T>() where T : class {
        return new NHibernateRepository<T>(_session);
    }

    public void Begin() {
        if (!_session.Transaction.IsActive)
            _session.BeginTransaction();
    }

    public void Commit() {
        if (_session.Transaction.IsActive)
            _session.Transaction.Commit();
    }

    public void Dispose() {
        _session.Close();
    }
}

public class NHibernateRepository<T> : IRepository<T> where T : class {
    private readonly ISession _session;

    public NHibernateRepository(ISession session) {
        _session = session;
    }

    public IQueryable<T> GetAll() {
        return _session.Query<T>();
    }

    public T GetByID(int id) {
        return _session.Get<T>(id);
    }

    public void Insert(T entity) {
        _session.SaveOrUpdate(entity);
    }

    public void Delete(T entity) {
        _session.Delete(entity);
    }
}

// Configure the container
container.RegisterType<ISessionFactory>(new ContainerControlledLifetimeManager(), new InjectionFactory(c => {
    return CreateSessionFactory();
}));
container.RegisterType<ISession>(new InjectionFactory(c => {
    var sessionFactory = container.Resolve<ISessionFactory>();
    return sessionFactory.OpenSession();
}));
container.RegisterType<IDataContext, NHibernateDataContext>(new PerRequestLifetimeManager<IDataContext>());