src/org/objectweb/cjdbc/controller/loadbalancer/raidb2/RAIDb2ec_WRR.java

説明を見る。

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

import java.sql.SQLException;
import java.util.HashMap;

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.WeightedBalancer;
import org.objectweb.cjdbc.controller.loadbalancer.policies.WaitForCompletionPolicy;
import org.objectweb.cjdbc.controller.loadbalancer.policies.createtable.CreateTablePolicy;
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 RAIDb2ec_WRR extends RAIDb2ec
{
  /*
   * How the code is organized ? 1. Member variables 2. Constructor(s) 3.
   * Request handling 4. Debug/Monitoring
   */

  private HashMap backends;

  /*
   * Constructors
   */

  public RAIDb2ec_WRR(VirtualDatabase vdb,
      WaitForCompletionPolicy waitForCompletionPolicy,
      CreateTablePolicy createTablePolicy,
      ErrorCheckingPolicy errorCheckingPolicy, int nbOfConcurrentReads)
      throws SQLException
  {
    super(vdb, waitForCompletionPolicy, createTablePolicy, errorCheckingPolicy,
        nbOfConcurrentReads);
  }

  /*
   * 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");
  }

  /*
   * Backends management
   */

  public void setWeight(String name, int w) throws SQLException
  {
    throw new SQLException("Weight is not supported with this load balancer");
  }

  /*
   * Debug/Monitoring
   */

  public String getInformation()
  {
    if (backends == null)
      return "RAIDb-2 Error Checking with Weighted Round Robin Request load balancer: "
          + "!!!Warning!!! No backend nodes found\n";
    else
      return "RAIDb-2 Error Checking with Weighted Round Robin Request load balancer balancing over "
          + backends.size() + " nodes\n";
  }

  public String getRaidb2Xml()
  {
    return WeightedBalancer.getRaidbXml(backends,
        DatabasesXmlTags.ELT_RAIDb_2ec_WeightedRoundRobin);
  }
}

---