src/org/objectweb/cjdbc/controller/recoverylog/AbstractRecoveryLog.java

説明を見る。

package org.objectweb.cjdbc.controller.recoverylog;

import java.sql.SQLException;
import java.util.ArrayList;

import org.objectweb.cjdbc.common.i18n.Translate;
import org.objectweb.cjdbc.common.log.Trace;
import org.objectweb.cjdbc.common.sql.AbstractWriteRequest;
import org.objectweb.cjdbc.common.sql.StoredProcedure;
import org.objectweb.cjdbc.common.xml.DatabasesXmlTags;
import org.objectweb.cjdbc.common.xml.XmlComponent;
import org.objectweb.cjdbc.controller.requestmanager.TransactionMarkerMetaData;

public abstract class AbstractRecoveryLog implements XmlComponent
{

  static Trace logger       = Trace
                                .getLogger("org.objectweb.cjdbc.controller.recoverylog");

  private long recoveringNb = 0;

  public abstract void logRequest(AbstractWriteRequest request)
      throws SQLException;

  public abstract void logRequest(StoredProcedure proc, boolean isRead)
      throws SQLException;

  //
  // Transaction management
  //

  public abstract long getLastTransactionId() throws SQLException;

  public abstract void begin(TransactionMarkerMetaData tm) throws SQLException;

  public abstract void commit(TransactionMarkerMetaData tm) throws SQLException;

  public abstract void rollback(TransactionMarkerMetaData tm)
      throws SQLException;

  //
  // Checkpoint Management
  //

  public abstract void storeCheckpoint(String checkpointName)
      throws SQLException;

  public abstract void storeCheckpoint(String checkpointName, long requestId)
      throws SQLException;

  public abstract void removeCheckpoint(String checkpointName)
      throws SQLException;

  public abstract long getCheckpointRequestId(String checkpointName)
      throws SQLException;

  public abstract RecoveryTask recoverNextRequest(long previousRequestId)
      throws SQLException;

  public synchronized void beginRecovery()

  {
    recoveringNb++;
  }

  public synchronized void endRecovery()
  {
    recoveringNb--;
    if (recoveringNb == 0)
    {
      try
      {
        cleanRecoveryLog();
      }
      catch (SQLException e)
      {
        logger.error(Translate.get("recovery.cleaning.failed", e));
      }
    }
  }

  public synchronized boolean isRecovering()
  {
    return recoveringNb > 0;
  }

  public abstract void cleanRecoveryLog() throws SQLException;

  public String getXml()

  {
    StringBuffer info = new StringBuffer();
    info.append("<" + DatabasesXmlTags.ELT_RecoveryLog + ">");
    info.append(getXmlImpl());
    info.append("</" + DatabasesXmlTags.ELT_RecoveryLog + ">");
    return info.toString();
  }

  public abstract String getXmlImpl();

  public abstract ArrayList getCheckpointNames() throws SQLException;

  public abstract void storeBackendInfo(String databaseName,
      String backendName, String checkpoint,int backendState) throws SQLException;

  public abstract BackendRecoveryInfo getBackendInfo(String databaseName,
      String backendName) throws SQLException;

  public abstract String[][] getData();

}

---