クラス org.objectweb.cjdbc.common.sql.SelectRequest

org.objectweb.cjdbc.common.sql.SelectRequestに対する継承グラフ

[凡例]org.objectweb.cjdbc.common.sql.SelectRequestのコラボレーション図

[凡例]すべてのメンバ一覧

---

説明

A SelectRequest is an SQL request of the following syntax:

  SELECT [ALL|DISTINCT] select-item[,select-item]* 
  FROM table-specification[,table-specification]* 
  [WHERE search-condition] 
  [GROUP BY grouping-column[,grouping-column]] 
  [HAVING search-condition] 
  [ORDER BY sort-specification[,sort-specification]] 
  [LIMIT ignored]
 

Note that table-specification in the FROM clause can be a sub-select. Everything after the end of the WHERE clause is ignored.

作者:

Emmanuel Cecchet

Julie Marguerite

Mathieu Peltier

Sara Bouchenak

バージョン:

1.0

SelectRequest.java の 63 行で定義されています。

Public メソッド
	SelectRequest (String sqlQuery, boolean escapeProcessing, int timeout, String lineSeparator, DatabaseSchema schema, int granularity, boolean isCaseSensitive) throws SQLException
	SelectRequest (String sqlQuery, boolean escapeProcessing, int timeout, String lineSeparator)
void	parse (DatabaseSchema schema, int granularity, boolean isCaseSensitive) throws SQLException
void	cloneParsing (AbstractRequest request)
ArrayList	getSelect ()
ArrayList	getFrom ()
ArrayList	getAliasedFrom ()
ArrayList	getWhere ()
ArrayList	getOrderBy ()
Hashtable	getWhereValues ()
boolean	isReadRequest ()
boolean	isWriteRequest ()
boolean	isUnknownRequest ()
String	getPkValue ()
void	setPkValue (String pkValue)
String	getCursorName ()
void	setCursorName (String cursorName)
void	debug ()
Public 変数
transient int	funcType = 0
Static Public 変数
final int	NO_FUNCTION = 0
final int	MAX_FUNCTION = 1
final int	MIN_FUNCTION = 2
final int	AVERAGE_FUNCTION = 3
final int	COUNT_FUNCTION = 4
final int	SUM_FUNCTION = 5
Private メソッド
ArrayList	getFromTables (String fromClause, DatabaseSchema schema, boolean isCaseSensitive) throws SQLException
ArrayList	getSelectedColumns (String selectClause, ArrayList aliasedFrom, boolean isCaseSensitive)
boolean	isSqlFunction (String str)
ArrayList	getWhereColumns (String whereClause, ArrayList aliasedFrom, boolean setUniqueCacheable, boolean isCaseSensitive)
Private 変数
transient ArrayList	select
transient ArrayList	from
transient ArrayList	aliasFrom
transient ArrayList	where
transient ArrayList	order
transient String	pkValue
transient Hashtable	whereValues
String	cursorName = null

---

コンストラクタとデストラクタ

org.objectweb.cjdbc.common.sql.SelectRequest.SelectRequest (  String  sqlQuery, boolean  escapeProcessing, int  timeout, String  lineSeparator, DatabaseSchema  schema, int  granularity, boolean  isCaseSensitive )  throws SQLException

Creates a new SelectRequest instance. The caller must give an SQL request, without any leading or trailing spaces and beginning with 'select ' (it will not be checked). The SQL request is parsed and selected tables and columns are retrieved using the given DatabaseSchema. If the syntax is incorrect an exception is thrown. 引数: sqlQuery  the SQL query escapeProcessing  should the driver to escape processing before sending to the database ? timeout  an int value lineSeparator  the line separator used in the query schema  a DatabaseSchema value granularity  parsing granularity as defined in ParsingGranularities isCaseSensitive  true if parsing is case sensitive 例外: SQLException  if an error occurs SelectRequest.java の 133 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.SelectRequest.parse(). 参照元 org.objectweb.cjdbc.common.sql.SelectRequest.getFromTables(). { this(sqlQuery, escapeProcessing, timeout, lineSeparator); parse(schema, granularity, isCaseSensitive); }

org.objectweb.cjdbc.common.sql.SelectRequest.SelectRequest (  String  sqlQuery, boolean  escapeProcessing, int  timeout, String  lineSeparator )

Creates a new SelectRequest instance. The caller must give an SQL request, without any leading or trailing spaces and beginning with the 'select' keyword (it will not be checked). The request is not parsed but it can be done later by a call to parse(DatabaseSchema, int, boolean). 引数: sqlQuery  the SQL query escapeProcessing  should the driver to escape processing before sending to the database ? timeout  an int value lineSeparator  the line separator used in the query 参照: parse SelectRequest.java の 156 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.SelectRequest.pkValue. { super(sqlQuery, escapeProcessing, timeout, lineSeparator); cacheable = RequestType.CACHEABLE; isParsed = false; pkValue = null; }

---

メソッド

void org.objectweb.cjdbc.common.sql.SelectRequest.cloneParsing (  AbstractRequest  request  )  [virtual]

参照: AbstractRequest.cloneParsing(AbstractRequest) org.objectweb.cjdbc.common.sql.AbstractRequestを実装しています. SelectRequest.java の 344 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.SelectRequest.from, org.objectweb.cjdbc.common.sql.AbstractRequest.getCacheAbility(), org.objectweb.cjdbc.common.sql.SelectRequest.getFrom(), org.objectweb.cjdbc.common.sql.SelectRequest.getPkValue(), org.objectweb.cjdbc.common.sql.SelectRequest.getSelect(), org.objectweb.cjdbc.common.sql.SelectRequest.getWhere(), org.objectweb.cjdbc.common.sql.AbstractRequest.isParsed, org.objectweb.cjdbc.common.sql.SelectRequest.pkValue, org.objectweb.cjdbc.common.sql.SelectRequest.select, と org.objectweb.cjdbc.common.sql.SelectRequest.where. { if (!request.isParsed()) return; SelectRequest selectRequest = (SelectRequest) request; select = selectRequest.getSelect(); from = selectRequest.getFrom(); where = selectRequest.getWhere(); cacheable = selectRequest.getCacheAbility(); pkValue = selectRequest.getPkValue(); isParsed = true; }

void org.objectweb.cjdbc.common.sql.SelectRequest.debug (   )

Displays some debugging information about this request. org.objectweb.cjdbc.common.sql.AbstractRequestを再定義しています。 SelectRequest.java の 1069 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.SelectRequest.from, org.objectweb.cjdbc.common.sql.SelectRequest.pkValue, org.objectweb.cjdbc.common.sql.SelectRequest.select, と org.objectweb.cjdbc.common.sql.SelectRequest.where. { super.debug(); if (select != null) { System.out.println("Selected columns:"); for (int i = 0; i < select.size(); i++) System.out .println(" " + ((TableColumn) select.get(i)).getColumnName()); } else System.out.println("No information on selected columns"); if (select != null) { System.out.println(""); System.out.println("From tables:"); for (int i = 0; i < from.size(); i++) System.out.println(" " + from.get(i)); } else System.out.println("No information on from tables"); System.out.println(""); System.out.println("Where columns:"); if (where == null) System.out.println(" No Where clause"); else for (int i = 0; i < where.size(); i++) System.out.print(" " + ((TableColumn) where.get(i)).getColumnName()); System.out.println(""); System.out.println("PK value: " + pkValue); }

ArrayList org.objectweb.cjdbc.common.sql.SelectRequest.getAliasedFrom (   )

Returns an ArrayList of AliasedDatabaseTable objects representing the table names found in the FROM clause of this request. 戻り値: an ArrayList of AliasedDatabaseTable SelectRequest.java の 962 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.SelectRequest.aliasFrom. { return aliasFrom; }

String org.objectweb.cjdbc.common.sql.SelectRequest.getCursorName (   )

Returns the cursorName value. 戻り値: Returns the cursorName. SelectRequest.java の 1051 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.SelectRequest.cursorName. 参照元 org.objectweb.cjdbc.controller.virtualdatabase.ControllerResultSet.ControllerResultSet(). { return cursorName; }

ArrayList org.objectweb.cjdbc.common.sql.SelectRequest.getFrom (   )

Returns an ArrayList of String objects representing the table names found in the FROM clause of this request. 戻り値: an ArrayList of String SelectRequest.java の 950 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.SelectRequest.from. 参照元 org.objectweb.cjdbc.common.sql.SelectRequest.cloneParsing(), org.objectweb.cjdbc.common.sql.SelectRequest.getFromTables(), org.objectweb.cjdbc.common.sql.CreateRequest.parse(), org.objectweb.cjdbc.controller.cache.result.ResultCacheTable.processAddToCache(), org.objectweb.cjdbc.controller.cache.result.ResultCacheColumnUnique.processAddToCache(), と org.objectweb.cjdbc.controller.cache.result.ResultCacheColumn.processAddToCache(). { return from; }

ArrayList org.objectweb.cjdbc.common.sql.SelectRequest.getFromTables (  String  fromClause, DatabaseSchema  schema, boolean  isCaseSensitive )  throws SQLException [private]

Extracts the tables from the given FROM clause and retrieves their alias if any. 引数: fromClause  the FROM clause of the request (without the FROM keyword) schema  the DatabaseSchema this request refers to isCaseSensitive  true if table name parsing is case sensitive 戻り値: an ArrayList of AliasedDatabaseTable objects 例外: SQLException  if an error occurs SelectRequest.java の 369 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.SelectRequest.getFrom(), org.objectweb.cjdbc.common.sql.AbstractRequest.getLineSeparator(), org.objectweb.cjdbc.common.sql.schema.DatabaseTable.getName(), org.objectweb.cjdbc.common.sql.SelectRequest.parse(), と org.objectweb.cjdbc.common.sql.SelectRequest.SelectRequest(). 参照元 org.objectweb.cjdbc.common.sql.SelectRequest.parse(). { ArrayList result = new ArrayList(); // Search for subselects in from clause try { int subSelect = fromClause.toLowerCase().indexOf("select"); while (subSelect != -1) { int subFromIndex = fromClause.indexOf("from", subSelect + 1) + 5; int bracket = subFromIndex; int parenthesis = 1; do { char c = fromClause.charAt(bracket); switch (c) { case '(' : parenthesis++; break; case ')' : parenthesis--; break; default : break; } bracket++; } while ((parenthesis > 0) && (bracket < fromClause.length())); SelectRequest subQuery = new SelectRequest(fromClause.substring( subSelect, bracket - 1).trim(), this.escapeProcessing, 0, getLineSeparator()); subQuery.parse(schema, ParsingGranularities.TABLE, isCaseSensitive); for (Iterator iter = subQuery.getFrom().iterator(); iter.hasNext();) { result.add(new AliasedDatabaseTable(schema.getTable((String) iter .next(), isCaseSensitive), null)); } if (subFromIndex + bracket > fromClause.length()) { if (subSelect > 0) { fromClause = fromClause.substring(0, subSelect - 1).trim(); if ((fromClause.length() > 0) && (fromClause.charAt(fromClause.length() - 1) == '(')) fromClause = fromClause.substring(0, fromClause.length() - 1) .trim(); } else fromClause = ""; break; // Nothing more to process } fromClause = (subSelect > 0 ? fromClause.substring(0, subSelect - 1) .trim() : "") + fromClause.substring(subFromIndex + bracket).trim(); subSelect = fromClause.toLowerCase().indexOf("select"); } } catch (RuntimeException e) { // Parsing failed, select everything return schema.getTables(); } // Use a brutal force technique by matching schema table names in the from // clause ArrayList tables = schema.getTables(); int size = tables.size(); for (int i = 0; i < size; i++) { // Check if this table is found in the FROM string DatabaseTable t = (DatabaseTable) tables.get(i); String tableName = t.getName(); if (!isCaseSensitive) tableName = tableName.toLowerCase(); // Check that we have a full match and not a partial match int index; int afterTableNameIndex = 0; boolean left; boolean right; do { index = fromClause.indexOf(tableName, afterTableNameIndex); if (index == -1) break; afterTableNameIndex = index + tableName.length(); left = (index == 0) || ((index > 0) && ((fromClause.charAt(index - 1) == ' ') || (fromClause.charAt(index - 1) == '(') || (fromClause.charAt(index - 1) == ',') || (fromClause .charAt(index - 1) == getLineSeparator().charAt( getLineSeparator().length() - 1)))); right = (afterTableNameIndex >= fromClause.length()) || ((afterTableNameIndex < fromClause.length()) && ((fromClause .charAt(afterTableNameIndex) == ' ') || (fromClause.charAt(afterTableNameIndex) == ',') || (fromClause.charAt(afterTableNameIndex) == ')') || (fromClause .charAt(afterTableNameIndex) == getLineSeparator().charAt(0)))); } while (!left || !right); if (index != -1) { // Check if the table has an alias // Example: SELECT x.price FROM item x String alias = null; index += tableName.length(); if ((index < fromClause.length()) && (fromClause.charAt(index) == ' ')) { char c; // Skip spaces before alias do { c = fromClause.charAt(index); index++; } while ((index < fromClause.length()) && (c != ' ') && (c != getLineSeparator().charAt(0))); if (index < fromClause.length()) { int start = index; do { c = fromClause.charAt(index); index++; } while ((index < fromClause.length()) && (c != ' ') && (c != ',') && (c != getLineSeparator().charAt(0))); alias = fromClause.substring(start, index - 1); } } result.add(new AliasedDatabaseTable(t, alias)); } } return result; }

ArrayList org.objectweb.cjdbc.common.sql.SelectRequest.getOrderBy (   )

Returns an ArrayList of OrderBy objects representing the columns involved in the ORDER BY clause of this request. 戻り値: an ArrayList of OrderBy SelectRequest.java の 986 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.SelectRequest.order. { return order; }

String org.objectweb.cjdbc.common.sql.SelectRequest.getPkValue (   )

戻り値: Returns the pkValue. SelectRequest.java の 1033 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.SelectRequest.pkValue. 参照元 org.objectweb.cjdbc.common.sql.SelectRequest.cloneParsing(), と org.objectweb.cjdbc.controller.cache.result.ResultCacheColumnUnique.processAddToCache(). { return pkValue; }

ArrayList org.objectweb.cjdbc.common.sql.SelectRequest.getSelect (   )

Returns an ArrayList of DatabaseColumn objects representing the columns selected in the SELECT clause of this request. 戻り値: an ArrayList of TableColumn SelectRequest.java の 938 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.SelectRequest.select. 参照元 org.objectweb.cjdbc.common.sql.SelectRequest.cloneParsing(), org.objectweb.cjdbc.common.sql.CreateRequest.parse(), org.objectweb.cjdbc.controller.cache.result.ResultCacheColumnUnique.processAddToCache(), と org.objectweb.cjdbc.controller.cache.result.ResultCacheColumn.processAddToCache(). { return select; }

ArrayList org.objectweb.cjdbc.common.sql.SelectRequest.getSelectedColumns (  String  selectClause, ArrayList  aliasedFrom, boolean  isCaseSensitive )  [private]

Gets all the columns selected in the given SELECT clause. The selected columns or tables must be found in the given ArrayList of AliasedDatabaseTable representing the FROM clause of the same request. 引数: selectClause  SELECT clause of the request (without the SELECT keyword) aliasedFrom  an ArrayList of AliasedDatabaseTable isCaseSensitive  true if column name parsing is case sensitive 戻り値: an ArrayList of TableColumn SelectRequest.java の 524 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.schema.AliasedDatabaseTable.getAlias(), org.objectweb.cjdbc.common.sql.schema.DatabaseTable.getColumn(), org.objectweb.cjdbc.common.sql.schema.DatabaseTable.getColumns(), org.objectweb.cjdbc.common.sql.schema.DatabaseColumn.getName(), org.objectweb.cjdbc.common.sql.schema.DatabaseTable.getName(), org.objectweb.cjdbc.common.sql.schema.AliasedDatabaseTable.getTable(), と org.objectweb.cjdbc.common.sql.SelectRequest.isSqlFunction(). 参照元 org.objectweb.cjdbc.common.sql.SelectRequest.parse(). { StringTokenizer selectTokens = new StringTokenizer(selectClause, ","); ArrayList result = new ArrayList(); StringBuffer unresolvedTokens = null; while (selectTokens.hasMoreTokens()) { String token = selectTokens.nextToken().trim(); // Check if it is a function, e.g., MAX, COUNT, etc. if (isSqlFunction(token)) { // token has the following form: // max(...) // or // count(...) int leftPar = token.indexOf("("); token = token.substring(leftPar + 1, token.length() - 1); } // Is it using an aliased table name (x.price for example) ? String alias = null; int aliasIdx = token.indexOf("."); if (aliasIdx != -1) { alias = token.substring(0, aliasIdx); token = token.substring(aliasIdx + 1); // Get // rid // of // the // '.' } // Discard any AS clause int as = token.indexOf(" as "); if (as != -1) token = token.substring(0, as).trim(); // Now token only contains the column name // Deal with SELECT * or x.* if (token.indexOf("*") != -1) { if (alias == null) { // We have to take all colums of all tables of the FROM // clause int size = aliasedFrom.size(); for (int i = 0; i < size; i++) { DatabaseTable t = ((AliasedDatabaseTable) aliasedFrom.get(i)) .getTable(); ArrayList cols = t.getColumns(); int colSize = cols.size(); for (int j = 0; j < colSize; j++) result.add(new TableColumn(t.getName(), ((DatabaseColumn) cols .get(j)).getName())); } return result; } else { // Add all colums of the table corresponding to the alias int size = aliasedFrom.size(); for (int i = 0; i < size; i++) { AliasedDatabaseTable adt = (AliasedDatabaseTable) aliasedFrom .get(i); // The alias could be the full name of the table // instead of a "real" alias if (alias.equals(adt.getAlias()) || alias.equals(adt.getTable().getName())) { DatabaseTable t = adt.getTable(); ArrayList cols = t.getColumns(); int colSize = cols.size(); for (int j = 0; j < colSize; j++) result.add(new TableColumn(t.getName(), ((DatabaseColumn) cols .get(i)).getName())); break; } } } continue; } // First, we suppose that it's a simple column name. // If it fails, we will consider it later. DatabaseColumn col = null; if (alias == null) { int size = aliasedFrom.size(); for (int i = 0; i < size; i++) { DatabaseTable t = ((AliasedDatabaseTable) aliasedFrom.get(i)) .getTable(); col = t.getColumn(token, isCaseSensitive); if (col != null) { result.add(new TableColumn(t.getName(), col.getName())); break; } } } else // same with an alias { int size = aliasedFrom.size(); for (int i = 0; i < size; i++) { AliasedDatabaseTable t = (AliasedDatabaseTable) aliasedFrom.get(i); // It can be either an alias or the fully qualified name of // the table if (alias.equals(t.getAlias()) || alias.equals(t.getTable().getName())) { col = t.getTable().getColumn(token, isCaseSensitive); if (col != null) { result .add(new TableColumn(t.getTable().getName(), col.getName())); break; } } } } if (col == null) { if (unresolvedTokens == null) unresolvedTokens = new StringBuffer(); unresolvedTokens.append(token); unresolvedTokens.append(" "); } } if (unresolvedTokens != null) { // Those tokens may be complex expressions, so instead of parsing // them, we use a brutal force technique and we try to directly // identify every column name of each table. DatabaseColumn col; String unresolvedTokensString = unresolvedTokens.toString(); if (!isCaseSensitive) unresolvedTokensString = unresolvedTokensString.toLowerCase(); int asize = aliasedFrom.size(); for (int i = 0; i < asize; i++) { DatabaseTable t = ((AliasedDatabaseTable) aliasedFrom.get(i)) .getTable(); ArrayList cols = t.getColumns(); int size = cols.size(); for (int j = 0; j < size; j++) { col = (DatabaseColumn) cols.get(j); String columnName = col.getName(); if (!isCaseSensitive) columnName = columnName.toLowerCase(); // if pattern found and column not already in result, it's a // dependency ! int matchIdx = unresolvedTokensString.indexOf(columnName); if (matchIdx != -1) if ((matchIdx == 0) || (unresolvedTokens.charAt(matchIdx - 1) == ' ') || (unresolvedTokens.charAt(matchIdx - 1) == '(') || (unresolvedTokens.charAt(matchIdx - 1) == '.')) { TableColumn c = new TableColumn(t.getName(), col.getName()); if (!result.contains(c)) result.add(c); } } } } return result; }

ArrayList org.objectweb.cjdbc.common.sql.SelectRequest.getWhere (   )

Returns an ArrayList of TableColumn objects representing the columns involved in the WHERE clause of this request. 戻り値: an ArrayList of TableColumn SelectRequest.java の 974 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.SelectRequest.where. 参照元 org.objectweb.cjdbc.common.sql.SelectRequest.cloneParsing(), org.objectweb.cjdbc.controller.cache.result.ResultCacheColumnUnique.processAddToCache(), と org.objectweb.cjdbc.controller.cache.result.ResultCacheColumn.processAddToCache(). { return where; }

ArrayList org.objectweb.cjdbc.common.sql.SelectRequest.getWhereColumns (  String  whereClause, ArrayList  aliasedFrom, boolean  setUniqueCacheable, boolean  isCaseSensitive )  [private]

Gets all the columns involved in the given WHERE clause. The selected columns or tables must be found in the given ArrayList of AliasedDatabaseTable representing the FROM clause of the same request. 引数: whereClause  WHERE clause of the request (without the WHERE keyword) aliasedFrom  an ArrayList of AliasedDatabaseTable setUniqueCacheable  true if we have to check is this select is UNIQUE or not isCaseSensitive  true if column name parsing is case sensitive 戻り値: an ArrayList of TableColumn SelectRequest.java の 769 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.schema.DatabaseTable.getColumns(), org.objectweb.cjdbc.common.sql.schema.DatabaseTable.getName(), org.objectweb.cjdbc.common.sql.schema.DatabaseColumn.getName(), org.objectweb.cjdbc.common.sql.schema.DatabaseColumn.isUnique, と org.objectweb.cjdbc.common.sql.SelectRequest.pkValue. 参照元 org.objectweb.cjdbc.common.sql.SelectRequest.parse(). { ArrayList result = new ArrayList(); // TableColumn // objects if (!isCaseSensitive) whereClause = whereClause.toLowerCase(); // Instead of parsing the clause, we use a brutal force technique // and we try to directly identify every column name of each table. DatabaseColumn col; for (int i = 0; i < aliasedFrom.size(); i++) { DatabaseTable t = ((AliasedDatabaseTable) aliasedFrom.get(i)).getTable(); ArrayList cols = t.getColumns(); int size = cols.size(); for (int j = 0; j < size; j++) { col = (DatabaseColumn) cols.get(j); // if pattern found and column not already in result, it's a // dependency ! String columnName = col.getName(); if (!isCaseSensitive) columnName = columnName.toLowerCase(); int matchIdx = whereClause.indexOf(columnName); while (matchIdx > 0) { // Try to check that we got the full pattern and not a // sub-pattern char beforePattern = whereClause.charAt(matchIdx - 1); if (((beforePattern >= 'a') && (beforePattern <= 'z')) || ((beforePattern >= 'A') && (beforePattern <= 'Z')) || (beforePattern == '_')) matchIdx = whereClause.indexOf(columnName, matchIdx + 1); else { char afterPattern; try { afterPattern = whereClause.charAt(matchIdx + columnName.length()); if (((afterPattern >= 'a') && (afterPattern <= 'z')) || ((afterPattern >= 'A') && (afterPattern <= 'Z')) || (afterPattern == '_')) { // This is a subset of the full name of another // column, //let's jump to next mathing pattern matchIdx = whereClause.indexOf(columnName, matchIdx + 1); } else break; } catch (IndexOutOfBoundsException e) { break; } } } if (matchIdx == -1) continue; result.add(new TableColumn(t.getName(), col.getName())); if (setUniqueCacheable) { // Check if this request selects a // unique row if (!col.isUnique()) { // Column has no unicity constraint, // we can select multiple rows // with same value, give up. setUniqueCacheable = false; continue; } // Check if the column is in the left side of an equality // with a // constant. // e.g.: 'column_name1 = 10' is ok // but '5=table_name.column_name2' will fail int lookingForEqual = matchIdx + columnName.length(); boolean searchReverse = false; try { while (whereClause.charAt(lookingForEqual) == ' ') lookingForEqual++; } catch (Exception e) { searchReverse = true; } String rightSide; if (searchReverse || (whereClause.charAt(lookingForEqual) != '=')) { try { // try reverse StringBuffer sb = new StringBuffer(whereClause.substring(0, lookingForEqual)); String reverse = sb.reverse().toString(); reverse = reverse.substring(reverse.indexOf('=') + 1); sb = new StringBuffer(reverse); // Get back the original values sb = sb.reverse(); rightSide = sb.toString(); } catch (Exception e) { // No equality, it is not unique cacheable setUniqueCacheable = false; continue; } } else { // We found it let's move to next char int nextSpace = lookingForEqual + 1; try { while (whereClause.charAt(nextSpace) == ' ') nextSpace++; } catch (Exception e1) { // This should not happen // unless we get a query like: // 'select ... where id= ' setUniqueCacheable = false; continue; } rightSide = whereClause.substring(nextSpace); } char firstChar = rightSide.charAt(0); if ((firstChar == '\'') || (firstChar == '"') || ((firstChar >= '0') && (firstChar <= '9')) || (firstChar == '?')) { // Ok, the value is either // '...' or "..." or starts // with a // number which is enough for us to consider that it is // an // acceptable constant. pkValue = rightSide; } else { setUniqueCacheable = false; continue; } } } } if (setUniqueCacheable && !result.isEmpty()) cacheable = RequestType.UNIQUE_CACHEABLE; return result; }

Hashtable org.objectweb.cjdbc.common.sql.SelectRequest.getWhereValues (   )

Returns an Hashtable of String keys representing unique column names and String values associated with the columns involved in this request. 戻り値: an Hashtable value SelectRequest.java の 998 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.SelectRequest.whereValues. 参照元 org.objectweb.cjdbc.controller.cache.result.schema.CacheDatabaseColumn.invalidateAllUniqueWithValuesAndAllNonUnique(). { return whereValues; }

boolean org.objectweb.cjdbc.common.sql.SelectRequest.isReadRequest (   )  [virtual]

戻り値: true 参照: org.objectweb.cjdbc.common.sql.AbstractRequest.isReadRequest() org.objectweb.cjdbc.common.sql.AbstractRequestを実装しています. SelectRequest.java の 1007 行で定義されています。 { return true; }

boolean org.objectweb.cjdbc.common.sql.SelectRequest.isSqlFunction (  String  str  )  [private]

Checks if the string parameter represents an SQL function, e. g., MAX, COUNT, SUM, etc. 引数: str  A lower-case string that may represent an SQL function 戻り値: boolean true if it is an SQL function and false otherwise. SelectRequest.java の 713 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.SelectRequest.funcType. 参照元 org.objectweb.cjdbc.common.sql.SelectRequest.getSelectedColumns(). { if (str != null) { if (str.startsWith("max(") && str.endsWith(")")) { funcType = SelectRequest.MAX_FUNCTION; return true; } else if (str.startsWith("count(") && str.endsWith(")")) { funcType = SelectRequest.COUNT_FUNCTION; return true; } else if (str.startsWith("avg(") && str.endsWith(")")) { funcType = SelectRequest.AVERAGE_FUNCTION; return true; } else if (str.startsWith("min(") && str.endsWith(")")) { funcType = SelectRequest.MIN_FUNCTION; return true; } else if (str.startsWith("sum(") && str.endsWith(")")) { funcType = SelectRequest.SUM_FUNCTION; return true; } else { funcType = SelectRequest.NO_FUNCTION; return false; } } else return false; }

boolean org.objectweb.cjdbc.common.sql.SelectRequest.isUnknownRequest (   )  [virtual]

戻り値: false 参照: org.objectweb.cjdbc.common.sql.AbstractRequest.isUnknownRequest() org.objectweb.cjdbc.common.sql.AbstractRequestを実装しています. SelectRequest.java の 1025 行で定義されています。 { return false; }

boolean org.objectweb.cjdbc.common.sql.SelectRequest.isWriteRequest (   )  [virtual]

戻り値: false 参照: org.objectweb.cjdbc.common.sql.AbstractRequest.isWriteRequest() org.objectweb.cjdbc.common.sql.AbstractRequestを実装しています. SelectRequest.java の 1016 行で定義されています。 { return false; }

void org.objectweb.cjdbc.common.sql.SelectRequest.parse (  DatabaseSchema  schema, int  granularity, boolean  isCaseSensitive )  throws SQLException [virtual]

The result of the parsing is accessible through the getSelect(), getFrom()and getWhere()functions. 参照: org.objectweb.cjdbc.common.sql.AbstractRequest.parse(org.objectweb.cjdbc.common.sql.schema.DatabaseSchema, int, boolean) org.objectweb.cjdbc.common.sql.AbstractRequestを実装しています. SelectRequest.java の 173 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.SelectRequest.aliasFrom, org.objectweb.cjdbc.common.sql.SelectRequest.from, org.objectweb.cjdbc.common.sql.SelectRequest.getFromTables(), org.objectweb.cjdbc.common.sql.SelectRequest.getSelectedColumns(), org.objectweb.cjdbc.common.sql.SelectRequest.getWhereColumns(), org.objectweb.cjdbc.common.sql.SelectRequest.select, と org.objectweb.cjdbc.common.sql.SelectRequest.where. 参照元 org.objectweb.cjdbc.common.sql.SelectRequest.getFromTables(), org.objectweb.cjdbc.common.sql.CreateRequest.parse(), と org.objectweb.cjdbc.common.sql.SelectRequest.SelectRequest(). { if (granularity == ParsingGranularities.NO_PARSING) { cacheable = RequestType.CACHEABLE; isParsed = true; return; } // Sanity check if (schema == null) throw new SQLException( "Unable to parse request with an undefined database schema"); String originalSQL = this.trimCarriageReturn(); String sql = originalSQL.toLowerCase(); if (!isCaseSensitive) originalSQL = sql; // Strip 'select' sql = sql.substring(6).trim(); // Look for DISTINCT if (sql.startsWith("distinct")) sql = sql.substring(8).trim(); // Strip 'distinct ' // Look for the begining of the FROM clause int fromIndex = sql.indexOf("from "); if (fromIndex == -1) throw new SQLException( "Unable to find the FROM keyword in this SELECT statement: '" + sql + "'"); // Keep SELECT clause for later, we first have to check the // tables involved in the FROM clause int fshift = originalSQL.length() - sql.length(); String selectClause = (isCaseSensitive) ? originalSQL.substring(fshift, fshift + fromIndex) : sql.substring(0, fromIndex); // Get rid of FROM sql = sql.substring(fromIndex + 5).trim(); // Now find the boundaries of the FROM and WHERE clauses int whereIndex = 0; int parenthesis = 0; int lastParenthesisIdx = 0; boolean foundWhere = false; do { switch (sql.charAt(whereIndex)) { case '(' : parenthesis++; break; case ')' : parenthesis--; lastParenthesisIdx = whereIndex; break; case 'w' : if (parenthesis == 0) try { foundWhere = (sql.charAt(whereIndex + 1) == 'h') && (sql.charAt(whereIndex + 2) == 'e') && (sql.charAt(whereIndex + 3) == 'r') && (sql.charAt(whereIndex + 4) == 'e'); } catch (StringIndexOutOfBoundsException ignore) { foundWhere = false; } default : break; } whereIndex++; } while ((!foundWhere) && (whereIndex < sql.length())); if (foundWhere) whereIndex--; else whereIndex = -1; // Warning! Here if whereIndex is -1 (no where clause) // endWhere is used to find the end of the FROM clause. // The variable name can be misleading but it's faster to do it this // way. int endWhere = sql.indexOf("group by ", lastParenthesisIdx); if (endWhere == -1) { endWhere = sql.indexOf("having ", lastParenthesisIdx); if (endWhere == -1) { endWhere = sql.indexOf("order by ", lastParenthesisIdx); if (endWhere == -1) { endWhere = sql.indexOf("limit ", lastParenthesisIdx); if (endWhere == -1) endWhere = sql.length(); } } } int endFrom; if (whereIndex == -1) endFrom = endWhere; else endFrom = whereIndex; try { switch (granularity) { case ParsingGranularities.NO_PARSING : return; case ParsingGranularities.TABLE : int shift = originalSQL.length() - sql.length(); from = getFromTables(originalSQL.substring(shift, shift + endFrom) .trim(), schema, isCaseSensitive); break; case ParsingGranularities.COLUMN : case ParsingGranularities.COLUMN_UNIQUE : shift = originalSQL.length() - sql.length(); from = getFromTables(originalSQL.substring(shift, shift + endFrom) .trim(), schema, isCaseSensitive); // Find columns selected in the SELECT clause select = getSelectedColumns(selectClause, from, isCaseSensitive); if (whereIndex > 1) // Find columns involved in the WHERE clause (5="WHERE") where = getWhereColumns(originalSQL.substring( shift + whereIndex + 5, shift + endWhere).trim(), from, granularity == ParsingGranularities.COLUMN_UNIQUE, isCaseSensitive); break; default : throw new SQLException("Unsupported parsing granularity: '" + granularity + "'"); } } catch (SQLException e) { from = null; select = null; where = null; cacheable = RequestType.UNCACHEABLE; throw e; } //Gokul added this //I need to have the aliases to determine if any of the OrderBy columns //are referenced using their alias aliasFrom = from; if (from != null) { // Convert 'from' to an ArrayList of String objects instead of // AliasedTables objects int size = from.size(); ArrayList unaliased = new ArrayList(size); for (int i = 0; i < size; i++) unaliased .add(((AliasedDatabaseTable) from.get(i)).getTable().getName()); from = unaliased; } isParsed = true; }

void org.objectweb.cjdbc.common.sql.SelectRequest.setCursorName (  String  cursorName  )

Sets the cursorName value. 引数: cursorName  The cursorName to set. SelectRequest.java の 1061 行で定義されています。 参照元 org.objectweb.cjdbc.driver.Statement.executeQuery(), と org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabaseWorkerThread.readRequestFromStream(). { this.cursorName = cursorName; }

void org.objectweb.cjdbc.common.sql.SelectRequest.setPkValue (  String  pkValue  )

引数: pkValue  The pkValue to set. SelectRequest.java の 1041 行で定義されています。 { this.pkValue = pkValue; }

---

変数

transient ArrayList org.objectweb.cjdbc.common.sql.SelectRequest.aliasFrom [private]

ArrayList of AliasedTable objects SelectRequest.java の 72 行で定義されています。 参照元 org.objectweb.cjdbc.common.sql.SelectRequest.getAliasedFrom(), と org.objectweb.cjdbc.common.sql.SelectRequest.parse().

final int org.objectweb.cjdbc.common.sql.SelectRequest.AVERAGE_FUNCTION = 3 [static]

Represents a SQL average() macro SelectRequest.java の 87 行で定義されています。

final int org.objectweb.cjdbc.common.sql.SelectRequest.COUNT_FUNCTION = 4 [static]

Represents a SQL count() macro SelectRequest.java の 89 行で定義されています。

String org.objectweb.cjdbc.common.sql.SelectRequest.cursorName = null [private]

SelectRequest.java の 110 行で定義されています。 参照元 org.objectweb.cjdbc.common.sql.SelectRequest.getCursorName().

transient ArrayList org.objectweb.cjdbc.common.sql.SelectRequest.from [private]

ArrayList of String objects. SelectRequest.java の 69 行で定義されています。 参照元 org.objectweb.cjdbc.common.sql.SelectRequest.cloneParsing(), org.objectweb.cjdbc.common.sql.SelectRequest.debug(), org.objectweb.cjdbc.common.sql.SelectRequest.getFrom(), と org.objectweb.cjdbc.common.sql.SelectRequest.parse().

transient int org.objectweb.cjdbc.common.sql.SelectRequest.funcType = 0

Need to keep track of type of query, e.g. MAX, COUNT, etc. SelectRequest.java の 94 行で定義されています。 参照元 org.objectweb.cjdbc.common.sql.SelectRequest.isSqlFunction().

final int org.objectweb.cjdbc.common.sql.SelectRequest.MAX_FUNCTION = 1 [static]

Represents a SQL max() macro SelectRequest.java の 83 行で定義されています。

final int org.objectweb.cjdbc.common.sql.SelectRequest.MIN_FUNCTION = 2 [static]

Represents a SQL min() macro SelectRequest.java の 85 行で定義されています。

final int org.objectweb.cjdbc.common.sql.SelectRequest.NO_FUNCTION = 0 [static]

Some values to keep track of function in the SELECT request SelectRequest.java の 81 行で定義されています。

transient ArrayList org.objectweb.cjdbc.common.sql.SelectRequest.order [private]

ArrayList of OrderBy objects SelectRequest.java の 78 行で定義されています。 参照元 org.objectweb.cjdbc.common.sql.SelectRequest.getOrderBy().

transient String org.objectweb.cjdbc.common.sql.SelectRequest.pkValue [private]

Primary key value in case of a unique selection SelectRequest.java の 97 行で定義されています。 参照元 org.objectweb.cjdbc.common.sql.SelectRequest.cloneParsing(), org.objectweb.cjdbc.common.sql.SelectRequest.debug(), org.objectweb.cjdbc.common.sql.SelectRequest.getPkValue(), org.objectweb.cjdbc.common.sql.SelectRequest.getWhereColumns(), と org.objectweb.cjdbc.common.sql.SelectRequest.SelectRequest().

transient ArrayList org.objectweb.cjdbc.common.sql.SelectRequest.select [private]

ArrayList of TableColumn objects. SelectRequest.java の 66 行で定義されています。 参照元 org.objectweb.cjdbc.common.sql.SelectRequest.cloneParsing(), org.objectweb.cjdbc.common.sql.SelectRequest.debug(), org.objectweb.cjdbc.common.sql.SelectRequest.getSelect(), と org.objectweb.cjdbc.common.sql.SelectRequest.parse().

final int org.objectweb.cjdbc.common.sql.SelectRequest.SUM_FUNCTION = 5 [static]

Represents a SQL sum() macro SelectRequest.java の 91 行で定義されています。

transient ArrayList org.objectweb.cjdbc.common.sql.SelectRequest.where [private]

ArrayList of TableColumn objects. SelectRequest.java の 75 行で定義されています。 参照元 org.objectweb.cjdbc.common.sql.SelectRequest.cloneParsing(), org.objectweb.cjdbc.common.sql.SelectRequest.debug(), org.objectweb.cjdbc.common.sql.SelectRequest.getWhere(), と org.objectweb.cjdbc.common.sql.SelectRequest.parse().

transient Hashtable org.objectweb.cjdbc.common.sql.SelectRequest.whereValues [private]

Hashtable of String keys corresponding to column names and String values corresponding to the values associated with the UNIQUE columns of a UNIQUE SELECT. Used with the COLUMN_UNIQUE_DELETE granularity. 参照: org.objectweb.cjdbc.controller.cache.result.CachingGranularities SelectRequest.java の 108 行で定義されています。 参照元 org.objectweb.cjdbc.common.sql.SelectRequest.getWhereValues().

---

このクラスの説明は次のファイルから生成されました:

• src/org/objectweb/cjdbc/common/sql/SelectRequest.java

---