Github user twdsilva commented on a diff in the pull request:
https://github.com/apache/phoenix/pull/34#discussion_r23267987
--- Diff:
phoenix-core/src/main/java/org/apache/phoenix/compile/IndexColumnExpressionCompiler.java
---
@@ -0,0 +1,302 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.phoenix.compile;
+
+import java.sql.SQLException;
+import java.util.Collections;
+import java.util.List;
+
+import org.apache.hadoop.hbase.client.Scan;
+import org.apache.phoenix.compile.GroupByCompiler.GroupBy;
+import org.apache.phoenix.expression.ColumnExpression;
+import org.apache.phoenix.expression.Expression;
+import org.apache.phoenix.jdbc.PhoenixConnection;
+import org.apache.phoenix.parse.AddParseNode;
+import org.apache.phoenix.parse.AndParseNode;
+import org.apache.phoenix.parse.ArrayAllComparisonNode;
+import org.apache.phoenix.parse.ArrayAnyComparisonNode;
+import org.apache.phoenix.parse.ArrayElemRefNode;
+import org.apache.phoenix.parse.CaseParseNode;
+import org.apache.phoenix.parse.CastParseNode;
+import org.apache.phoenix.parse.ColumnDef;
+import org.apache.phoenix.parse.ColumnParseNode;
+import org.apache.phoenix.parse.ComparisonParseNode;
+import org.apache.phoenix.parse.DivideParseNode;
+import org.apache.phoenix.parse.FunctionParseNode;
+import org.apache.phoenix.parse.ModulusParseNode;
+import org.apache.phoenix.parse.MultiplyParseNode;
+import org.apache.phoenix.parse.NamedTableNode;
+import org.apache.phoenix.parse.NotParseNode;
+import org.apache.phoenix.parse.OrParseNode;
+import org.apache.phoenix.parse.ParseNode;
+import org.apache.phoenix.parse.RowValueConstructorParseNode;
+import org.apache.phoenix.parse.SQLParser;
+import org.apache.phoenix.parse.StringConcatParseNode;
+import org.apache.phoenix.parse.SubtractParseNode;
+import org.apache.phoenix.parse.TableName;
+import org.apache.phoenix.schema.PColumn;
+import org.apache.phoenix.schema.PTable;
+import org.apache.phoenix.schema.PTableType;
+import org.apache.phoenix.util.IndexUtil;
+
+/**
+ * Visitor that checks if nodes other than ColumnParseNode are present as
+ * an expression in an index. If the expression is present, then the node
is
+ * not visited but processed as a ColumnParseNode.
+ */
+public class IndexColumnExpressionCompiler extends ExpressionCompiler {
+
+ IndexColumnExpressionCompiler(StatementContext context) {
+ super(context);
+ }
+
+ IndexColumnExpressionCompiler(StatementContext context, boolean
resolveViewConstants) {
+ super(context, resolveViewConstants);
+ }
+
+ IndexColumnExpressionCompiler(StatementContext context, GroupBy
groupBy) {
+ super(context, groupBy);
+ }
+
+ IndexColumnExpressionCompiler(StatementContext context, GroupBy
groupBy, boolean resolveViewConstants) {
+ super(context, groupBy, resolveViewConstants);
+ }
+
+ /**
+ * Returns the compiled expression
+ *
+ * @param node
+ * data table parse node
+ */
+ private Expression getExpression(ParseNode node) throws SQLException {
+ PhoenixConnection connection = this.context.getConnection();
+ PTable indexTable = this.context.getCurrentTable().getTable();
+ NamedTableNode dataTableNode = NamedTableNode.create(null,
TableName.create(indexTable.getParentSchemaName().getString(),
+ indexTable.getParentTableName().getString()),
Collections.<ColumnDef>emptyList());
+ ColumnResolver resolver = FromCompiler.getResolver(dataTableNode,
connection);
+ StatementContext context = new
StatementContext(this.context.getStatement(), resolver, new Scan(), new
SequenceManager(this.context.getStatement()));
+ ExpressionCompiler expressionCompiler = new
ExpressionCompiler(context);
+ return node.accept(expressionCompiler);
+ }
+
+ /**
+ * @return true if current table is an index and there is an expression
that matches the given node
+ */
+ private boolean matchesIndexedExpression(ParseNode node) throws
SQLException {
+ if
(context.getCurrentTable().getTable().getType()!=PTableType.INDEX) {
+ return false;
+ }
+ DataTableNodeRewriter statementRewriter = new
DataTableNodeRewriter();
+ ParseNode dataTableParseNode = node.accept(statementRewriter);
+ Expression dataTableExpression =
getExpression(dataTableParseNode);
+ // if the node matches a column expression
+ if
(ColumnExpression.class.isAssignableFrom(dataTableExpression.getClass())) {
+ return false;
+ }
+ for ( PColumn column :
this.context.getCurrentTable().getTable().getColumns()) {
--- End diff --
In IndexColumnExpressionCompiler, all the visitEnter methods check if the
ParseNode matches an expression in the index, if there is a match it returns
false for visitEnter. Then in the visitLeave I call convertAndVisitParseNode
which creates a ColumnParseNode for the column that contains the matching
expression and then calls the visit method on the column parse node.
Instead of this, should I only check if there is a match in the visitLeave ?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
