src/org/objectweb/cjdbc/controller/virtualdatabase/protocol/ExecWriteRequest.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.AbstractWriteRequest;
import org.objectweb.cjdbc.controller.loadbalancer.AllBackendsFailedException;
import org.objectweb.cjdbc.controller.requestmanager.distributed.DistributedRequestManager;

public class ExecWriteRequest extends DistributedRequest
{
  public ExecWriteRequest(AbstractWriteRequest request)
  {
    super(request);
  }

  public Object executeRequest(DistributedRequestManager drm)
      throws SQLException
  {
    try
    {
      drm.scheduleExecWriteRequest((AbstractWriteRequest) request);
      int execWriteRequestResult = 0;
      try
      {
        execWriteRequestResult = drm
            .loadBalanceExecWriteRequest((AbstractWriteRequest) request);
      }
      catch (AllBackendsFailedException e)
      {
        drm.updateAndNotifyExecWriteRequest((AbstractWriteRequest) request,
            false);
        drm.addFailedOnAllBackends(request);
        if (drm.getLogger().isDebugEnabled())
          drm.getLogger().debug(Translate.get("virtualdatabase.distributed.write.all.backends.locally.failed",request.getSQLShortForm(drm.getVirtualDatabase()
                      .getSQLShortFormLength())));
        return e;
      }
      drm.updateAndNotifyExecWriteRequest((AbstractWriteRequest) request, true);
      return new Integer(execWriteRequestResult);
    }
    catch (SQLException e)
    {
      drm.getLogger().warn(Translate.get("virtualdatabase.distributed.write.sqlexception",e.getMessage()), e);
      throw e;
    }
    catch (RuntimeException re)
    {
      drm.getLogger().warn(Translate.get("virtualdatabase.distributed.write.exception",re.getMessage()), re);
      throw new SQLException(re.getMessage());
    }
  }

}

---