src/org/objectweb/cjdbc/controller/monitoring/SQLMonitoring.java

説明を見る。

package org.objectweb.cjdbc.controller.monitoring;

import java.util.ArrayList;
import java.util.Collection;
import java.util.Hashtable;
import java.util.Iterator;

import org.objectweb.cjdbc.common.log.Trace;
import org.objectweb.cjdbc.common.sql.AbstractRequest;
import org.objectweb.cjdbc.common.util.Stats;
import org.objectweb.cjdbc.common.xml.DatabasesXmlTags;

public class SQLMonitoring extends Monitoring
{
  private Hashtable    statList;     // SQL query -> Stat
  private ArrayList    ruleList;
  private boolean      defaultRule;

  private static Trace logger = null;

  public SQLMonitoring(String vdbName)
  {
    statList = new Hashtable();
    ruleList = new ArrayList();
    logger = Trace.getLogger("org.objectweb.cjdbc.controller.monitoring."
        + vdbName);
  }

  public final void logRequestTime(AbstractRequest request, long time)
  {
    Stats stat = getStatForRequest(request);
    if (stat == null)
      return;
    stat.incrementCount();
    stat.updateTime(time);
    if (logger.isDebugEnabled())
      logger.debug(time + " " + stat.getName());
  }

  public final void logError(AbstractRequest request)
  {
    Stats stat = getStatForRequest(request);
    if (stat == null)
      return;
    stat.incrementError();
    if (logger.isDebugEnabled())
      logger.debug("ERROR " + stat.getName());
  }

  public final void logCacheHit(AbstractRequest request)
  {
    Stats stat = getStatForRequest(request);
    if (stat == null)
      return;
    stat.incrementCacheHit();
    if (logger.isDebugEnabled())
      logger.debug("Cache hit " + stat.getName());
  }

  public final void resetRequestStat(AbstractRequest request)
  {
    Stats stat = getStatForRequest(request);
    if (stat == null)
      return;
    stat.reset();
  }

  public final Stats getStatForRequest(AbstractRequest request)
  {
    String sql = monitorRequestRule(request);
    if (sql == null)
      return null;

    // Note that the Hashtable is synchronized
    Stats stat = (Stats) statList.get(sql);
    if (stat == null)
    { // No entry for this query, create a new Stats entry
      stat = new Stats(sql);
      statList.put(sql, stat);
    }
    return stat;
  }

  public String[][] getAllStatsInformation()
  {
    Collection values = statList.values();
    String[][] result = new String[values.size()][];
    int i = 0;
    for (Iterator iter = values.iterator(); iter.hasNext(); i++)
    {
      Stats stat = (Stats) iter.next();
      result[i] = stat.toStringTable();
    }
    return result;
  }

  public void dumpAllStatsInformation()
  {
    if (logger.isInfoEnabled())
    {
      for (Iterator iter = statList.values().iterator(); iter.hasNext();)
      {
        Stats stat = (Stats) iter.next();
        logger.info(stat.singleLineDisplay());
      }
    }
  }

  /*
   * Rules Management
   */

  public boolean getDefaultRule()
  {
    return defaultRule;
  }

  public void setDefaultRule(boolean monitoring)
  {
    this.defaultRule = monitoring;
  }

  public void addRule(SQLMonitoringRule rule)
  {
    this.ruleList.add(rule);
  }

  private String monitorRequestRule(AbstractRequest request)
  {
    for (int i = 0; i < ruleList.size(); i++)
    {
      SQLMonitoringRule rule = (SQLMonitoringRule) ruleList.get(i);
      String sql = rule.matches(request);
      if (sql != null)
      { // This rule matches
        if (rule.isMonitoring())
          return sql;
        else
          return null;
      }
    }

    // No rule matched, use the default rule
    if (defaultRule)
    {
      if (request.getSqlSkeleton() == null)
        return request.getSQL();
      else
        return request.getSqlSkeleton();
    }
    else
      return null;
  }

  public ArrayList getRuleList()
  {
    return ruleList;
  }

  public String getXmlImpl()
  {
    String info = "<" + DatabasesXmlTags.ELT_SQLMonitoring + " "
        + DatabasesXmlTags.ATT_defaultMonitoring + "=\"";
    info += getDefaultRule();
    info += "\">";
    for (int i = 0; i < ruleList.size(); i++)
    {
      SQLMonitoringRule rule = (SQLMonitoringRule) ruleList.get(i);
      info += rule.getXml();
    }
    info += "</" + DatabasesXmlTags.ELT_SQLMonitoring + ">";
    return info;
  }

}

---