Open Source Repository

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



org/hibernate/transaction/CacheSynchronization.java
//$Id: CacheSynchronization.java 9239 2006-02-08 22:34:34Z steveebersole $
package org.hibernate.transaction;

import javax.transaction.Status;
import javax.transaction.Synchronization;
import javax.transaction.SystemException;
import javax.transaction.Transaction;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.hibernate.TransactionException;
import org.hibernate.jdbc.JDBCContext;
import org.hibernate.util.JTAHelper;

/**
 @author Gavin King
 */
public final class CacheSynchronization implements Synchronization {

  private static final Log log = LogFactory.getLog(CacheSynchronization.class);

  private final TransactionFactory.Context ctx;
  private JDBCContext jdbcContext;
  private final Transaction transaction;
  private final org.hibernate.Transaction hibernateTransaction;

  public CacheSynchronization(
      TransactionFactory.Context ctx, 
      JDBCContext jdbcContext, 
      Transaction transaction, 
      org.hibernate.Transaction tx
  ) {
    this.ctx = ctx;
    this.jdbcContext = jdbcContext;
    this.transaction = transaction;
    this.hibernateTransaction = tx;
  }

  public void beforeCompletion() {
    log.trace("transaction before completion callback");

    boolean flush;
    try {
      flush = !ctx.isFlushModeNever() &&
              ctx.isFlushBeforeCompletionEnabled() && 
              !JTAHelper.isRollbacktransaction.getStatus() )
          //actually, this last test is probably unnecessary, since 
          //beforeCompletion() doesn't get called during rollback
    }
    catch (SystemException se) {
      log.error("could not determine transaction status", se);
      setRollbackOnly();
      throw new TransactionException("could not determine transaction status in beforeCompletion()", se);
    }
    
    try {
      if (flush) {
        log.trace("automatically flushing session");
        ctx.managedFlush();
      }
    }
    catch (RuntimeException re) {
      setRollbackOnly();
      throw re;
    }
    finally {
      jdbcContext.beforeTransactionCompletion(hibernateTransaction);
    }
  }

  private void setRollbackOnly() {
    try {
      transaction.setRollbackOnly();
    }
    catch (SystemException se) {
      log.error("could not set transaction to rollback only", se);
    }
  }

  public void afterCompletion(int status) {
    if log.isTraceEnabled() ) {
      log.trace("transaction after completion callback, status: " + status);
    }
    try {
      jdbcContext.afterTransactionCompletion(status==Status.STATUS_COMMITTED, hibernateTransaction);
    }
    finally {
      if ctx.shouldAutoClose() && !ctx.isClosed() ) {
        log.trace("automatically closing session");
        ctx.managedClose();
      }
    }
  }
  
  public String toString() {
    return CacheSynchronization.class.getName();
  }

}