Làm cách nào để gắn một phiên Hibernate vào một chuỗi trong Grails?

Question

Tôi đang viết một ứng dụng đa luồng trong Grails và các chủ đề bổ sung cần truy cập vào GORM/Hibernate. Khi họ cố gắng truy cập GORM, tôi nhận được lỗi "org.hibernate.HibernateException: Không có phiên Hibernate nào bị ràng buộc với luồng và cấu hình không cho phép tạo một giao dịch không giao dịch tại đây".

OK đủ công bằng, ai đó có thể hướng dẫn tôi cách tốt nhất để đặt chuỗi lên để có quyền truy cập? Các thông báo lỗi gần như âm thanh như bạn chỉ cần thay đổi một số tùy chọn cấu hình nhưng tôi cảm giác, nó không phải là đơn giản ...

Answer 1

Có một bean trong các ứng dụng Grails gọi là “persistenceInterceptor” có thể được sử dụng cho điều này.

Xem ví dụ này từ các plugin JMS về cách sử dụng nó:

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

Dưới đây là giao diện:

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

Và 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

Bạn cần phải đặt bất kỳ cuộc gọi GORM trong một đóng withTransaction. Một ví dụ được lấy từ một cuộc thảo luận về đa luồng tại https://fbflex.wordpress.com/2010/06/11/writing-batch-import-scripts-with-grails-gsql-and-gpars/

đơn luồng

user = User.findByUsername(photo.username) 

đa luồng

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

Answer 3

withNewSession cũng sẽ hoạt động. Trong trường hợp của tôi, tôi có bản cập nhật ưu tiên thấp, nơi bản cập nhật cuối cùng luôn có thể "giành được". version: false cũng rất quan trọng ở đây để tránh StaleObjectException:

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