org.apache.calcite.sql.validate

Class SqlValidatorImpl

java.lang.Object

org.apache.calcite.sql.validate.SqlValidatorImpl

All Implemented Interfaces:

org.apache.calcite.sql.validate.SqlValidator, org.apache.calcite.sql.validate.SqlValidatorWithHints

public class SqlValidatorImpl
extends Object
implements org.apache.calcite.sql.validate.SqlValidatorWithHints

Default implementation of SqlValidator.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SqlValidatorImpl.DmlNamespace Common base class for DML statement namespaces.
protected static class	SqlValidatorImpl.FunctionParamInfo Utility object used to maintain information about the parameters in a function call.
protected static class	SqlValidatorImpl.IdInfo Information about an identifier in a particular scope.
static class	SqlValidatorImpl.Status Validation status.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	expandColumnReferences
protected boolean	expandIdentifiers
protected Deque<SqlValidatorImpl.FunctionParamInfo>	functionCallStack Stack of objects that maintain information about function calls.
protected Map<String,SqlValidatorImpl.IdInfo>	idPositions Maps ParsePosition strings to the SqlIdentifier identifier objects at these positions
protected Map<org.apache.calcite.sql.SqlNode,org.apache.calcite.sql.validate.SqlValidatorNamespace>	namespaces Maps a node to the namespace which describes what columns they contain.
protected Map<org.apache.calcite.sql.SqlNode,org.apache.calcite.sql.validate.SqlValidatorScope>	scopes Maps query node objects to the SqlValidatorScope scope created from them.
static org.slf4j.Logger	TRACER
protected org.apache.calcite.rel.type.RelDataTypeFactory	typeFactory
protected org.apache.calcite.rel.type.RelDataType	unknownType The type of dynamic parameters until a type is imposed on them.
static String	UPDATE_ANON_PREFIX Alias prefix generated for source columns when rewriting UPDATE to MERGE.
static String	UPDATE_SRC_ALIAS Alias generated for the source table when rewriting UPDATE to MERGE.
static String	UPDATE_TGT_ALIAS Alias generated for the target table when rewriting UPDATE to MERGE if no alias was specified by the user.

Fields inherited from interface org.apache.calcite.sql.validate.SqlValidator

STRICT

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SqlValidatorImpl(org.apache.calcite.sql.SqlOperatorTable opTab, org.apache.calcite.sql.validate.SqlValidatorCatalogReader catalogReader, org.apache.calcite.rel.type.RelDataTypeFactory typeFactory, org.apache.calcite.sql.validate.SqlConformance conformance) Creates a validator.

Method Summary

Modifier and Type	Method and Description
protected void	addToSelectList(List<org.apache.calcite.sql.SqlNode> list, Set<String> aliases, List<Map.Entry<String,org.apache.calcite.rel.type.RelDataType>> fieldList, org.apache.calcite.sql.SqlNode exp, org.apache.calcite.sql.validate.SqlValidatorScope scope, boolean includeSystemVars) Adds an expression to a select list, ensuring that its alias does not clash with any existing expressions on the list.
protected void	checkTypeAssignment(org.apache.calcite.rel.type.RelDataType sourceRowType, org.apache.calcite.rel.type.RelDataType targetRowType, org.apache.calcite.sql.SqlNode query)
protected org.apache.calcite.sql.validate.MatchRecognizeNamespace	createMatchRecognizeNameSpace(org.apache.calcite.sql.SqlMatchRecognize call, org.apache.calcite.sql.SqlNode enclosingNode)
protected org.apache.calcite.sql.validate.SelectNamespace	createSelectNamespace(org.apache.calcite.sql.SqlSelect select, org.apache.calcite.sql.SqlNode enclosingNode) Creates a namespace for a SELECT node.
protected org.apache.calcite.sql.validate.SetopNamespace	createSetopNamespace(org.apache.calcite.sql.SqlCall call, org.apache.calcite.sql.SqlNode enclosingNode) Creates a namespace for a set operation (UNION, INTERSECT, or EXCEPT).
protected org.apache.calcite.sql.SqlSelect	createSourceSelectForDelete(org.apache.calcite.sql.SqlDelete call) Creates the SELECT statement that putatively feeds rows into a DELETE statement to be deleted.
protected org.apache.calcite.sql.SqlSelect	createSourceSelectForUpdate(org.apache.calcite.sql.SqlUpdate call) Creates the SELECT statement that putatively feeds rows into an UPDATE statement to be updated.
protected org.apache.calcite.rel.type.RelDataType	createTargetRowType(org.apache.calcite.sql.validate.SqlValidatorTable table, org.apache.calcite.sql.SqlNodeList targetColumnList, boolean append) Derives a row-type for INSERT and UPDATE operations.
void	declareCursor(org.apache.calcite.sql.SqlSelect select, org.apache.calcite.sql.validate.SqlValidatorScope parentScope)
String	deriveAlias(org.apache.calcite.sql.SqlNode node, int ordinal)
org.apache.calcite.rel.type.RelDataType	deriveConstructorType(org.apache.calcite.sql.validate.SqlValidatorScope scope, org.apache.calcite.sql.SqlCall call, org.apache.calcite.sql.SqlFunction unresolvedConstructor, org.apache.calcite.sql.SqlFunction resolvedConstructor, List<org.apache.calcite.rel.type.RelDataType> argTypes)
org.apache.calcite.rel.type.RelDataType	deriveType(org.apache.calcite.sql.validate.SqlValidatorScope scope, org.apache.calcite.sql.SqlNode expr)
org.apache.calcite.sql.SqlNode	expand(org.apache.calcite.sql.SqlNode expr, org.apache.calcite.sql.validate.SqlValidatorScope scope)
org.apache.calcite.sql.SqlNode	expandGroupByOrHavingExpr(org.apache.calcite.sql.SqlNode expr, org.apache.calcite.sql.validate.SqlValidatorScope scope, org.apache.calcite.sql.SqlSelect select, boolean havingExpression)
org.apache.calcite.sql.SqlNode	expandOrderExpr(org.apache.calcite.sql.SqlSelect select, org.apache.calcite.sql.SqlNode orderExpr)
org.apache.calcite.sql.SqlNodeList	expandStar(org.apache.calcite.sql.SqlNodeList selectList, org.apache.calcite.sql.SqlSelect select, boolean includeSystemVars)
protected org.apache.calcite.sql.SqlNode	getAggregate(org.apache.calcite.sql.SqlSelect select) Returns the parse tree node (GROUP BY, HAVING, or an aggregate function call) that causes select to be an aggregate query, or null if it is not an aggregate query.
org.apache.calcite.sql.validate.SqlValidatorCatalogReader	getCatalogReader()
boolean	getColumnReferenceExpansion()
org.apache.calcite.sql.validate.SqlConformance	getConformance()
org.apache.calcite.sql.validate.SqlValidatorScope	getCursorScope(org.apache.calcite.sql.SqlSelect select)
org.apache.calcite.config.NullCollation	getDefaultNullCollation()
org.apache.calcite.sql.validate.SqlValidatorScope	getEmptyScope()
List<List<String>>	getFieldOrigins(org.apache.calcite.sql.SqlNode sqlQuery)
org.apache.calcite.sql.validate.SqlValidatorScope	getFromScope(org.apache.calcite.sql.SqlSelect select)
org.apache.calcite.sql.validate.SqlValidatorScope	getGroupScope(org.apache.calcite.sql.SqlSelect select)
org.apache.calcite.sql.validate.SqlValidatorScope	getHavingScope(org.apache.calcite.sql.SqlSelect select)
org.apache.calcite.sql.validate.SqlValidatorScope	getJoinScope(org.apache.calcite.sql.SqlNode node)
protected org.apache.calcite.rel.type.RelDataType	getLogicalSourceRowType(org.apache.calcite.rel.type.RelDataType sourceRowType, org.apache.calcite.sql.SqlInsert insert)
protected org.apache.calcite.rel.type.RelDataType	getLogicalTargetRowType(org.apache.calcite.rel.type.RelDataType targetRowType, org.apache.calcite.sql.SqlInsert insert)
org.apache.calcite.sql.validate.SqlValidatorScope	getMatchRecognizeScope(org.apache.calcite.sql.SqlMatchRecognize node)
org.apache.calcite.sql.validate.SqlValidatorNamespace	getNamespace(org.apache.calcite.sql.SqlNode node)
org.apache.calcite.sql.SqlOperatorTable	getOperatorTable()
org.apache.calcite.sql.validate.SqlValidatorScope	getOrderScope(org.apache.calcite.sql.SqlSelect select)
org.apache.calcite.sql.SqlNode	getOriginal(org.apache.calcite.sql.SqlNode expr)
org.apache.calcite.sql.validate.SqlValidatorScope	getOverScope(org.apache.calcite.sql.SqlNode node)
org.apache.calcite.rel.type.RelDataType	getParameterRowType(org.apache.calcite.sql.SqlNode sqlQuery)
String	getParentCursor(String columnListParamName)
org.apache.calcite.sql.validate.SelectScope	getRawSelectScope(org.apache.calcite.sql.SqlSelect select)
org.apache.calcite.sql.validate.SqlValidatorScope	getSelectScope(org.apache.calcite.sql.SqlSelect select)
protected org.apache.calcite.sql.SqlNode	getSelfJoinExprForUpdate(org.apache.calcite.sql.SqlNode table, String alias) Allows a subclass to provide information about how to convert an UPDATE into a MERGE via self-join.
org.apache.calcite.rel.type.RelDataTypeFactory	getTypeFactory()
org.apache.calcite.rel.type.RelDataType	getUnknownType()
org.apache.calcite.rel.type.RelDataType	getValidatedNodeType(org.apache.calcite.sql.SqlNode node)
org.apache.calcite.rel.type.RelDataType	getValidatedNodeTypeIfKnown(org.apache.calcite.sql.SqlNode node)
org.apache.calcite.sql.validate.SqlValidatorImpl.ValidationErrorFunction	getValidationErrorFunction()
org.apache.calcite.sql.validate.SqlValidatorScope	getWhereScope(org.apache.calcite.sql.SqlSelect select)
protected org.apache.calcite.sql.SqlWindow	getWindowByName(org.apache.calcite.sql.SqlIdentifier id, org.apache.calcite.sql.validate.SqlValidatorScope scope)
org.apache.calcite.sql.validate.SqlValidatorScope	getWithScope(org.apache.calcite.sql.SqlNode withItem)
org.apache.calcite.runtime.CalciteException	handleUnresolvedFunction(org.apache.calcite.sql.SqlCall call, org.apache.calcite.sql.SqlFunction unresolvedFunction, List<org.apache.calcite.rel.type.RelDataType> argTypes, List<String> argNames)
protected void	inferUnknownTypes(org.apache.calcite.rel.type.RelDataType inferredType, org.apache.calcite.sql.validate.SqlValidatorScope scope, org.apache.calcite.sql.SqlNode node)
boolean	isAggregate(org.apache.calcite.sql.SqlNode selectNode)
boolean	isAggregate(org.apache.calcite.sql.SqlSelect select)
protected boolean	isNestedAggregateWindow(org.apache.calcite.sql.SqlNode node)
protected boolean	isOverAggregateWindow(org.apache.calcite.sql.SqlNode node)
boolean	isSystemField(org.apache.calcite.rel.type.RelDataTypeField field)
List<org.apache.calcite.sql.validate.SqlMoniker>	lookupHints(org.apache.calcite.sql.SqlNode topNode, org.apache.calcite.sql.parser.SqlParserPos pos)
void	lookupNameCompletionHints(org.apache.calcite.sql.validate.SqlValidatorScope scope, List<String> names, org.apache.calcite.sql.parser.SqlParserPos pos, Collection<org.apache.calcite.sql.validate.SqlMoniker> hintList) Populates a list of all the valid alternatives for an identifier.
org.apache.calcite.sql.validate.SqlMoniker	lookupQualifiedName(org.apache.calcite.sql.SqlNode topNode, org.apache.calcite.sql.parser.SqlParserPos pos)
org.apache.calcite.runtime.CalciteContextException	newValidationError(org.apache.calcite.sql.SqlNode node, org.apache.calcite.runtime.Resources.ExInst<org.apache.calcite.sql.validate.SqlValidatorException> e)
protected org.apache.calcite.sql.SqlNode	performUnconditionalRewrites(org.apache.calcite.sql.SqlNode node, boolean underFrom) Performs expression rewrites which are always used unconditionally.
void	popFunctionCall()
void	pushFunctionCall()
protected void	registerNamespace(org.apache.calcite.sql.validate.SqlValidatorScope usingScope, String alias, org.apache.calcite.sql.validate.SqlValidatorNamespace ns, boolean forceNullable) Registers a new namespace, and adds it as a child of its parent scope.
void	removeValidatedNodeType(org.apache.calcite.sql.SqlNode node)
org.apache.calcite.sql.SqlWindow	resolveWindow(org.apache.calcite.sql.SqlNode windowOrRef, org.apache.calcite.sql.validate.SqlValidatorScope scope, boolean populateBounds)
void	setCallRewrite(boolean rewriteCalls)
void	setColumnReferenceExpansion(boolean expandColumnReferences)
void	setDefaultNullCollation(org.apache.calcite.config.NullCollation nullCollation)
void	setIdentifierExpansion(boolean expandIdentifiers)
void	setOriginal(org.apache.calcite.sql.SqlNode expr, org.apache.calcite.sql.SqlNode original)
void	setValidatedNodeType(org.apache.calcite.sql.SqlNode node, org.apache.calcite.rel.type.RelDataType type) Saves the type of a SqlNode, now that it has been validated.
protected boolean	shouldAllowIntermediateOrderBy()
protected boolean	shouldAllowOverRelation()
boolean	shouldExpandIdentifiers()
org.apache.calcite.sql.SqlNode	validate(org.apache.calcite.sql.SqlNode topNode)
void	validateAggregateParams(org.apache.calcite.sql.SqlCall aggCall, org.apache.calcite.sql.SqlNode filter, org.apache.calcite.sql.validate.SqlValidatorScope scope)
void	validateCall(org.apache.calcite.sql.SqlCall call, org.apache.calcite.sql.validate.SqlValidatorScope scope)
void	validateColumnListParams(org.apache.calcite.sql.SqlFunction function, List<org.apache.calcite.rel.type.RelDataType> argTypes, List<org.apache.calcite.sql.SqlNode> operands)
void	validateDataType(org.apache.calcite.sql.SqlDataTypeSpec dataType)
void	validateDelete(org.apache.calcite.sql.SqlDelete call)
void	validateDynamicParam(org.apache.calcite.sql.SqlDynamicParam dynamicParam)
protected void	validateFeature(org.apache.calcite.runtime.Feature feature, org.apache.calcite.sql.parser.SqlParserPos context) Validates that a particular feature is enabled.
protected void	validateFrom(org.apache.calcite.sql.SqlNode node, org.apache.calcite.rel.type.RelDataType targetRowType, org.apache.calcite.sql.validate.SqlValidatorScope scope) Validates the FROM clause of a query, or (recursively) a child node of the FROM clause: AS, OVER, JOIN, VALUES, or sub-query.
protected void	validateGroupClause(org.apache.calcite.sql.SqlSelect select) Validates the GROUP BY clause of a SELECT statement.
protected void	validateHavingClause(org.apache.calcite.sql.SqlSelect select)
void	validateIdentifier(org.apache.calcite.sql.SqlIdentifier id, org.apache.calcite.sql.validate.SqlValidatorScope scope)
void	validateInsert(org.apache.calcite.sql.SqlInsert insert)
void	validateIntervalQualifier(org.apache.calcite.sql.SqlIntervalQualifier qualifier)
protected void	validateJoin(org.apache.calcite.sql.SqlJoin join, org.apache.calcite.sql.validate.SqlValidatorScope scope)
void	validateLiteral(org.apache.calcite.sql.SqlLiteral literal)
void	validateMatchRecognize(org.apache.calcite.sql.SqlCall call)
void	validateMerge(org.apache.calcite.sql.SqlMerge call)
boolean	validateModality(org.apache.calcite.sql.SqlSelect select, org.apache.calcite.sql.validate.SqlModality modality, boolean fail)
protected void	validateNamespace(org.apache.calcite.sql.validate.SqlValidatorNamespace namespace, org.apache.calcite.rel.type.RelDataType targetRowType) Validates a namespace.
protected void	validateOrderList(org.apache.calcite.sql.SqlSelect select) Validates the ORDER BY clause of a SELECT statement.
protected void	validateOver(org.apache.calcite.sql.SqlCall call, org.apache.calcite.sql.validate.SqlValidatorScope scope)
org.apache.calcite.sql.SqlNode	validateParameterizedExpression(org.apache.calcite.sql.SqlNode topNode, Map<String,org.apache.calcite.rel.type.RelDataType> nameToTypeMap)
void	validateQuery(org.apache.calcite.sql.SqlNode node, org.apache.calcite.sql.validate.SqlValidatorScope scope, org.apache.calcite.rel.type.RelDataType targetRowType)
protected void	validateSelect(org.apache.calcite.sql.SqlSelect select, org.apache.calcite.rel.type.RelDataType targetRowType) Validates a SELECT statement.
protected org.apache.calcite.rel.type.RelDataType	validateSelectList(org.apache.calcite.sql.SqlNodeList selectItems, org.apache.calcite.sql.SqlSelect select, org.apache.calcite.rel.type.RelDataType targetRowType)
void	validateSequenceValue(org.apache.calcite.sql.validate.SqlValidatorScope scope, org.apache.calcite.sql.SqlIdentifier id)
void	validateUpdate(org.apache.calcite.sql.SqlUpdate call)
protected void	validateValues(org.apache.calcite.sql.SqlCall node, org.apache.calcite.rel.type.RelDataType targetRowType, org.apache.calcite.sql.validate.SqlValidatorScope scope) Validates a VALUES clause.
protected void	validateWhereClause(org.apache.calcite.sql.SqlSelect select)
protected void	validateWhereOrOn(org.apache.calcite.sql.validate.SqlValidatorScope scope, org.apache.calcite.sql.SqlNode condition, String clause)
void	validateWindow(org.apache.calcite.sql.SqlNode windowOrId, org.apache.calcite.sql.validate.SqlValidatorScope scope, org.apache.calcite.sql.SqlCall call)
protected void	validateWindowClause(org.apache.calcite.sql.SqlSelect select)
void	validateWith(org.apache.calcite.sql.SqlWith with, org.apache.calcite.sql.validate.SqlValidatorScope scope)
void	validateWithItem(org.apache.calcite.sql.SqlWithItem withItem)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

TRACER

public static final org.slf4j.Logger TRACER

UPDATE_SRC_ALIAS

public static final String UPDATE_SRC_ALIAS

Alias generated for the source table when rewriting UPDATE to MERGE.

See Also:

Constant Field Values

UPDATE_TGT_ALIAS

public static final String UPDATE_TGT_ALIAS

Alias generated for the target table when rewriting UPDATE to MERGE if no alias was specified by the user.

See Also:

Constant Field Values

UPDATE_ANON_PREFIX

public static final String UPDATE_ANON_PREFIX

Alias prefix generated for source columns when rewriting UPDATE to MERGE.

See Also:

Constant Field Values

idPositions

protected final Map<String,SqlValidatorImpl.IdInfo> idPositions

Maps ParsePosition strings to the SqlIdentifier identifier objects at these positions

scopes

protected final Map<org.apache.calcite.sql.SqlNode,org.apache.calcite.sql.validate.SqlValidatorScope> scopes

Maps query node objects to the SqlValidatorScope scope created from them.

namespaces

protected final Map<org.apache.calcite.sql.SqlNode,org.apache.calcite.sql.validate.SqlValidatorNamespace> namespaces

Maps a node to the namespace which describes what columns they contain.

functionCallStack

protected final Deque<SqlValidatorImpl.FunctionParamInfo> functionCallStack

Stack of objects that maintain information about function calls. A stack is needed to handle nested function calls. The function call currently being validated is at the top of the stack.

typeFactory

protected final org.apache.calcite.rel.type.RelDataTypeFactory typeFactory

unknownType

protected final org.apache.calcite.rel.type.RelDataType unknownType

The type of dynamic parameters until a type is imposed on them.

expandIdentifiers

protected boolean expandIdentifiers

expandColumnReferences

protected boolean expandColumnReferences

Constructor Detail

SqlValidatorImpl

protected SqlValidatorImpl(org.apache.calcite.sql.SqlOperatorTable opTab,
                           org.apache.calcite.sql.validate.SqlValidatorCatalogReader catalogReader,
                           org.apache.calcite.rel.type.RelDataTypeFactory typeFactory,
                           org.apache.calcite.sql.validate.SqlConformance conformance)

Creates a validator.

Parameters:

opTab - Operator table

catalogReader - Catalog reader

typeFactory - Type factory

conformance - Compatibility mode

Method Detail

getConformance

public org.apache.calcite.sql.validate.SqlConformance getConformance()

Specified by:

getConformance in interface org.apache.calcite.sql.validate.SqlValidator

getCatalogReader

public org.apache.calcite.sql.validate.SqlValidatorCatalogReader getCatalogReader()

Specified by:

getCatalogReader in interface org.apache.calcite.sql.validate.SqlValidator

getOperatorTable

public org.apache.calcite.sql.SqlOperatorTable getOperatorTable()

Specified by:

getOperatorTable in interface org.apache.calcite.sql.validate.SqlValidator

getTypeFactory

public org.apache.calcite.rel.type.RelDataTypeFactory getTypeFactory()

Specified by:

getTypeFactory in interface org.apache.calcite.sql.validate.SqlValidator

getUnknownType

public org.apache.calcite.rel.type.RelDataType getUnknownType()

Specified by:

getUnknownType in interface org.apache.calcite.sql.validate.SqlValidator

expandStar

public org.apache.calcite.sql.SqlNodeList expandStar(org.apache.calcite.sql.SqlNodeList selectList,
                                                     org.apache.calcite.sql.SqlSelect select,
                                                     boolean includeSystemVars)

Specified by:

expandStar in interface org.apache.calcite.sql.validate.SqlValidator

declareCursor

public void declareCursor(org.apache.calcite.sql.SqlSelect select,
                          org.apache.calcite.sql.validate.SqlValidatorScope parentScope)

Specified by:

declareCursor in interface org.apache.calcite.sql.validate.SqlValidator

pushFunctionCall

public void pushFunctionCall()

Specified by:

pushFunctionCall in interface org.apache.calcite.sql.validate.SqlValidator

popFunctionCall

public void popFunctionCall()

Specified by:

popFunctionCall in interface org.apache.calcite.sql.validate.SqlValidator

getParentCursor

public String getParentCursor(String columnListParamName)

Specified by:

getParentCursor in interface org.apache.calcite.sql.validate.SqlValidator

validate

public org.apache.calcite.sql.SqlNode validate(org.apache.calcite.sql.SqlNode topNode)

Specified by:

validate in interface org.apache.calcite.sql.validate.SqlValidator

lookupHints

public List<org.apache.calcite.sql.validate.SqlMoniker> lookupHints(org.apache.calcite.sql.SqlNode topNode,
                                                                    org.apache.calcite.sql.parser.SqlParserPos pos)

Specified by:

lookupHints in interface org.apache.calcite.sql.validate.SqlValidatorWithHints

lookupQualifiedName

public org.apache.calcite.sql.validate.SqlMoniker lookupQualifiedName(org.apache.calcite.sql.SqlNode topNode,
                                                                      org.apache.calcite.sql.parser.SqlParserPos pos)

Specified by:

lookupQualifiedName in interface org.apache.calcite.sql.validate.SqlValidatorWithHints

lookupNameCompletionHints

public final void lookupNameCompletionHints(org.apache.calcite.sql.validate.SqlValidatorScope scope,
                                            List<String> names,
                                            org.apache.calcite.sql.parser.SqlParserPos pos,
                                            Collection<org.apache.calcite.sql.validate.SqlMoniker> hintList)

Populates a list of all the valid alternatives for an identifier.

Parameters:

scope - Validation scope

names - Components of the identifier

pos - position

hintList - a list of valid options

validateParameterizedExpression

public org.apache.calcite.sql.SqlNode validateParameterizedExpression(org.apache.calcite.sql.SqlNode topNode,
                                                                      Map<String,org.apache.calcite.rel.type.RelDataType> nameToTypeMap)

Specified by:

validateParameterizedExpression in interface org.apache.calcite.sql.validate.SqlValidator

validateQuery

public void validateQuery(org.apache.calcite.sql.SqlNode node,
                          org.apache.calcite.sql.validate.SqlValidatorScope scope,
                          org.apache.calcite.rel.type.RelDataType targetRowType)

Specified by:

validateQuery in interface org.apache.calcite.sql.validate.SqlValidator

validateNamespace

protected void validateNamespace(org.apache.calcite.sql.validate.SqlValidatorNamespace namespace,
                                 org.apache.calcite.rel.type.RelDataType targetRowType)

Validates a namespace.

Parameters:

namespace - Namespace

targetRowType - Desired row type, must not be null, may be the data type 'unknown'.

getEmptyScope

public org.apache.calcite.sql.validate.SqlValidatorScope getEmptyScope()

getCursorScope

public org.apache.calcite.sql.validate.SqlValidatorScope getCursorScope(org.apache.calcite.sql.SqlSelect select)

getWhereScope

public org.apache.calcite.sql.validate.SqlValidatorScope getWhereScope(org.apache.calcite.sql.SqlSelect select)

Specified by:

getWhereScope in interface org.apache.calcite.sql.validate.SqlValidator

getSelectScope

public org.apache.calcite.sql.validate.SqlValidatorScope getSelectScope(org.apache.calcite.sql.SqlSelect select)

Specified by:

getSelectScope in interface org.apache.calcite.sql.validate.SqlValidator

getRawSelectScope

public org.apache.calcite.sql.validate.SelectScope getRawSelectScope(org.apache.calcite.sql.SqlSelect select)

Specified by:

getRawSelectScope in interface org.apache.calcite.sql.validate.SqlValidator

getHavingScope

public org.apache.calcite.sql.validate.SqlValidatorScope getHavingScope(org.apache.calcite.sql.SqlSelect select)

Specified by:

getHavingScope in interface org.apache.calcite.sql.validate.SqlValidator

getGroupScope

public org.apache.calcite.sql.validate.SqlValidatorScope getGroupScope(org.apache.calcite.sql.SqlSelect select)

Specified by:

getGroupScope in interface org.apache.calcite.sql.validate.SqlValidator

getFromScope

public org.apache.calcite.sql.validate.SqlValidatorScope getFromScope(org.apache.calcite.sql.SqlSelect select)

Specified by:

getFromScope in interface org.apache.calcite.sql.validate.SqlValidator

getOrderScope

public org.apache.calcite.sql.validate.SqlValidatorScope getOrderScope(org.apache.calcite.sql.SqlSelect select)

Specified by:

getOrderScope in interface org.apache.calcite.sql.validate.SqlValidator

getMatchRecognizeScope

public org.apache.calcite.sql.validate.SqlValidatorScope getMatchRecognizeScope(org.apache.calcite.sql.SqlMatchRecognize node)

Specified by:

getMatchRecognizeScope in interface org.apache.calcite.sql.validate.SqlValidator

getJoinScope

public org.apache.calcite.sql.validate.SqlValidatorScope getJoinScope(org.apache.calcite.sql.SqlNode node)

Specified by:

getJoinScope in interface org.apache.calcite.sql.validate.SqlValidator

getOverScope

public org.apache.calcite.sql.validate.SqlValidatorScope getOverScope(org.apache.calcite.sql.SqlNode node)

Specified by:

getOverScope in interface org.apache.calcite.sql.validate.SqlValidator

getNamespace

public org.apache.calcite.sql.validate.SqlValidatorNamespace getNamespace(org.apache.calcite.sql.SqlNode node)

Specified by:

getNamespace in interface org.apache.calcite.sql.validate.SqlValidator

performUnconditionalRewrites

protected org.apache.calcite.sql.SqlNode performUnconditionalRewrites(org.apache.calcite.sql.SqlNode node,
                                                                      boolean underFrom)

Performs expression rewrites which are always used unconditionally. These rewrites massage the expression tree into a standard form so that the rest of the validation logic can be simpler.

Parameters:

node - expression to be rewritten

underFrom - whether node appears directly under a FROM clause

Returns:

rewritten expression

getSelfJoinExprForUpdate

protected org.apache.calcite.sql.SqlNode getSelfJoinExprForUpdate(org.apache.calcite.sql.SqlNode table,
                                                                  String alias)

Allows a subclass to provide information about how to convert an UPDATE into a MERGE via self-join. If this method returns null, then no such conversion takes place. Otherwise, this method should return a suitable unique identifier expression for the given table.

Parameters:

table - identifier for table being updated

alias - alias to use for qualifying columns in expression, or null for unqualified references; if this is equal to "SYS$SRC", then column references have been anonymized to "SYS$ANONx", where x is the 1-based column number.

Returns:

expression for unique identifier, or null to prevent conversion

createSourceSelectForUpdate

protected org.apache.calcite.sql.SqlSelect createSourceSelectForUpdate(org.apache.calcite.sql.SqlUpdate call)

Creates the SELECT statement that putatively feeds rows into an UPDATE statement to be updated.

Parameters:

call - Call to the UPDATE operator

Returns:

select statement

createSourceSelectForDelete

protected org.apache.calcite.sql.SqlSelect createSourceSelectForDelete(org.apache.calcite.sql.SqlDelete call)

Creates the SELECT statement that putatively feeds rows into a DELETE statement to be deleted.

Parameters:

call - Call to the DELETE operator

Returns:

select statement

getValidatedNodeType

public org.apache.calcite.rel.type.RelDataType getValidatedNodeType(org.apache.calcite.sql.SqlNode node)

Specified by:

getValidatedNodeType in interface org.apache.calcite.sql.validate.SqlValidator

getValidatedNodeTypeIfKnown

public org.apache.calcite.rel.type.RelDataType getValidatedNodeTypeIfKnown(org.apache.calcite.sql.SqlNode node)

Specified by:

getValidatedNodeTypeIfKnown in interface org.apache.calcite.sql.validate.SqlValidator

setValidatedNodeType

public final void setValidatedNodeType(org.apache.calcite.sql.SqlNode node,
                                       org.apache.calcite.rel.type.RelDataType type)

Saves the type of a SqlNode, now that it has been validated.

Unlike the base class method, this method is not deprecated. It is available from within Calcite, but is not part of the public API.

Specified by:

setValidatedNodeType in interface org.apache.calcite.sql.validate.SqlValidator

Parameters:

node - A SQL parse tree node, never null

type - Its type; must not be null

removeValidatedNodeType

public void removeValidatedNodeType(org.apache.calcite.sql.SqlNode node)

Specified by:

removeValidatedNodeType in interface org.apache.calcite.sql.validate.SqlValidator

deriveType

public org.apache.calcite.rel.type.RelDataType deriveType(org.apache.calcite.sql.validate.SqlValidatorScope scope,
                                                          org.apache.calcite.sql.SqlNode expr)

Specified by:

deriveType in interface org.apache.calcite.sql.validate.SqlValidator

deriveConstructorType

public org.apache.calcite.rel.type.RelDataType deriveConstructorType(org.apache.calcite.sql.validate.SqlValidatorScope scope,
                                                                     org.apache.calcite.sql.SqlCall call,
                                                                     org.apache.calcite.sql.SqlFunction unresolvedConstructor,
                                                                     org.apache.calcite.sql.SqlFunction resolvedConstructor,
                                                                     List<org.apache.calcite.rel.type.RelDataType> argTypes)

Specified by:

deriveConstructorType in interface org.apache.calcite.sql.validate.SqlValidator

handleUnresolvedFunction

public org.apache.calcite.runtime.CalciteException handleUnresolvedFunction(org.apache.calcite.sql.SqlCall call,
                                                                            org.apache.calcite.sql.SqlFunction unresolvedFunction,
                                                                            List<org.apache.calcite.rel.type.RelDataType> argTypes,
                                                                            List<String> argNames)

Specified by:

handleUnresolvedFunction in interface org.apache.calcite.sql.validate.SqlValidator

inferUnknownTypes

protected void inferUnknownTypes(org.apache.calcite.rel.type.RelDataType inferredType,
                                 org.apache.calcite.sql.validate.SqlValidatorScope scope,
                                 org.apache.calcite.sql.SqlNode node)

addToSelectList

protected void addToSelectList(List<org.apache.calcite.sql.SqlNode> list,
                               Set<String> aliases,
                               List<Map.Entry<String,org.apache.calcite.rel.type.RelDataType>> fieldList,
                               org.apache.calcite.sql.SqlNode exp,
                               org.apache.calcite.sql.validate.SqlValidatorScope scope,
                               boolean includeSystemVars)

Adds an expression to a select list, ensuring that its alias does not clash with any existing expressions on the list.

deriveAlias

public String deriveAlias(org.apache.calcite.sql.SqlNode node,
                          int ordinal)

Specified by:

deriveAlias in interface org.apache.calcite.sql.validate.SqlValidator

setIdentifierExpansion

public void setIdentifierExpansion(boolean expandIdentifiers)

Specified by:

setIdentifierExpansion in interface org.apache.calcite.sql.validate.SqlValidator

setColumnReferenceExpansion

public void setColumnReferenceExpansion(boolean expandColumnReferences)

Specified by:

setColumnReferenceExpansion in interface org.apache.calcite.sql.validate.SqlValidator

getColumnReferenceExpansion

public boolean getColumnReferenceExpansion()

Specified by:

getColumnReferenceExpansion in interface org.apache.calcite.sql.validate.SqlValidator

setDefaultNullCollation

public void setDefaultNullCollation(org.apache.calcite.config.NullCollation nullCollation)

Specified by:

setDefaultNullCollation in interface org.apache.calcite.sql.validate.SqlValidator

getDefaultNullCollation

public org.apache.calcite.config.NullCollation getDefaultNullCollation()

Specified by:

getDefaultNullCollation in interface org.apache.calcite.sql.validate.SqlValidator

setCallRewrite

public void setCallRewrite(boolean rewriteCalls)

Specified by:

setCallRewrite in interface org.apache.calcite.sql.validate.SqlValidator

shouldExpandIdentifiers

public boolean shouldExpandIdentifiers()

Specified by:

shouldExpandIdentifiers in interface org.apache.calcite.sql.validate.SqlValidator

shouldAllowIntermediateOrderBy

protected boolean shouldAllowIntermediateOrderBy()

createMatchRecognizeNameSpace

protected org.apache.calcite.sql.validate.MatchRecognizeNamespace createMatchRecognizeNameSpace(org.apache.calcite.sql.SqlMatchRecognize call,
                                                                                                org.apache.calcite.sql.SqlNode enclosingNode)

registerNamespace

protected void registerNamespace(org.apache.calcite.sql.validate.SqlValidatorScope usingScope,
                                 String alias,
                                 org.apache.calcite.sql.validate.SqlValidatorNamespace ns,
                                 boolean forceNullable)

Registers a new namespace, and adds it as a child of its parent scope. Derived class can override this method to tinker with namespaces as they are created.

Parameters:

usingScope - Parent scope (which will want to look for things in this namespace)

alias - Alias by which parent will refer to this namespace

ns - Namespace

forceNullable - Whether to force the type of namespace to be nullable

shouldAllowOverRelation

protected boolean shouldAllowOverRelation()

createSelectNamespace

protected org.apache.calcite.sql.validate.SelectNamespace createSelectNamespace(org.apache.calcite.sql.SqlSelect select,
                                                                                org.apache.calcite.sql.SqlNode enclosingNode)

Creates a namespace for a SELECT node. Derived class may override this factory method.

Parameters:

select - Select node

enclosingNode - Enclosing node

Returns:

Select namespace

createSetopNamespace

protected org.apache.calcite.sql.validate.SetopNamespace createSetopNamespace(org.apache.calcite.sql.SqlCall call,
                                                                              org.apache.calcite.sql.SqlNode enclosingNode)

Creates a namespace for a set operation (UNION, INTERSECT, or EXCEPT). Derived class may override this factory method.

Parameters:

call - Call to set operation

enclosingNode - Enclosing node

Returns:

Set operation namespace

isAggregate

public boolean isAggregate(org.apache.calcite.sql.SqlSelect select)

Specified by:

isAggregate in interface org.apache.calcite.sql.validate.SqlValidator

isNestedAggregateWindow

protected boolean isNestedAggregateWindow(org.apache.calcite.sql.SqlNode node)

isOverAggregateWindow

protected boolean isOverAggregateWindow(org.apache.calcite.sql.SqlNode node)

getAggregate

protected org.apache.calcite.sql.SqlNode getAggregate(org.apache.calcite.sql.SqlSelect select)

Returns the parse tree node (GROUP BY, HAVING, or an aggregate function call) that causes select to be an aggregate query, or null if it is not an aggregate query.

The node is useful context for error messages, but you cannot assume that the node is the only aggregate function.

isAggregate

public boolean isAggregate(org.apache.calcite.sql.SqlNode selectNode)

Specified by:

isAggregate in interface org.apache.calcite.sql.validate.SqlValidator

validateIdentifier

public void validateIdentifier(org.apache.calcite.sql.SqlIdentifier id,
                               org.apache.calcite.sql.validate.SqlValidatorScope scope)

Specified by:

validateIdentifier in interface org.apache.calcite.sql.validate.SqlValidator

validateLiteral

public void validateLiteral(org.apache.calcite.sql.SqlLiteral literal)

Specified by:

validateLiteral in interface org.apache.calcite.sql.validate.SqlValidator

validateIntervalQualifier

public void validateIntervalQualifier(org.apache.calcite.sql.SqlIntervalQualifier qualifier)

Specified by:

validateIntervalQualifier in interface org.apache.calcite.sql.validate.SqlValidator

validateFrom

protected void validateFrom(org.apache.calcite.sql.SqlNode node,
                            org.apache.calcite.rel.type.RelDataType targetRowType,
                            org.apache.calcite.sql.validate.SqlValidatorScope scope)

Validates the FROM clause of a query, or (recursively) a child node of the FROM clause: AS, OVER, JOIN, VALUES, or sub-query.

Parameters:

node - Node in FROM clause, typically a table or derived table

targetRowType - Desired row type of this expression, or unknownType if not fussy. Must not be null.

scope - Scope

validateOver

protected void validateOver(org.apache.calcite.sql.SqlCall call,
                            org.apache.calcite.sql.validate.SqlValidatorScope scope)

validateJoin

protected void validateJoin(org.apache.calcite.sql.SqlJoin join,
                            org.apache.calcite.sql.validate.SqlValidatorScope scope)

validateSelect

protected void validateSelect(org.apache.calcite.sql.SqlSelect select,
                              org.apache.calcite.rel.type.RelDataType targetRowType)

Validates a SELECT statement.

Parameters:

select - Select statement

targetRowType - Desired row type, must not be null, may be the data type 'unknown'.

validateModality

public boolean validateModality(org.apache.calcite.sql.SqlSelect select,
                                org.apache.calcite.sql.validate.SqlModality modality,
                                boolean fail)

Specified by:

validateModality in interface org.apache.calcite.sql.validate.SqlValidator

validateWindowClause

protected void validateWindowClause(org.apache.calcite.sql.SqlSelect select)

validateWith

public void validateWith(org.apache.calcite.sql.SqlWith with,
                         org.apache.calcite.sql.validate.SqlValidatorScope scope)

Specified by:

validateWith in interface org.apache.calcite.sql.validate.SqlValidator

validateWithItem

public void validateWithItem(org.apache.calcite.sql.SqlWithItem withItem)

Specified by:

validateWithItem in interface org.apache.calcite.sql.validate.SqlValidator

validateSequenceValue

public void validateSequenceValue(org.apache.calcite.sql.validate.SqlValidatorScope scope,
                                  org.apache.calcite.sql.SqlIdentifier id)

Specified by:

validateSequenceValue in interface org.apache.calcite.sql.validate.SqlValidator

getWithScope

public org.apache.calcite.sql.validate.SqlValidatorScope getWithScope(org.apache.calcite.sql.SqlNode withItem)

Specified by:

getWithScope in interface org.apache.calcite.sql.validate.SqlValidator

validateOrderList

protected void validateOrderList(org.apache.calcite.sql.SqlSelect select)

Validates the ORDER BY clause of a SELECT statement.

Parameters:

select - Select statement

expandOrderExpr

public org.apache.calcite.sql.SqlNode expandOrderExpr(org.apache.calcite.sql.SqlSelect select,
                                                      org.apache.calcite.sql.SqlNode orderExpr)

Specified by:

expandOrderExpr in interface org.apache.calcite.sql.validate.SqlValidator

validateGroupClause

protected void validateGroupClause(org.apache.calcite.sql.SqlSelect select)

Validates the GROUP BY clause of a SELECT statement. This method is called even if no GROUP BY clause is present.

validateWhereClause

protected void validateWhereClause(org.apache.calcite.sql.SqlSelect select)

validateWhereOrOn

protected void validateWhereOrOn(org.apache.calcite.sql.validate.SqlValidatorScope scope,
                                 org.apache.calcite.sql.SqlNode condition,
                                 String clause)

validateHavingClause

protected void validateHavingClause(org.apache.calcite.sql.SqlSelect select)

validateSelectList

protected org.apache.calcite.rel.type.RelDataType validateSelectList(org.apache.calcite.sql.SqlNodeList selectItems,
                                                                     org.apache.calcite.sql.SqlSelect select,
                                                                     org.apache.calcite.rel.type.RelDataType targetRowType)

createTargetRowType

protected org.apache.calcite.rel.type.RelDataType createTargetRowType(org.apache.calcite.sql.validate.SqlValidatorTable table,
                                                                      org.apache.calcite.sql.SqlNodeList targetColumnList,
                                                                      boolean append)

Derives a row-type for INSERT and UPDATE operations.

Parameters:

table - Target table for INSERT/UPDATE

targetColumnList - List of target columns, or null if not specified

append - Whether to append fields to those in baseRowType

Returns:

Rowtype

validateInsert

public void validateInsert(org.apache.calcite.sql.SqlInsert insert)

Specified by:

validateInsert in interface org.apache.calcite.sql.validate.SqlValidator

getLogicalTargetRowType

protected org.apache.calcite.rel.type.RelDataType getLogicalTargetRowType(org.apache.calcite.rel.type.RelDataType targetRowType,
                                                                          org.apache.calcite.sql.SqlInsert insert)

getLogicalSourceRowType

protected org.apache.calcite.rel.type.RelDataType getLogicalSourceRowType(org.apache.calcite.rel.type.RelDataType sourceRowType,
                                                                          org.apache.calcite.sql.SqlInsert insert)

checkTypeAssignment

protected void checkTypeAssignment(org.apache.calcite.rel.type.RelDataType sourceRowType,
                                   org.apache.calcite.rel.type.RelDataType targetRowType,
                                   org.apache.calcite.sql.SqlNode query)

validateDelete

public void validateDelete(org.apache.calcite.sql.SqlDelete call)

Specified by:

validateDelete in interface org.apache.calcite.sql.validate.SqlValidator

validateUpdate

public void validateUpdate(org.apache.calcite.sql.SqlUpdate call)

Specified by:

validateUpdate in interface org.apache.calcite.sql.validate.SqlValidator

validateMerge

public void validateMerge(org.apache.calcite.sql.SqlMerge call)

Specified by:

validateMerge in interface org.apache.calcite.sql.validate.SqlValidator

validateValues

protected void validateValues(org.apache.calcite.sql.SqlCall node,
                              org.apache.calcite.rel.type.RelDataType targetRowType,
                              org.apache.calcite.sql.validate.SqlValidatorScope scope)

Validates a VALUES clause.

Parameters:

node - Values clause

targetRowType - Row type which expression must conform to

scope - Scope within which clause occurs

validateDataType

public void validateDataType(org.apache.calcite.sql.SqlDataTypeSpec dataType)

Specified by:

validateDataType in interface org.apache.calcite.sql.validate.SqlValidator

validateDynamicParam

public void validateDynamicParam(org.apache.calcite.sql.SqlDynamicParam dynamicParam)

Specified by:

validateDynamicParam in interface org.apache.calcite.sql.validate.SqlValidator

getValidationErrorFunction

public org.apache.calcite.sql.validate.SqlValidatorImpl.ValidationErrorFunction getValidationErrorFunction()

newValidationError

public org.apache.calcite.runtime.CalciteContextException newValidationError(org.apache.calcite.sql.SqlNode node,
                                                                             org.apache.calcite.runtime.Resources.ExInst<org.apache.calcite.sql.validate.SqlValidatorException> e)

Specified by:

newValidationError in interface org.apache.calcite.sql.validate.SqlValidator

getWindowByName

protected org.apache.calcite.sql.SqlWindow getWindowByName(org.apache.calcite.sql.SqlIdentifier id,
                                                           org.apache.calcite.sql.validate.SqlValidatorScope scope)

resolveWindow

public org.apache.calcite.sql.SqlWindow resolveWindow(org.apache.calcite.sql.SqlNode windowOrRef,
                                                      org.apache.calcite.sql.validate.SqlValidatorScope scope,
                                                      boolean populateBounds)

Specified by:

resolveWindow in interface org.apache.calcite.sql.validate.SqlValidator

getOriginal

public org.apache.calcite.sql.SqlNode getOriginal(org.apache.calcite.sql.SqlNode expr)

setOriginal

public void setOriginal(org.apache.calcite.sql.SqlNode expr,
                        org.apache.calcite.sql.SqlNode original)

validateWindow

public void validateWindow(org.apache.calcite.sql.SqlNode windowOrId,
                           org.apache.calcite.sql.validate.SqlValidatorScope scope,
                           org.apache.calcite.sql.SqlCall call)

Specified by:

validateWindow in interface org.apache.calcite.sql.validate.SqlValidator

validateMatchRecognize

public void validateMatchRecognize(org.apache.calcite.sql.SqlCall call)

Specified by:

validateMatchRecognize in interface org.apache.calcite.sql.validate.SqlValidator

validateAggregateParams

public void validateAggregateParams(org.apache.calcite.sql.SqlCall aggCall,
                                    org.apache.calcite.sql.SqlNode filter,
                                    org.apache.calcite.sql.validate.SqlValidatorScope scope)

Specified by:

validateAggregateParams in interface org.apache.calcite.sql.validate.SqlValidator

validateCall

public void validateCall(org.apache.calcite.sql.SqlCall call,
                         org.apache.calcite.sql.validate.SqlValidatorScope scope)

Specified by:

validateCall in interface org.apache.calcite.sql.validate.SqlValidator

validateFeature

protected void validateFeature(org.apache.calcite.runtime.Feature feature,
                               org.apache.calcite.sql.parser.SqlParserPos context)

Validates that a particular feature is enabled. By default, all features are enabled; subclasses may override this method to be more discriminating.

Parameters:

feature - feature being used, represented as a resource instance

context - parser position context for error reporting, or null if

expand

public org.apache.calcite.sql.SqlNode expand(org.apache.calcite.sql.SqlNode expr,
                                             org.apache.calcite.sql.validate.SqlValidatorScope scope)

Specified by:

expand in interface org.apache.calcite.sql.validate.SqlValidator

expandGroupByOrHavingExpr

public org.apache.calcite.sql.SqlNode expandGroupByOrHavingExpr(org.apache.calcite.sql.SqlNode expr,
                                                                org.apache.calcite.sql.validate.SqlValidatorScope scope,
                                                                org.apache.calcite.sql.SqlSelect select,
                                                                boolean havingExpression)

isSystemField

public boolean isSystemField(org.apache.calcite.rel.type.RelDataTypeField field)

Specified by:

isSystemField in interface org.apache.calcite.sql.validate.SqlValidator

getFieldOrigins

public List<List<String>> getFieldOrigins(org.apache.calcite.sql.SqlNode sqlQuery)

Specified by:

getFieldOrigins in interface org.apache.calcite.sql.validate.SqlValidator

getParameterRowType

public org.apache.calcite.rel.type.RelDataType getParameterRowType(org.apache.calcite.sql.SqlNode sqlQuery)

Specified by:

getParameterRowType in interface org.apache.calcite.sql.validate.SqlValidator

validateColumnListParams

public void validateColumnListParams(org.apache.calcite.sql.SqlFunction function,
                                     List<org.apache.calcite.rel.type.RelDataType> argTypes,
                                     List<org.apache.calcite.sql.SqlNode> operands)

Specified by:

validateColumnListParams in interface org.apache.calcite.sql.validate.SqlValidator