src/org/objectweb/cjdbc/controller/loadbalancer/raidb1/RAIDb1ec_RR.java

説明を見る。

package org.objectweb.cjdbc.controller.loadbalancer.raidb1;

import java.sql.SQLException;

import org.objectweb.cjdbc.common.sql.NotImplementedException;
import org.objectweb.cjdbc.common.sql.SelectRequest;
import org.objectweb.cjdbc.common.sql.StoredProcedure;
import org.objectweb.cjdbc.common.xml.DatabasesXmlTags;
import org.objectweb.cjdbc.controller.cache.metadata.MetadataCache;
import org.objectweb.cjdbc.controller.loadbalancer.policies.WaitForCompletionPolicy;
import org.objectweb.cjdbc.controller.loadbalancer.policies.errorchecking.ErrorCheckingPolicy;
import org.objectweb.cjdbc.controller.virtualdatabase.ControllerResultSet;
import org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase;

public class RAIDb1ec_RR extends RAIDb1ec
{
  /*
   * How the code is organized ? 1. Member variables 2. Constructor(s) 3.
   * Request handling 4. Debug/Monitoring
   */

  //  private int index; // index in the backend vector the Round-Robin
  /*
   * Constructors
   */

  public RAIDb1ec_RR(VirtualDatabase vdb,
      WaitForCompletionPolicy waitForCompletionPolicy,
      ErrorCheckingPolicy errorCheckingPolicy, int nbOfConcurrentReads)
      throws SQLException
  {
    super(vdb, waitForCompletionPolicy, errorCheckingPolicy,
        nbOfConcurrentReads);
    // index = -1;
  }

  /*
   * Request Handling
   */

  public ControllerResultSet execReadRequest(SelectRequest request, MetadataCache metadataCache)
      throws SQLException
  {
    throw new NotImplementedException(this.getClass().getName()
        + ":execReadRequest");
  }

  public ControllerResultSet execReadOnlyReadStoredProcedure(StoredProcedure proc, MetadataCache metadataCache)
      throws SQLException
  {
    throw new NotImplementedException(this.getClass().getName()
        + ":execReadStoredProcedure");
  }

  /*
   * Debug/Monitoring
   */

  public String getInformation()
  {
    // We don't lock since we don't need a top accurate value
    int size = vdb.getBackends().size();

    if (size == 0)
      return "RAIDb-1 Error Checking with Round-Robin Request load balancer: !!!Warning!!! No backend nodes found\n";
    else
      return "RAIDb-1 Error Checking with Round-Robin Request load balancer ("
          + size + " backends)\n";
  }

  public String getRaidb1Xml()
  {
    return "<" + DatabasesXmlTags.ELT_RAIDb_1ec_RoundRobin + "/>";
  }

}

---