src/org/objectweb/cjdbc/controller/scheduler/raidb1/RAIDb1OptimisticQueryLevelScheduler.java

説明を見る。

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

import java.sql.SQLException;
import java.util.HashSet;

import org.objectweb.cjdbc.common.sql.AbstractWriteRequest;
import org.objectweb.cjdbc.common.sql.ParsingGranularities;
import org.objectweb.cjdbc.common.sql.SelectRequest;
import org.objectweb.cjdbc.common.xml.DatabasesXmlTags;
import org.objectweb.cjdbc.controller.requestmanager.RAIDbLevels;
import org.objectweb.cjdbc.controller.scheduler.AbstractScheduler;

public class RAIDb1OptimisticQueryLevelScheduler extends AbstractScheduler
{

  //
  // How the code is organized ?
  //
  // 1. Member variables
  // 2. Constructor
  // 3. Request handling
  // 4. Transaction management
  // 5. Debug/Monitoring
  //

  private long    requestId;
  private HashSet completedWrites = new HashSet(); // set of tids

  //
  // Constructor
  //

  public RAIDb1OptimisticQueryLevelScheduler()
  {
    super(RAIDbLevels.RAIDb1, ParsingGranularities.NO_PARSING);
    requestId = 0;
  }

  //
  // Request Handling
  //

  public synchronized void scheduleReadRequest(SelectRequest request)
      throws SQLException
  {
    request.setId(requestId++);
  }

  public final void readCompletedNotify(SelectRequest request)
  {
  }

  public synchronized void scheduleNonSuspendedWriteRequest(
      AbstractWriteRequest request) throws SQLException
  {
    request.setId(requestId++);
    //    if (request.isAutoCommit())
    //      request.setBlocking(true);
    //    else
    request.setBlocking(completedWrites.contains(new Long(request
        .getTransactionId())));
  }

  public final synchronized void notifyWriteCompleted(
      AbstractWriteRequest request)
  {
    if (!request.isAutoCommit())
      completedWrites.add(new Long(request.getTransactionId()));
  }

  //
  // Transaction Management
  //

  protected final void commitTransaction(long transactionId)
  {
    completedWrites.remove(new Long(transactionId));
  }

  protected final void rollbackTransaction(long transactionId)
  {
    completedWrites.remove(new Long(transactionId));
  }

  //
  // Debug/Monitoring
  //

  public String getXmlImpl()
  {
    return "<" + DatabasesXmlTags.ELT_RAIDb1Scheduler + " "
        + DatabasesXmlTags.ATT_level + "=\""
        + DatabasesXmlTags.VAL_optimisticQuery + "\"/>";
  }

}

---