Public NotInheritable Class NHibernateSessionManager
' <summary>
' This is a thread-safe, lazy singleton. See http://www.yoda.arachsys.com/csharp/singleton.html
' for more details about its implementation.
' </summary>
Public Shared _Instance As NHibernateSessionManager
Public Shared Property Instance() As NHibernateSessionManager
Get
Return Nested.nHibernateSessionManager
End Get
Set(ByVal value As NHibernateSessionManager)
End Set
End Property
' <summary>
' Initializes the NHibernate session factory upon instantiation.
' </summary>
Private Sub New()
InitSessionFactory()
End Sub
' <summary>
' Assists with ensuring thread-safe, lazy singleton
' </summary>
Private Class Nested
Shared Sub New()
End Sub
Friend Shared ReadOnly nHibernateSessionManager As NHibernateSessionManager = New NHibernateSessionManager()
End Class
Private Sub InitSessionFactory()
'Dim cfg As NHibernate.Cfg.Configuration = New NHibernate.Cfg.Configuration()
'' The following makes sure the the web.config contains a declaration for the HBM_ASSEMBLY appSetting
'If ConfigurationManager.AppSettings("HBM_ASSEMBLY") Is Nothing Or ConfigurationManager.AppSettings("HBM_ASSEMBLY") = "" Then
' Throw New ConfigurationErrorsException("NHibernateManager.InitSessionFactory: ""HBM_ASSEMBLY"" must be " & _
' "provided as an appSetting within your config file. ""HBM_ASSEMBLY"" informs NHibernate which assembly " & _
' "contains the HBM files. It is assumed that the HBM files are embedded resources. An example config " & _
' "declaration is <add key=""HBM_ASSEMBLY"" value=""MyProject.Core"" />")
'End If
'cfg.AddAssembly(System.Configuration.ConfigurationManager.AppSettings("HBM_ASSEMBLY"))
sessionFactory = New NHibernate.Cfg.Configuration().Configure.BuildSessionFactory
End Sub
' <summary>
' Allows you to register an interceptor on a new session. This may not be called if there is already
' an open session attached to the HttpContext. If you have an interceptor to be used, modify
' the HttpModule to call this before calling BeginTransaction().
' </summary>
Public Sub RegisterInterceptor(ByVal interceptor As IInterceptor)
Dim session As ISession = threadSession
If (Not session Is Nothing) And session.IsOpen Then
Throw New CacheException("You cannot register an interceptor once a session has already been opened")
End If
GetSession(interceptor)
End Sub
Public Function GetSession() As ISession
Return GetSession(Nothing)
End Function
' <summary>
' Gets a session with or without an interceptor. This method is not called directly instead,
' it gets invoked from other public methods.
' </summary>
Private Function GetSession(ByVal interceptor As IInterceptor) As ISession
Dim session As ISession = threadSession
If session Is Nothing Then
If Not interceptor Is Nothing Then
session = sessionFactory.OpenSession(interceptor)
Else
session = sessionFactory.OpenSession()
End If
End If
threadSession = session
Return session
End Function
Public Sub CloseSession()
Dim session As ISession = threadSession
threadSession = Nothing
If (Not session Is Nothing) And session.IsOpen Then
Console.WriteLine("")
Console.WriteLine("***** Session Close")
session.Close()
End If
End Sub
Public Sub BeginTransaction()
Dim transaction As ITransaction = _threadTransaction
If transaction Is Nothing Then
transaction = GetSession().BeginTransaction()
_threadTransaction = transaction
Console.WriteLine("")
Console.WriteLine("***** Transaction Begin")
End If
End Sub
Public Sub CommitTransaction()
Dim transaction As ITransaction = _threadTransaction
Try
If (Not transaction Is Nothing) And (Not transaction.WasCommitted) And (Not transaction.WasRolledBack) Then
transaction.Commit()
_threadTransaction = Nothing
Console.WriteLine("")
Console.WriteLine("***** Transaction Commit")
End If
Catch ex As HibernateException
RollbackTransaction()
Throw ex
End Try
End Sub
Public Sub RollbackTransaction()
Dim transaction As ITransaction = _threadTransaction
Try
_threadTransaction = Nothing
If (Not transaction Is Nothing) And (Not transaction.WasCommitted) And (Not transaction.WasRolledBack) Then
transaction.Rollback()
End If
Catch ex As HibernateException
Throw ex
Finally
CloseSession()
End Try
End Sub
Friend _threadTransaction As ITransaction
Friend Property threadTranaction() As ITransaction
Get
Return CallContext.GetData("THREAD_TRANSACTION")
End Get
Set(ByVal value As ITransaction)
CallContext.SetData("THREAD_TRANSACTION", value)
End Set
End Property
Private _threadSession As ISession
Public Property threadSession() As ISession
Get
Return CallContext.GetData("THREAD_SESSION")
End Get
Set(ByVal value As ISession)
CallContext.SetData("THREAD_SESSION", value)
End Set
End Property
Private sessionFactory As ISessionFactory
End Class
then call load the POCO before begin transaction.
Login
FAQ
Search
