src/org/objectweb/cjdbc/controller/scheduler/singledb/SingleDBQueryLevelScheduler.java

説明を見る。

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

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 SingleDBQueryLevelScheduler extends AbstractScheduler
{

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

  private long requestId;

  //
  // Constructor
  //

  public SingleDBQueryLevelScheduler()
  {
    super(RAIDbLevels.SingleDB, ParsingGranularities.NO_PARSING);

    requestId = 0;
  }

  //
  // Request Handling
  //

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

  public final void readCompletedNotify(SelectRequest request)
  {
  }

  public final synchronized void scheduleNonSuspendedWriteRequest(
      AbstractWriteRequest request)
  {
    request.setId(requestId++);
  }

  public final void notifyWriteCompleted(AbstractWriteRequest request)
  {
  }

  //
  // Transaction Management
  //

  protected final void commitTransaction(long transactionId)
  {
  }

  protected final void rollbackTransaction(long transactionId)
  {
  }

  //
  // Debug/Monitoring
  //
  public String getXmlImpl()
  {
    return "<" + DatabasesXmlTags.ELT_SingleDBScheduler + " "
        + DatabasesXmlTags.ATT_level + "=\"" + DatabasesXmlTags.VAL_query
        + "\"/>";
  }

}

---