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

説明を見る。

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

import java.sql.SQLException;

import org.objectweb.cjdbc.common.sql.AbstractWriteRequest;
import org.objectweb.cjdbc.controller.loadbalancer.AllBackendsFailedException;
import org.objectweb.cjdbc.controller.requestmanager.distributed.DistributedRequestManager;
import org.objectweb.cjdbc.controller.virtualdatabase.ControllerResultSet;

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

  public Object executeRequest(DistributedRequestManager drm)
      throws SQLException
  {
    try
    {
      drm.scheduleExecWriteRequest((AbstractWriteRequest) request);
      ControllerResultSet execWriteRequestResult = null;
      try
      {
        execWriteRequestResult = drm
            .loadBalanceExecWriteRequestWithKeys((AbstractWriteRequest) request);
      }
      catch (AllBackendsFailedException e)
      {
        drm.updateAndNotifyExecWriteRequest((AbstractWriteRequest) request,
            false);
        drm.addFailedOnAllBackends(request);
      }
      drm.updateAndNotifyExecWriteRequest((AbstractWriteRequest) request, true);
      return execWriteRequestResult;
    }
    catch (SQLException e)
    {
      return e;
    }
  }

}

---