src/org/objectweb/cjdbc/controller/virtualdatabase/protocol/Commit.java

説明を見る。

package org.objectweb.cjdbc.controller.virtualdatabase.protocol;

import java.sql.SQLException;

import org.objectweb.cjdbc.common.i18n.Translate;
import org.objectweb.cjdbc.common.sql.AbstractRequest;
import org.objectweb.cjdbc.common.sql.UnknownRequest;
import org.objectweb.cjdbc.controller.loadbalancer.AllBackendsFailedException;
import org.objectweb.cjdbc.controller.requestmanager.TransactionMarkerMetaData;
import org.objectweb.cjdbc.controller.requestmanager.distributed.DistributedRequestManager;

public class Commit extends CJDBCGroupMessage
{

  private long transactionId;

  public Commit(long transactionId)
  {
    this.transactionId = transactionId;
  }

  public Object commit(DistributedRequestManager drm) throws SQLException
  {
    try
    {
      Long tid = new Long(transactionId);
      TransactionMarkerMetaData tm = drm.getTransactionMarker(tid);

      // Wait for the scheduler to give us the authorization to execute
      drm.getScheduler().commit(tm);

      if (drm.getLogger().isDebugEnabled())
        drm.getLogger().debug(Translate.get("transaction.commit", "" + tid));

      try
      {
        // Send to load balancer
        drm.getLoadBalancer().commit(tm);

        // Notify the cache
        if (drm.getResultCache() != null)
          drm.getResultCache().commit(tm.getTransactionId());

        // Notify the recovery log manager
        if (drm.getRecoveryLog() != null)
          drm.getRecoveryLog().commit(tm);
      }
      catch (SQLException e)
      {
        return e;
      }
      catch (AllBackendsFailedException e)
      {
        AbstractRequest request = new UnknownRequest("commit", false, 0, "\n");
        request.setTransactionId(transactionId);
        drm.addFailedOnAllBackends(request);
        if (drm.getLogger().isDebugEnabled())
          drm.getLogger().debug(Translate.get("virtualdatabase.distributed.commit.all.backends.locally.failed",transactionId));
        return e;
      }
      finally
      {
        // Notify scheduler for completion
        drm.getScheduler().commitCompleted(transactionId);
        drm.completeTransaction(tid);
      }
      return Boolean.TRUE;
    }
    catch (SQLException e)
    {
      drm.getLogger()
          .warn(Translate.get("virtualdatabase.distributed.commit.sqlexception"), e);
      throw e;
    }
    catch (RuntimeException re)
    {
      drm.getLogger().warn(Translate.get("virtualdatabase.distributed.commit.exception"), re);
      throw new SQLException(re.getMessage());
    }
  }

}

---