C-JDBC: org.objectweb.cjdbc.common.sql.SelectRequest Class Reference

00175   {
00176     if (granularity == ParsingGranularities.NO_PARSING)
00177     {
00178       cacheable = RequestType.CACHEABLE;
00179       isParsed = true;
00180       return;
00181     }
00182 
00183     // Sanity check
00184     if (schema == null)
00185       throw new SQLException(
00186           "Unable to parse request with an undefined database schema");
00187 
00188     String originalSQL = this.trimCarriageReturn();
00189     String sql = originalSQL.toLowerCase();
00190     if (!isCaseSensitive)
00191       originalSQL = sql;
00192 
00193     // Strip 'select'
00194     sql = sql.substring(6).trim();
00195 
00196     // Look for DISTINCT
00197     if (sql.startsWith("distinct"))
00198       sql = sql.substring(8).trim(); // Strip 'distinct '
00199 
00200     // Look for the begining of the FROM clause
00201     int fromIndex = sql.indexOf("from ");
00202     if (fromIndex == -1)
00203       throw new SQLException(
00204           "Unable to find the FROM keyword in this SELECT statement: '" + sql
00205               + "'");
00206 
00207     // Keep SELECT clause for later, we first have to check the
00208     // tables involved in the FROM clause
00209     int fshift = originalSQL.length() - sql.length();
00210     String selectClause = (isCaseSensitive) ? originalSQL.substring(fshift,
00211         fshift + fromIndex) : sql.substring(0, fromIndex);
00212 
00213     // Get rid of FROM
00214     sql = sql.substring(fromIndex + 5).trim();
00215 
00216     // Now find the boundaries of the FROM and WHERE clauses
00217     int whereIndex = 0;
00218     int parenthesis = 0;
00219     int lastParenthesisIdx = 0;
00220     boolean foundWhere = false;
00221     do
00222     {
00223       switch (sql.charAt(whereIndex))
00224       {
00225         case '(' :
00226           parenthesis++;
00227           break;
00228         case ')' :
00229           parenthesis--;
00230           lastParenthesisIdx = whereIndex;
00231           break;
00232         case 'w' :
00233           if (parenthesis == 0)
00234             try
00235             {
00236               foundWhere = (sql.charAt(whereIndex + 1) == 'h')
00237                   && (sql.charAt(whereIndex + 2) == 'e')
00238                   && (sql.charAt(whereIndex + 3) == 'r')
00239                   && (sql.charAt(whereIndex + 4) == 'e');
00240             }
00241             catch (StringIndexOutOfBoundsException ignore)
00242             {
00243               foundWhere = false;
00244             }
00245         default :
00246           break;
00247       }
00248       whereIndex++;
00249     }
00250     while ((!foundWhere) && (whereIndex < sql.length()));
00251     if (foundWhere)
00252       whereIndex--;
00253     else
00254       whereIndex = -1;
00255 
00256     // Warning! Here if whereIndex is -1 (no where clause)
00257     // endWhere is used to find the end of the FROM clause.
00258     // The variable name can be misleading but it's faster to do it this
00259     // way.
00260     int endWhere = sql.indexOf("group by ", lastParenthesisIdx);
00261     if (endWhere == -1)
00262     {
00263       endWhere = sql.indexOf("having ", lastParenthesisIdx);
00264       if (endWhere == -1)
00265       {
00266         endWhere = sql.indexOf("order by ", lastParenthesisIdx);
00267         if (endWhere == -1)
00268         {
00269           endWhere = sql.indexOf("limit ", lastParenthesisIdx);
00270           if (endWhere == -1)
00271             endWhere = sql.length();
00272         }
00273       }
00274     }
00275     int endFrom;
00276     if (whereIndex == -1)
00277       endFrom = endWhere;
00278     else
00279       endFrom = whereIndex;
00280 
00281     try
00282     {
00283       switch (granularity)
00284       {
00285         case ParsingGranularities.NO_PARSING :
00286           return;
00287         case ParsingGranularities.TABLE :
00288           int shift = originalSQL.length() - sql.length();
00289           from = getFromTables(originalSQL.substring(shift, shift + endFrom)
00290               .trim(), schema, isCaseSensitive);
00291           break;
00292         case ParsingGranularities.COLUMN :
00293         case ParsingGranularities.COLUMN_UNIQUE :
00294           shift = originalSQL.length() - sql.length();
00295           from = getFromTables(originalSQL.substring(shift, shift + endFrom)
00296               .trim(), schema, isCaseSensitive);
00297           // Find columns selected in the SELECT clause
00298           select = getSelectedColumns(selectClause, from, isCaseSensitive);
00299           if (whereIndex > 1)
00300             // Find columns involved in the WHERE clause (5="WHERE")
00301             where = getWhereColumns(originalSQL.substring(
00302                 shift + whereIndex + 5, shift + endWhere).trim(), from,
00303                 granularity == ParsingGranularities.COLUMN_UNIQUE,
00304                 isCaseSensitive);
00305           break;
00306         default :
00307           throw new SQLException("Unsupported parsing granularity: '"
00308               + granularity + "'");
00309       }
00310     }
00311     catch (SQLException e)
00312     {
00313       from = null;
00314       select = null;
00315       where = null;
00316       cacheable = RequestType.UNCACHEABLE;
00317       throw e;
00318     }
00319 
00320     //Gokul added this
00321     //I need to have the aliases to determine if any of the OrderBy columns
00322     //are referenced using their alias
00323 
00324     aliasFrom = from;
00325 
00326     if (from != null)
00327     {
00328       // Convert 'from' to an ArrayList of String objects instead of
00329       // AliasedTables objects
00330       int size = from.size();
00331       ArrayList unaliased = new ArrayList(size);
00332       for (int i = 0; i < size; i++)
00333         unaliased
00334             .add(((AliasedDatabaseTable) from.get(i)).getTable().getName());
00335       from = unaliased;
00336     }
00337 
00338     isParsed = true;
00339   }


Public Member Functions
	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 Attributes
transient int	funcType = 0
Static Public Attributes
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

org.objectweb.cjdbc.common.sql.SelectRequest Class Reference

Public Member Functions

Public Attributes

Static Public Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation