selectparser.java

通过系统把几乎所有与人力资源相关的数据统一管理

//$Id: SelectParser.java,v 1.14.2.8 2003/09/29 12:06:28 oneovthafew Exp $
package net.sf.hibernate.hql;

import java.util.HashSet;
import java.util.LinkedList;
import java.util.Set;
import java.util.List;

import net.sf.hibernate.Hibernate;
import net.sf.hibernate.QueryException;
import net.sf.hibernate.dialect.SQLFunction;
import net.sf.hibernate.type.Type;
import net.sf.hibernate.util.StringHelper;

/**
 * Parsers the select clause of a Hibernate query.
 * 
 * @author Gavin King, David Channon
 */
public class SelectParser implements Parser {
	
	//TODO: arithmetic expressions, multiple new Foo(...)
	
	private static final Set COUNT_MODIFIERS = new HashSet();
	static {		
		COUNT_MODIFIERS.add("distinct");
		COUNT_MODIFIERS.add("all");
		COUNT_MODIFIERS.add("*");
	}
	
	private LinkedList aggregateFuncTokenList = new LinkedList();
	
	private boolean ready;
	private boolean aggregate;
	private boolean first;
	private boolean afterNew;
	private boolean insideNew;
	private Class holderClass;
	
	private final SelectPathExpressionParser pathExpressionParser;
	private final PathExpressionParser aggregatePathExpressionParser;
	{
		pathExpressionParser = new SelectPathExpressionParser();
		aggregatePathExpressionParser = new PathExpressionParser();
		//TODO: would be nice to use false, but issues with MS SQL
		pathExpressionParser.setUseThetaStyleJoin(true);
		aggregatePathExpressionParser.setUseThetaStyleJoin(true);
	}
	
	public void token(String token, QueryTranslator q) throws QueryException {
		
		String lctoken = token.toLowerCase();
		
		if (first) {
			first = false;
			if ( "distinct".equals(lctoken) ) {
				q.setDistinct(true);
				return;
			}
			else if ( "all".equals(lctoken) ) {
				q.setDistinct(false);
				return;
			}
		}
		
		if (afterNew) {
			afterNew=false;
			holderClass = q.getImportedClass(token);
			if (holderClass==null) throw new QueryException("class not found: " + token);
			q.setHolderClass(holderClass);
			insideNew = true;
		}
		else if ( token.equals(StringHelper.COMMA) ) {
			if (ready) throw new QueryException("alias or expression expected in SELECT");
			q.appendScalarSelectToken(StringHelper.COMMA_SPACE);
			ready=true;
		}
		else if ( "new".equals(lctoken) ) {
			afterNew=true;
			ready=false;
		}
		else if ( StringHelper.OPEN_PAREN.equals(token) ) {
			if (insideNew && !aggregate && !ready) {
				//opening paren in new Foo ( ... )
				ready=true;
			}
			else if (aggregate) {
				q.appendScalarSelectToken(token);
			}
			else {
				throw new QueryException("aggregate function expected before ( in SELECT");
			}
			ready = true;
		}
		else if ( StringHelper.CLOSE_PAREN.equals(token) ) {
			if (insideNew && !aggregate && !ready) { 
				//if we are inside a new Result(), but not inside a nested function
				insideNew = false;
			}
			else if (aggregate && ready) {
				q.appendScalarSelectToken(token);
				aggregateFuncTokenList.removeLast();
				if (aggregateFuncTokenList.size() < 1) {
					aggregate = false;
					ready = false;
				}
			}
			else {
				throw new QueryException("( expected before ) in select");
			}
		}
		else if ( COUNT_MODIFIERS.contains(lctoken) ) {
			if ( !ready || !aggregate ) throw new QueryException( token + " only allowed inside aggregate function in SELECT");
			q.appendScalarSelectToken(token);
			if ( "*".equals(token) ) q.addSelectScalar(Hibernate.INTEGER); //special case
		}
		else if ( getFunction(lctoken, q)!=null ) {
			// the name of an SQL function
			if (!ready) throw new QueryException(", expected before aggregate function in SELECT: " + token);
			aggregate = true;
 			aggregateFuncTokenList.add(lctoken);
			ready = false;
			q.appendScalarSelectToken(token);
			if( !aggregateHasArgs(lctoken, q) ) {
				q.addSelectScalar( aggregateType(aggregateFuncTokenList, null, q) );
				if ( !aggregateFuncNoArgsHasParenthesis(lctoken, q) ) {
					aggregateFuncTokenList.removeLast();
					if (aggregateFuncTokenList.size() < 1) {
						aggregate = false;
						ready = false;
					}
					else {
						ready = true;
					}
				}
			}
		}
		else if (aggregate) {
			if (!ready) throw new QueryException("( expected after aggregate function in SELECT");
			ParserHelper.parse(aggregatePathExpressionParser, q.unalias(token), ParserHelper.PATH_SEPARATORS, q);
			
			if ( aggregatePathExpressionParser.isCollectionValued() ) {
				q.addCollection(
					aggregatePathExpressionParser.getCollectionName(),
					aggregatePathExpressionParser.getCollectionRole()
				);
			}
			q.appendScalarSelectToken( aggregatePathExpressionParser.getWhereColumn() );
			q.addSelectScalar( aggregateType(aggregateFuncTokenList, aggregatePathExpressionParser.getWhereColumnType(), q ) );
			aggregatePathExpressionParser.addAssociation(q);
		}
		else {
			if (!ready) throw new QueryException(", expected in SELECT");
			ParserHelper.parse(pathExpressionParser, q.unalias(token), ParserHelper.PATH_SEPARATORS, q);
			if ( pathExpressionParser.isCollectionValued() ) {
				q.addCollection(
					pathExpressionParser.getCollectionName(),
					pathExpressionParser.getCollectionRole()
				);
			}
			else if ( pathExpressionParser.getWhereColumnType().isEntityType() ) {
				q.addSelectClass( pathExpressionParser.getSelectName() );
			}
			q.appendScalarSelectTokens( pathExpressionParser.getWhereColumns() );
			q.addSelectScalar( pathExpressionParser.getWhereColumnType() );
			pathExpressionParser.addAssociation(q);
			
			ready = false;
		}
	}
	
	public boolean aggregateHasArgs(String funcToken, QueryTranslator q) {
		return getFunction(funcToken, q).hasArguments();
	}

	public boolean aggregateFuncNoArgsHasParenthesis(String funcToken, QueryTranslator q) {
		return getFunction(funcToken, q).hasParenthesesIfNoArguments();
	}

	public Type aggregateType(List funcTokenList, Type type, QueryTranslator q) throws QueryException {
		Type retType = type;
		Type argType;
		for (int i=funcTokenList.size()-1; i>=0; i--) {
			argType = retType;
			String funcToken = (String) funcTokenList.get(i);
			retType = getFunction(funcToken, q).getReturnType( argType, q.getFactory() );
		}
		return retType;
	}
	
	private SQLFunction getFunction(String name, QueryTranslator q) {
		return (SQLFunction) q.getFactory().getDialect().getFunctions().get(name);
	}
	
	public void start(QueryTranslator q) {
		ready = true;
		first = true;
		aggregate = false;
		afterNew = false;
		insideNew = false;
		holderClass = null;
		aggregateFuncTokenList.clear();
	}
	
	public void end(QueryTranslator q) {
	}
	
}