¿Cómo puedo vincular una sesión de Hibernate a un hilo en Grails?

Question

Escribo una aplicación multiproceso en Grails y los subprocesos adicionales necesitan acceso a GORM/Hibernate. Cuando intentan acceder a GORM, recibo el error "org.hibernate.HibernateException: ninguna sesión de Hibernate vinculada al hilo, y la configuración no permite la creación de una no transaccional aquí".

Bien, ¿alguien me puede guiar en la mejor manera de configurar los hilos para tener acceso? El mensaje de error casi suena como que solo necesita cambiar algunas opciones de configuración, pero siento que no es tan simple ...

Answer 1

Hay un frijol en aplicaciones Grails llamado “persistenceInterceptor” que se puede utilizar para esta.

Ver este ejemplo desde el plugin JMS sobre cómo usarlo:

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

Aquí es la interfaz:

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

y de hibernación 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

Debe realizar cualquier llamada GORM en un cierre conTransaction. Un ejemplo tomado de una discusión de múltiples subprocesos en https://fbflex.wordpress.com/2010/06/11/writing-batch-import-scripts-with-grails-gsql-and-gpars/

Individual roscada

user = User.findByUsername(photo.username) 

multihilo

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

Answer 3

con NewSession también funcionará. En mi caso, tengo actualizaciones de baja prioridad donde la última actualización siempre puede "ganar". version: false también es importante aquí para evitar la excepción StaleObjectException:

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