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

説明を見る。

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

import java.util.Iterator;

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.controller.cache.result.entries.CacheEntry;
import org.objectweb.cjdbc.controller.cache.result.schema.CacheDatabaseTable;

public class ResultCacheTable extends ResultCache
{
  public ResultCacheTable(int maxEntries, int pendingTimeout)
  {
    super(maxEntries, pendingTimeout);
    parsingGranularity = ParsingGranularities.TABLE;
  }

  protected void processAddToCache(CacheEntry qe)
  {
    SelectRequest request = qe.getRequest();
    for (Iterator i = request.getFrom().iterator(); i.hasNext();)
      cdbs.getTable((String) i.next()).addCacheEntry(qe);
  }

  public boolean isUpdateNecessary(UpdateRequest request)
  {
    return true;
  }

  protected void processWriteNotify(AbstractWriteRequest request)
  {
    CacheDatabaseTable cdt = cdbs.getTable(request.getTableName());

    if (cdt != null)
      cdt.invalidateAll();
    else
    {
      logger.warn("Table " + request.getTableName()
          + " not found in cache schema. Flushing whole cache.");
      flushCache();
    }
  }

  public String getName()
  {
    return "table";
  }
}

---