Jak powiązać sesję hibernacji z wątkiem w Grails?

Question

Piszę wielowątkową aplikację w Grails, a dodatkowe wątki potrzebują dostępu do GORM/Hibernate. Kiedy próbują uzyskać dostęp do GORM, pojawia się błąd "org.hibernate.HibernateException: Brak sesji hibernacji związanej z wątkiem, a konfiguracja nie pozwala na utworzenie tutaj nietransakcyjnego".

OK, wystarczy, czy ktoś poprowadzi mnie w najlepszy sposób, aby ustawić wątki, aby uzyskać dostęp? Komunikat o błędzie brzmi, jakbyś musiał zmienić niektóre opcje konfiguracji, ale wyczuwam, to nie jest takie proste ...

Answer 1

Jest fasoli w zastosowaniach GRAILS zwane „persistenceInterceptor”, które mogą być stosowane do to.

Zobacz ten przykład z wtyczki JMS, w jaki sposób z niego korzystać:

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

Oto interfejs:

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

i hibernacji 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

Musisz umieścić wszystkie wywołania GORM w zamknięciu Transakcja. Przykładem z omówienie wielu gwintu w https://fbflex.wordpress.com/2010/06/11/writing-batch-import-scripts-with-grails-gsql-and-gpars/

Pojedynczy gwintowany

user = User.findByUsername(photo.username) 

wiele gwintowanych

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

Answer 3

withNewSession również będzie działać. W moim przypadku mam aktualizacje o niskim priorytecie, gdzie ostatnia aktualizacja zawsze może "wygrać". Ważne jest także tutaj: version: false, aby uniknąć wyjątku StaleObjectException:

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