Wie verbinde ich eine Hibernate-Sitzung mit einem Thread in Grails?

Question

Ich schreibe eine Multithread-Anwendung in Grails und die zusätzlichen Threads benötigen Zugriff auf GORM/Hibernate. Wenn sie versuchen, auf GORM zuzugreifen, erhalte ich den Fehler "org.hibernate.HibernateException: Keine an den Thread gebundene Hibernate-Sitzung, und die Konfiguration erlaubt hier nicht die Erstellung von nicht-transaktionalen Sitzungen".

OK fair genug, kann mir jemand auf dem besten Weg helfen, die Threads einzurichten, um Zugang zu haben? Die Fehlermeldung klingt fast so, als müssten Sie nur einige Konfigurationsoptionen ändern, aber ich denke, es ist nicht so einfach ...

Answer 1

Es gibt eine Bohne in Grails-Anwendungen „persistenceInterceptor“ genannt, die verwendet werden können Dies.

Sehen Sie dieses Beispiel aus der JMS-Plugin, wie es zu benutzen:

http://github.com/gpc/grails-jms/blob/master/src/groovy/grails/plugin/jms/listener/adapter/PersistenceContextAwareListenerAdapter.groovy#L21

Hier ist die Schnittstelle:

https://github.com/grails/grails-core/blob/master/grails-core/src/main/groovy/grails/persistence/support/PersistenceContextInterceptor.java

Und Hibernate impl:

https://github.com/grails/grails-data-mapping/blob/master/grails-datastore-gorm-support/src/main/groovy/org/grails/orm/hibernate4/support/HibernatePersistenceContextInterceptor.java

Answer 2

Sie müssen alle GORM-Aufrufe in einen withTransaction-Abschluss einfügen. Ein Beispiel aus einer Diskussion über Multi-Threading, die am https://fbflex.wordpress.com/2010/06/11/writing-batch-import-scripts-with-grails-gsql-and-gpars/

Einzelgewinde

user = User.findByUsername(photo.username) 

Gewinde Multi

User.withTransaction{ 
user = User.findByUsername(photo.username) 
} 

Answer 3

withNewSession wird auch funktionieren. In meinem Fall habe ich Updates mit niedriger Priorität, bei denen das letzte Update immer "gewinnen" kann. version: false ist auch hier wichtig, um die StaleObjectException zu vermeiden:

 Thread.start { 
     try { 
      Widget.withNewSession { 
       xxx() 
       log.info "Asynchronously did some updates." 
      } 
     } catch (Exception ex) { 
      log.error "Failed to asynchronously do something...", ex 
     } 
    }