Come associare una sessione di sospensione a un thread in Grails?

Question

Sto scrivendo un'applicazione multi-thread in Grails e i thread aggiuntivi devono accedere a GORM/Hibernate. Quando provano ad accedere a GORM viene visualizzato l'errore "org.hibernate.HibernateException: nessuna sessione di sospensione legata al thread e la configurazione non consente la creazione di quella non transazionale qui".

OK abbastanza giusto, qualcuno può guidarmi sul modo migliore per impostare i thread per avere accesso? Il messaggio di errore sembra quasi dover cambiare alcune opzioni di configurazione, tuttavia, non è così semplice ...

Answer 1

C'è un fagiolo in applicazioni Grails chiamato “persistenceInterceptor” che può essere utilizzato per Questo.

Vedere questo esempio dal plugin JMS su come usarlo:

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

Qui è l'interfaccia:

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

e 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

È necessario inserire qualsiasi chiamata GORM in una chiusura withTransaction. Un esempio tratto da una discussione di multi filettatura a https://fbflex.wordpress.com/2010/06/11/writing-batch-import-scripts-with-grails-gsql-and-gpars/

singolo filettato

user = User.findByUsername(photo.username) 

multi threaded

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

Answer 3

withNewSession funzionerà anche. Nel mio caso, ho aggiornamenti a bassa priorità in cui l'ultimo aggiornamento può sempre "vincere". version: false è anche importante al fine di evitare lo StaleObjectException:

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