Open Source Repository

Home /hibernate/hibernate-3.2.4.ga | Repository Home



org/hibernate/action/EntityInsertAction.java
//$Id: EntityInsertAction.java 11403 2007-04-11 14:25:13Z [email protected] $
package org.hibernate.action;

import java.io.Serializable;

import org.hibernate.AssertionFailure;
import org.hibernate.HibernateException;
import org.hibernate.cache.CacheKey;
import org.hibernate.cache.entry.CacheEntry;
import org.hibernate.engine.EntityEntry;
import org.hibernate.engine.SessionFactoryImplementor;
import org.hibernate.engine.SessionImplementor;
import org.hibernate.engine.Versioning;
import org.hibernate.event.PostInsertEvent;
import org.hibernate.event.PostInsertEventListener;
import org.hibernate.event.PreInsertEvent;
import org.hibernate.event.PreInsertEventListener;
import org.hibernate.event.EventSource;
import org.hibernate.persister.entity.EntityPersister;

public final class EntityInsertAction extends EntityAction {

  private Object[] state;
  private Object version;
  private Object cacheEntry;

  public EntityInsertAction(
          Serializable id,
          Object[] state,
          Object instance,
          Object version,
          EntityPersister persister,
          SessionImplementor sessionthrows HibernateException {
    supersession, id, instance, persister );
    this.state = state;
    this.version = version;
  }

  public Object[] getState() {
    return state;
  }

  public void execute() throws HibernateException {
    EntityPersister persister = getPersister();
    SessionImplementor session = getSession();
    Object instance = getInstance();
    Serializable id = getId();

    boolean veto = preInsert();

    // Don't need to lock the cache here, since if someone
    // else inserted the same pk first, the insert would fail

    if !veto ) {
      
      persister.insertid, state, instance, session );
    
      EntityEntry entry = session.getPersistenceContext().getEntryinstance );
      if entry == null ) {
        throw new AssertionFailure"possible nonthreadsafe access to session" );
      }
      
      entry.postInsert();
  
      if persister.hasInsertGeneratedProperties() ) {
        persister.processInsertGeneratedPropertiesid, instance, state, session );
        if persister.isVersionPropertyGenerated() ) {
          version = Versioning.getVersion(state, persister);
        }
        entry.postUpdate(instance, state, version);
      }
      
    }

    final SessionFactoryImplementor factory = getSession().getFactory();

    if isCachePutEnabledpersister, session ) ) {
      
      CacheEntry ce = new CacheEntry(
          state,
          persister, 
          persister.hasUninitializedLazyPropertiesinstance, session.getEntityMode() ),
          version,
          session,
          instance
        );
      
      cacheEntry = persister.getCacheEntryStructure().structure(ce);
      final CacheKey ck = new CacheKey
          id, 
          persister.getIdentifierType()
          persister.getRootEntityName()
          session.getEntityMode()
          session.getFactory() 
        );
//      boolean put = persister.getCache().insert(ck, cacheEntry);
      boolean put = persister.getCache().insertck, cacheEntry, version );
      
      if put && factory.getStatistics().isStatisticsEnabled() ) {
        factory.getStatisticsImplementor()
            .secondLevelCachePutgetPersister().getCache().getRegionName() );
      }
      
    }

    postInsert();

    if factory.getStatistics().isStatisticsEnabled() && !veto ) {
      factory.getStatisticsImplementor()
          .insertEntitygetPersister().getEntityName() );
    }

  }

  private void postInsert() {
    PostInsertEventListener[] postListeners = getSession().getListeners()
        .getPostInsertEventListeners();
    if postListeners.length > ) {
      PostInsertEvent postEvent = new PostInsertEvent(
          getInstance(),
          getId(),
          state,
          getPersister(),
          (EventSourcegetSession()
      );
      for int i = 0; i < postListeners.length; i++ ) {
        postListeners[i].onPostInsert(postEvent);
      }
    }
  }

  private void postCommitInsert() {
    PostInsertEventListener[] postListeners = getSession().getListeners()
        .getPostCommitInsertEventListeners();
    if postListeners.length > ) {
      PostInsertEvent postEvent = new PostInsertEvent(
          getInstance(),
          getId(),
          state,
          getPersister(),
          (EventSourcegetSession() 
      );
      for int i = 0; i < postListeners.length; i++ ) {
        postListeners[i].onPostInsert(postEvent);
      }
    }
  }

  private boolean preInsert() {
    PreInsertEventListener[] preListeners = getSession().getListeners()
        .getPreInsertEventListeners();
    boolean veto = false;
    if (preListeners.length>0) {
      PreInsertEvent preEvent = new PreInsertEventgetInstance(), getId(), state, getPersister(), getSession() );
      for int i = 0; i < preListeners.length; i++ ) {
        veto = preListeners[i].onPreInsert(preEvent|| veto;
      }
    }
    return veto;
  }

  //Make 100% certain that this is called before any subsequent ScheduledUpdate.afterTransactionCompletion()!!
  public void afterTransactionCompletion(boolean successthrows HibernateException {
    EntityPersister persister = getPersister();
    if success && isCachePutEnabledpersister, getSession() ) ) {
      final CacheKey ck = new CacheKey
          getId()
          persister.getIdentifierType()
          persister.getRootEntityName()
          getSession().getEntityMode()
          getSession().getFactory() 
        );
      boolean put = persister.getCache().afterInsert(ck, cacheEntry, version );
      
      if put && getSession().getFactory().getStatistics().isStatisticsEnabled() ) {
        getSession().getFactory().getStatisticsImplementor()
            .secondLevelCachePutgetPersister().getCache().getRegionName() );
      }
    }
    postCommitInsert();
  }

  protected boolean hasPostCommitEventListeners() {
    return getSession().getListeners().getPostCommitInsertEventListeners().length>0;
  }
  
  private boolean isCachePutEnabled(EntityPersister persister, SessionImplementor session) {
    return persister.hasCache() && 
        !persister.isCacheInvalidationRequired() && 
        session.getCacheMode().isPutEnabled();
  }

}