src/org/objectweb/cjdbc/common/sql/AbstractRequest.java

説明を見る。

package org.objectweb.cjdbc.common.sql;

import java.io.Serializable;
import java.sql.SQLException;

import org.objectweb.cjdbc.common.sql.schema.DatabaseSchema;

public abstract class AbstractRequest implements Serializable
{
  protected transient long id;

  protected String         sqlQuery;

  protected String         sqlSkeleton      = null;

  protected String         login;

  protected int            cacheable;

  protected boolean        isParsed;

  protected int            maxRows;

  private int              fetchSize        = 0;

  //
  // Connection related parameters
  //

  protected boolean        isReadOnly       = false;

  protected boolean        isAutoCommit;

  protected long           transactionId;

  protected int            timeout;

  protected boolean        escapeProcessing = true;

  private String           lineSeparator    = null;

  private boolean          driverProcessed  = true;

  public AbstractRequest(String sqlQuery, boolean escapeProcessing,
      int timeout, String lineSeparator)
  {
    this.sqlQuery = sqlQuery;
    this.escapeProcessing = escapeProcessing;
    this.timeout = timeout;
    this.lineSeparator = lineSeparator;
  }

  public abstract boolean isReadRequest();

  public abstract boolean isWriteRequest();

  public abstract boolean isUnknownRequest();

  public boolean isParsed()
  {
    return isParsed;
  }

  public boolean isReadOnly()
  {
    return isReadOnly;
  }

  public void setIsReadOnly(boolean isReadOnly)
  {
    this.isReadOnly = isReadOnly;
  }

  public int getCacheAbility()
  {
    return cacheable;
  }

  public void setCacheAbility(int cacheAbility)
  {
    this.cacheable = cacheAbility;
  }

  public boolean getEscapeProcessing()
  {
    return escapeProcessing;
  }

  public long getId()
  {
    return id;
  }

  public void setId(long id)
  {
    this.id = id;
  }

  public boolean isAutoCommit()
  {
    return isAutoCommit;
  }

  public void setIsAutoCommit(boolean isAutoCommit)
  {
    this.isAutoCommit = isAutoCommit;
  }

  public String getLogin()
  {
    return login;
  }

  public String getLineSeparator()
  {
    return lineSeparator;
  }

  public void setLineSeparator(String lineSeparator)
  {
    this.lineSeparator = lineSeparator;
  }

  public void setLogin(String login)
  {
    this.login = login;
  }

  public String getSQL()
  {
    return sqlQuery;
  }

  public String getSQLShortForm(int nbOfCharacters)
  {
    if ((nbOfCharacters == 0) || (sqlQuery.length() < nbOfCharacters))
      return sqlQuery;
    else
      return sqlQuery.substring(0, nbOfCharacters) + "...";
  }

  public int getMaxRows()
  {
    return maxRows;
  }

  public void setMaxRows(int rows)
  {
    maxRows = rows;
  }

  public void setSQL(String sql)
  {
    this.sqlQuery = sql;
  }

  public int getTimeout()
  {
    return timeout;
  }

  public void setTimeout(int timeout)
  {
    this.timeout = timeout;
  }

  public long getTransactionId()
  {
    return transactionId;
  }

  public void setTransactionId(long id)
  {
    transactionId = id;
  }

  public boolean equals(Object other)
  {
    if (!(other instanceof AbstractRequest))
      return false;

    AbstractRequest r = (AbstractRequest) other;
    return sqlQuery.equals(r.getSQL())
        && (transactionId == r.getTransactionId());
  }

  public abstract void parse(DatabaseSchema schema, int granularity,
      boolean isCaseSensitive) throws SQLException;

  public abstract void cloneParsing(AbstractRequest request);

  public String trimCarriageReturn()
  {
    if (sqlSkeleton != null)
      return trimCarriageReturn(sqlSkeleton);
    else
      return trimCarriageReturn(sqlQuery);
  }

  private String trimCarriageReturn(String s)
  {
    int lineSeparatorLength = lineSeparator.length();
    int idx = s.indexOf(lineSeparator);
    if (idx == -1)
      return s;
    else
    {
      if (idx == 0) // carriage is the first character
        return trimCarriageReturn(s.substring(lineSeparatorLength));
      else if (idx == (s.length() - lineSeparatorLength)) // is the last
        // character
        return s.substring(0, s.length() - lineSeparatorLength);
      else
        // is somewhere in the string
        return s.substring(0, idx) + " "
            + trimCarriageReturn(s.substring(idx + lineSeparatorLength));
    }
  }

  public String getSqlSkeleton()
  {
    return sqlSkeleton;
  }

  public void setSqlSkeleton(String skel)
  {
    sqlSkeleton = skel;
  }

  public boolean isDriverProcessed()
  {
    return driverProcessed;
  }

  public void setDriverProcessed(boolean driverProcessed)
  {
    this.driverProcessed = driverProcessed;
  }

  public void setFetchSize(int fetchSize)
  {
    this.fetchSize = fetchSize;
  }

  public int getFetchSize()
  {
    return fetchSize;
  }

  public void debug()
  {
    System.out.println("Request: " + sqlQuery);
    System.out.print("Cacheable status: ");
    System.out.println(RequestType.getInformation(cacheable));
  }

}

---