{"id":35670,"date":"2016-07-23T18:06:41","date_gmt":"2016-07-23T12:36:41","guid":{"rendered":"http:\/\/www.tothenew.com\/blog\/?p=35670"},"modified":"2016-07-25T12:05:04","modified_gmt":"2016-07-25T06:35:04","slug":"using-hibernate-events-with-persistenceeventlistener","status":"publish","type":"post","link":"https:\/\/www.tothenew.com\/blog\/using-hibernate-events-with-persistenceeventlistener\/","title":{"rendered":"Using Hibernate Events with PersistenceEventListener"},"content":{"rendered":"

In my last blog<\/a>, we discussed how to hook into GORM API to add some common custom functionality. We will refer the same problem that we discussed in my last blog. Here is the problem statement:<\/p>\n

In my grails plugin I was needed to add some fields that were common to a set of domains. For eg: for some domains we wanted to store fields like createdBy and lastUpdatedBy to keep track of users who created and last updated each record in that domain.<\/p><\/blockquote>\n

We also discussed that a plugin named Audit Logging Plugin<\/code> already exist for the same purpose. The reason behind not using the audit plugin is that the updates made by this plugin to update createdBy and lastUpdatedBy fields is done via a separate query. So how does this affects us? If we have auto versioning enabled in our Grails application<\/a>, then this will cause increment in version of the respective domain object. And if you are doing some operation in a separate thread upon insertion\/updation of the domain objects then you might encounter StaleObjectStateException<\/code>. In our case, on each insert\/update we were sending a message to Rabbit MQ queue which was being consumed by a separate application.<\/p>\n

So how to handle this:<\/strong>
\nSo instead of using the default grails events we used hibernate events to update the stamping fields. Here is the code to do this:<\/p>\n

[code lang=”groovy”]
\npackage com.verecloud.nimbus4.listener<\/p>\n

import groovy.util.logging.Commons
\nimport org.apache.commons.lang.ArrayUtils
\nimport org.grails.datastore.mapping.core.Datastore
\nimport org.grails.datastore.mapping.engine.event.*
\nimport org.hibernate.event.PreInsertEvent as HibernatePreInsertEvent
\nimport org.hibernate.event.PreUpdateEvent as HibernatePreUpdateEvent
\nimport org.hibernate.persister.entity.EntityPersister
\nimport org.springframework.context.ApplicationEvent<\/p>\n

@Commons
\nclass CustomPersistenceEventListenerImpl extends AbstractPersistenceEventListener {<\/p>\n

\/\/Name of Stamp fields
\n String stampCreatedBy = "createdBy"
\n String stampLastUpdatedBy = "lastUpdatedBy"<\/p>\n

CustomPersistenceEventListenerImpl(Datastore datastore) {
\n super(datastore)
\n }<\/p>\n

@Override
\n protected void onPersistenceEvent(AbstractPersistenceEvent event) {
\n if (event.source != this.datastore) {
\n log.trace("Event received for other datastore. Ignoring event")
\n return
\n }
\n \/\/Do stamping
\n \/\/event.nativeEvent will give us the actual HibernateEvent
\n stamp(event.nativeEvent, event.eventType)
\n }<\/p>\n

@Override
\n \/\/This listener will listen PreInsert and PreUpdate events only.
\n boolean supportsEventType(Class<? extends ApplicationEvent> eventType) {
\n return eventType.isAssignableFrom(PreInsertEvent) ||
\n eventType.isAssignableFrom(PreUpdateEvent)
\n }<\/p>\n

private stamp(Serializable event, EventType eventType) {
\n if (EventType.PreInsert == eventType) {
\n HibernatePreInsertEvent preInsertEvent = event as HibernatePreInsertEvent<\/p>\n

stampCreatedBy(preInsertEvent.entity, preInsertEvent.persister, preInsertEvent.state)
\n stampLastUpdatedBy(preInsertEvent.entity, preInsertEvent.persister, preInsertEvent.state)<\/p>\n

} else if (EventType.PreUpdate == eventType) {
\n \/\/On update we need to update lastUpdatedBy field only
\n HibernatePreUpdateEvent preUpdateEvent = event as HibernatePreUpdateEvent
\n stampLastUpdatedBy(preUpdateEvent.entity, preUpdateEvent.persister, preUpdateEvent.state)
\n }
\n }<\/p>\n

private void stampCreatedBy(entity, EntityPersister persister, Object[] state) {
\n if (entity.getProperty(stampCreatedBy) == null) {
\n String currentUser = getActor()<\/p>\n

String[] propertyNames = persister.entityMetamodel.propertyNames<\/p>\n

\/\/ inserts
\n entity.setProperty(stampCreatedBy, currentUser)
\n setValue(state, propertyNames, stampCreatedBy, currentUser, entity)
\n }
\n }<\/p>\n

private void stampLastUpdatedBy(entity, EntityPersister persister, Object[] state) {
\n String currentUser = getActor()
\n String[] propertyNames = persister.entityMetamodel.propertyNames<\/p>\n

\/\/ inserts
\n setValue(state, propertyNames, stampCreatedBy, entity.getProperty(stampCreatedBy), entity)<\/p>\n

\/\/ updates
\n entity.setProperty(stampLastUpdatedBy, currentUser)
\n setValue(state, propertyNames, stampLastUpdatedBy, currentUser, entity)
\n }<\/p>\n

\/\/Using this method we can directly set a value for a property which will update in the same query
\n private void setValue(Object[] state, String[] properties, String propertyToSet, Object value, Object entity) {
\n int index = ArrayUtils.indexOf(properties, propertyToSet)
\n if (index >= 0) {
\n state[index] = value
\n } else {
\n log.error("Field ‘" + propertyToSet + "’ not found on entity ‘" + entity.getClass().getName() + "’.")
\n }
\n }<\/p>\n

private String getActor() {
\n String actor = "Sandeep Poonia" \/\/fetch the user who is currently logged in
\n return actor
\n }
\n}
\n[\/code]<\/p>\n

And to register the listener from the plugin do:<\/p>\n

[code lang=”groovy”]
\ndef doWithApplicationContext = { ctx ->
\n\tregisterAuditLogListener(ctx, application)
\n}<\/p>\n

private void registerAuditLogListener(AbstractApplicationContext applicationContext, GrailsApplication application) {
\n application.mainContext.eventTriggeringInterceptor.datastores.each { key, datastore ->
\n CustomPersistenceEventListenerImpl listener = new CustomPersistenceEventListenerImpl(datastore)
\n applicationContext.addApplicationListener(listener)
\n }
\n}
\n[\/code]<\/p>\n

Another limitation with Audit Logging Plugin<\/code> is that it works on PreUpdate and not on PostUpdate which may be required in some cases.<\/p>\n","protected":false},"excerpt":{"rendered":"

In my last blog, we discussed how to hook into GORM API to add some common custom functionality. We will refer the same problem that we discussed in my last blog. Here is the problem statement: In my grails plugin I was needed to add some fields that were common to a set of domains. […]<\/p>\n","protected":false},"author":182,"featured_media":0,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"iawp_total_views":11},"categories":[7,1],"tags":[1711,3481,29,4840,3480],"aioseo_notices":[],"_links":{"self":[{"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/posts\/35670"}],"collection":[{"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/users\/182"}],"replies":[{"embeddable":true,"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/comments?post=35670"}],"version-history":[{"count":0,"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/posts\/35670\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/media?parent=35670"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/categories?post=35670"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/tags?post=35670"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}