src/org/objectweb/cjdbc/controller/cache/result/AbstractResultCache.java

説明を見る。

package org.objectweb.cjdbc.controller.cache.result;

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.ParsingGranularities;
import org.objectweb.cjdbc.common.sql.SelectRequest;
import org.objectweb.cjdbc.common.sql.UpdateRequest;
import org.objectweb.cjdbc.common.sql.schema.DatabaseSchema;
import org.objectweb.cjdbc.common.xml.XmlComponent;
import org.objectweb.cjdbc.controller.cache.CacheException;
import org.objectweb.cjdbc.controller.cache.CacheStatistics;
import org.objectweb.cjdbc.controller.cache.result.entries.CacheEntry;
import org.objectweb.cjdbc.controller.virtualdatabase.ControllerResultSet;

public abstract class AbstractResultCache implements XmlComponent
{
  //
  // How the code is organized?
  //
  // 1. Member variables
  // 2. Getter/Setter (possibly in alphabetical order)
  // 3. Cache management
  // 4. Transaction management
  // 5. Debug/Monitoring

  protected int          parsingGranularity = ParsingGranularities.NO_PARSING;

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

  /*
   * Getter/Setter methods
   */

  public int getParsingGranularity()
  {
    return parsingGranularity;
  }

  public void setParsingGranularity(int parsingGranularity)
  {
    this.parsingGranularity = parsingGranularity;
  }

  public void setDatabaseSchema(DatabaseSchema dbs)
  {
    if (logger.isInfoEnabled())
      logger.info(Translate.get("cache.schemas.not.supported"));
  }

  public void mergeDatabaseSchema(DatabaseSchema dbs)
  {
    if (logger.isInfoEnabled())
      logger.info(Translate.get("cache.scheduler.doesnt.support.schemas"));
  }

  /*
   * Cache Management
   */

  public abstract void addCachingRule(ResultCacheRule rule);

  public abstract ResultCacheRule getDefaultRule();

  public abstract void setDefaultRule(ResultCacheRule defaultRule);

  public abstract void addToCache(SelectRequest request,
      ControllerResultSet result) throws CacheException;

  public abstract CacheEntry getFromCache(SelectRequest request,
      boolean addToPendingQueries);

  public abstract void removeFromCache(SelectRequest request);

  public abstract void removeFromPendingQueries(SelectRequest request);

  public abstract void writeNotify(AbstractWriteRequest request)
      throws CacheException;

  public abstract boolean isUpdateNecessary(UpdateRequest request)
      throws CacheException;

  public abstract void flushCache();

  //
  // Transaction management
  //

  public abstract void commit(long transactionId) throws CacheException;

  public abstract void rollback(long transactionId) throws CacheException;

  /*
   * Debug/Monitoring
   */

  protected abstract String getXmlImpl();

  public String getXml()

  {
    return getXmlImpl();
  }

  public abstract String[][] getCacheData() throws CacheException;

  public abstract String[][] getCacheStatsData() throws CacheException;

  public abstract CacheStatistics getCacheStatistics();

  public abstract long getCacheSize();

}

---