Github user JamesRTaylor commented on a diff in the pull request:
https://github.com/apache/phoenix/pull/34#discussion_r23275183
--- 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 --
Yes, I think it's better to only check for a match in the visitLeave (see
comment about not having to specialize all visitLeave methods, but relying on
overriding a wrapGroupByExpression method instead).
---
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.
---
