Yingyi Bu has uploaded a new change for review.
https://asterix-gerrit.ics.uci.edu/971
Change subject: Support SELECT (*)?
......................................................................
Support SELECT (*)?
Change-Id: Ifa77431912670b55387fd5a722c2184341400a50
---
M
asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/SqlppExpressionToPlanTranslator.java
A
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/from/from.1.ddl.sqlpp
A
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/from/from.2.update.sqlpp
A
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/from/from.3.query.sqlpp
A
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/group_by/group_by.1.ddl.sqlpp
A
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/group_by/group_by.2.update.sqlpp
A
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/group_by/group_by.3.query.sqlpp
A
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/join/join.1.ddl.sqlpp
A
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/join/join.2.update.sqlpp
A
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/join/join.3.query.sqlpp
A
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/mixed/mixed.1.ddl.sqlpp
A
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/mixed/mixed.2.update.sqlpp
A
asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/mixed/mixed.3.query.sqlpp
A
asterixdb/asterix-app/src/test/resources/runtimets/results/select-star/from/from.1.adm
A
asterixdb/asterix-app/src/test/resources/runtimets/results/select-star/group_by/group_by.1.adm
A
asterixdb/asterix-app/src/test/resources/runtimets/results/select-star/join/join.1.adm
A
asterixdb/asterix-app/src/test/resources/runtimets/results/select-star/mixed/mixed.1.adm
M asterixdb/asterix-app/src/test/resources/runtimets/testsuite_sqlpp.xml
M
asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/rewrites/SqlppQueryRewriter.java
M
asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/rewrites/visitor/InlineColumnAliasVisitor.java
M
asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/util/SqlppVariableUtil.java
M
asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/visitor/CheckSql92AggregateVisitor.java
M
asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/visitor/base/AbstractSqlppSimpleExpressionVisitor.java
M asterixdb/asterix-lang-sqlpp/src/main/javacc/SQLPP.jj
24 files changed, 641 insertions(+), 38 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/71/971/1
diff --git
a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/SqlppExpressionToPlanTranslator.java
b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/SqlppExpressionToPlanTranslator.java
index 410da06..dc61687 100644
---
a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/SqlppExpressionToPlanTranslator.java
+++
b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/SqlppExpressionToPlanTranslator.java
@@ -28,8 +28,10 @@
import org.apache.asterix.lang.common.base.Clause.ClauseType;
import org.apache.asterix.lang.common.base.Expression;
import org.apache.asterix.lang.common.base.Expression.Kind;
+import org.apache.asterix.lang.common.clause.GroupbyClause;
import org.apache.asterix.lang.common.clause.LetClause;
import org.apache.asterix.lang.common.expression.FieldBinding;
+import org.apache.asterix.lang.common.expression.GbyVariableExpressionPair;
import org.apache.asterix.lang.common.expression.LiteralExpr;
import org.apache.asterix.lang.common.expression.RecordConstructor;
import org.apache.asterix.lang.common.expression.VariableExpr;
@@ -52,6 +54,7 @@
import org.apache.asterix.lang.sqlpp.expression.IndependentSubquery;
import org.apache.asterix.lang.sqlpp.expression.SelectExpression;
import org.apache.asterix.lang.sqlpp.optype.JoinType;
+import org.apache.asterix.lang.sqlpp.util.SqlppVariableUtil;
import org.apache.asterix.lang.sqlpp.visitor.base.ISqlppVisitor;
import org.apache.asterix.metadata.declared.AqlMetadataProvider;
import org.apache.asterix.om.base.AInt32;
@@ -208,7 +211,8 @@
if (selectBlock.hasHavingClause()) {
currentOpRef = new
MutableObject<>(selectBlock.getHavingClause().accept(this, currentOpRef).first);
}
- return selectBlock.getSelectClause().accept(this, currentOpRef);
+ SelectClause selectClause = selectBlock.getSelectClause();
+ return processSelectClause(selectClause, selectBlock, currentOpRef);
}
@Override
@@ -453,38 +457,7 @@
@Override
public Pair<ILogicalOperator, LogicalVariable> visit(SelectClause
selectClause, Mutable<ILogicalOperator> tupSrc)
throws AsterixException {
- Expression returnExpr;
- if (selectClause.selectElement()) {
- returnExpr = selectClause.getSelectElement().getExpression();
- } else {
- List<Projection> projections =
selectClause.getSelectRegular().getProjections();
- List<FieldBinding> fieldBindings = new ArrayList<>();
- for (Projection projection : projections) {
- fieldBindings.add(new FieldBinding(new LiteralExpr(new
StringLiteral(projection.getName())),
- projection.getExpression()));
- }
- returnExpr = new RecordConstructor(fieldBindings);
- }
- Pair<ILogicalExpression, Mutable<ILogicalOperator>> eo =
langExprToAlgExpression(returnExpr, tupSrc);
- LogicalVariable returnVar;
- ILogicalOperator returnOperator;
- if (returnExpr.getKind() == Kind.VARIABLE_EXPRESSION) {
- VariableExpr varExpr = (VariableExpr) returnExpr;
- returnOperator = eo.second.getValue();
- returnVar = context.getVar(varExpr.getVar().getId());
- } else {
- returnVar = context.newVar();
- returnOperator = new AssignOperator(returnVar, new
MutableObject<ILogicalExpression>(eo.first));
- returnOperator.getInputs().add(eo.second);
- }
- if (selectClause.distinct()) {
- DistinctOperator distinctOperator = new
DistinctOperator(mkSingletonArrayList(
- new MutableObject<ILogicalExpression>(new
VariableReferenceExpression(returnVar))));
- distinctOperator.getInputs().add(new
MutableObject<ILogicalOperator>(returnOperator));
- return new Pair<>(distinctOperator, returnVar);
- } else {
- return new Pair<>(returnOperator, returnVar);
- }
+ throw new UnsupportedOperationException(ERR_MSG);
}
@Override
@@ -502,7 +475,7 @@
@Override
public Pair<ILogicalOperator, LogicalVariable> visit(Projection
projection, Mutable<ILogicalOperator> arg)
throws AsterixException {
- throw new IllegalStateException();
+ throw new UnsupportedOperationException(ERR_MSG);
}
private Pair<ILogicalOperator, LogicalVariable> produceSelectPlan(boolean
isSubquery,
@@ -542,4 +515,93 @@
}
}
+ // Generates the return expression for a select clause.
+ private Pair<ILogicalOperator, LogicalVariable>
processSelectClause(SelectClause selectClause,
+ SelectBlock selectBlock, Mutable<ILogicalOperator> tupSrc) throws
AsterixException {
+ Expression returnExpr;
+ if (selectClause.selectElement()) {
+ returnExpr = selectClause.getSelectElement().getExpression();
+ } else {
+ returnExpr = generateReturnExpr(selectClause, selectBlock);
+ }
+ Pair<ILogicalExpression, Mutable<ILogicalOperator>> eo =
langExprToAlgExpression(returnExpr, tupSrc);
+ LogicalVariable returnVar;
+ ILogicalOperator returnOperator;
+ if (returnExpr.getKind() == Kind.VARIABLE_EXPRESSION) {
+ VariableExpr varExpr = (VariableExpr) returnExpr;
+ returnOperator = eo.second.getValue();
+ returnVar = context.getVar(varExpr.getVar().getId());
+ } else {
+ returnVar = context.newVar();
+ returnOperator = new AssignOperator(returnVar, new
MutableObject<ILogicalExpression>(eo.first));
+ returnOperator.getInputs().add(eo.second);
+ }
+ if (selectClause.distinct()) {
+ DistinctOperator distinctOperator = new
DistinctOperator(mkSingletonArrayList(
+ new MutableObject<ILogicalExpression>(new
VariableReferenceExpression(returnVar))));
+ distinctOperator.getInputs().add(new
MutableObject<ILogicalOperator>(returnOperator));
+ return new Pair<>(distinctOperator, returnVar);
+ } else {
+ return new Pair<>(returnOperator, returnVar);
+ }
+ }
+
+ // Generates the return expression for a select clause.
+ private Expression generateReturnExpr(SelectClause selectClause,
SelectBlock selectBlock) {
+ SelectRegular selectRegular = selectClause.getSelectRegular();
+ List<FieldBinding> fieldBindings = new ArrayList<>();
+ List<Projection> projections = selectRegular.getProjections();
+ for (Projection projection : projections) {
+ if (projection.star()) {
+ if (selectBlock.hasGroupbyClause()) {
+
fieldBindings.addAll(getGroupBindings(selectBlock.getGroupbyClause()));
+ } else if (selectBlock.hasFromClause()) {
+
fieldBindings.addAll(getFromBindings(selectBlock.getFromClause()));
+ }
+ } else {
+ fieldBindings.add(new FieldBinding(new LiteralExpr(new
StringLiteral(projection.getName())),
+ projection.getExpression()));
+ }
+ }
+ return new RecordConstructor(fieldBindings);
+ }
+
+ // Generates all field bindings according to the from clause.
+ private List<FieldBinding> getFromBindings(FromClause fromClause) {
+ List<FieldBinding> fieldBindings = new ArrayList<>();
+ for (FromTerm fromTerm : fromClause.getFromTerms()) {
+ fieldBindings.add(getFieldBinding(fromTerm.getLeftVariable()));
+ if (fromTerm.hasPositionalVariable()) {
+
fieldBindings.add(getFieldBinding(fromTerm.getPositionalVariable()));
+ }
+ if (!fromTerm.hasCorrelateClauses()) {
+ continue;
+ }
+ for (AbstractBinaryCorrelateClause correlateClause :
fromTerm.getCorrelateClauses()) {
+
fieldBindings.add(getFieldBinding(correlateClause.getRightVariable()));
+ if (correlateClause.hasPositionalVariable()) {
+
fieldBindings.add(getFieldBinding(correlateClause.getPositionalVariable()));
+ }
+ }
+ }
+ return fieldBindings;
+ }
+
+ // Generates all field bindings according to the from clause.
+ private List<FieldBinding> getGroupBindings(GroupbyClause groupbyClause) {
+ List<FieldBinding> fieldBindings = new ArrayList<>();
+ for (GbyVariableExpressionPair pair : groupbyClause.getGbyPairList()) {
+ fieldBindings.add(getFieldBinding(pair.getVar()));
+ }
+ fieldBindings.add(getFieldBinding(groupbyClause.getGroupVar()));
+ return fieldBindings;
+ }
+
+ // Generates a field binding for a variable.
+ private FieldBinding getFieldBinding(VariableExpr var) {
+ LiteralExpr fieldName = new LiteralExpr(
+ new
StringLiteral(SqlppVariableUtil.toUserDefinedVariableName(var.getVar()).getValue()));
+ return new FieldBinding(fieldName, var);
+ }
+
}
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/from/from.1.ddl.sqlpp
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/from/from.1.ddl.sqlpp
new file mode 100644
index 0000000..dba927c
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/from/from.1.ddl.sqlpp
@@ -0,0 +1,76 @@
+/*
+ * 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.
+ */
+
+drop database tpch if exists;
+create database tpch;
+
+use tpch;
+
+
+create type tpch.LineItemType as
+ closed {
+ l_orderkey : int64,
+ l_partkey : int64,
+ l_suppkey : int64,
+ l_linenumber : int64,
+ l_quantity : int64,
+ l_extendedprice : double,
+ l_discount : double,
+ l_tax : double,
+ l_returnflag : string,
+ l_linestatus : string,
+ l_shipdate : string,
+ l_commitdate : string,
+ l_receiptdate : string,
+ l_shipinstruct : string,
+ l_shipmode : string,
+ l_comment : string
+}
+
+create type tpch.OrderType as
+ closed {
+ o_orderkey : int64,
+ o_custkey : int64,
+ o_orderstatus : string,
+ o_totalprice : double,
+ o_orderdate : string,
+ o_orderpriority : string,
+ o_clerk : string,
+ o_shippriority : int64,
+ o_comment : string
+}
+
+create type tpch.CustomerType as
+ closed {
+ c_custkey : int64,
+ c_name : string,
+ c_address : string,
+ c_nationkey : int64,
+ c_phone : string,
+ c_acctbal : double,
+ c_mktsegment : string,
+ c_comment : string
+}
+
+create table LineItem(LineItemType) primary key l_orderkey,l_linenumber;
+
+create table Orders(OrderType) primary key o_orderkey;
+
+create table Customer(CustomerType) primary key c_custkey;
+
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/from/from.2.update.sqlpp
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/from/from.2.update.sqlpp
new file mode 100644
index 0000000..dd4aa2f
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/from/from.2.update.sqlpp
@@ -0,0 +1,28 @@
+/*
+ * 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.
+ */
+
+use tpch;
+
+
+load table LineItem using localfs
((`path`=`asterix_nc1://data/tpch0.001/lineitem.tbl`),(`format`=`delimited-text`),(`delimiter`=`|`))
pre-sorted;
+
+load table Orders using localfs
((`path`=`asterix_nc1://data/tpch0.001/orders.tbl`),(`format`=`delimited-text`),(`delimiter`=`|`))
pre-sorted;
+
+load table Customer using localfs
((`path`=`asterix_nc1://data/tpch0.001/customer.tbl`),(`format`=`delimited-text`),(`delimiter`=`|`))
pre-sorted;
+
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/from/from.3.query.sqlpp
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/from/from.3.query.sqlpp
new file mode 100644
index 0000000..53fb0cf
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/from/from.3.query.sqlpp
@@ -0,0 +1,32 @@
+/*
+ * 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.
+ */
+
+USE tpch;
+
+
+SELECT *
+FROM Customer c,
+ Orders o,
+ LineItem l
+WHERE c_mktsegment = 'BUILDING' AND c_custkey = o_custkey
+ AND l_orderkey = o_orderkey AND o_orderdate < '1995-03-15'
+ AND l_shipdate > '1995-03-15'
+ORDER BY l_linenumber, l_orderkey
+LIMIT 3;
+
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/group_by/group_by.1.ddl.sqlpp
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/group_by/group_by.1.ddl.sqlpp
new file mode 100644
index 0000000..581b684
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/group_by/group_by.1.ddl.sqlpp
@@ -0,0 +1,34 @@
+/*
+ * 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.
+ */
+
+drop database tpch if exists;
+create database tpch;
+
+use tpch;
+
+
+create type tpch.RegionType as
+ closed {
+ r_regionkey : int32,
+ r_name : string,
+ r_comment : string
+}
+
+create table Regions_group_no_agg(RegionType) primary key r_regionkey;
+
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/group_by/group_by.2.update.sqlpp
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/group_by/group_by.2.update.sqlpp
new file mode 100644
index 0000000..7283894
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/group_by/group_by.2.update.sqlpp
@@ -0,0 +1,24 @@
+/*
+ * 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.
+ */
+
+use tpch;
+
+
+load table Regions_group_no_agg using localfs
((`path`=`asterix_nc1://data/tpch0.001/region.tbl`),(`format`=`delimited-text`),(`delimiter`=`|`))
pre-sorted;
+
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/group_by/group_by.3.query.sqlpp
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/group_by/group_by.3.query.sqlpp
new file mode 100644
index 0000000..4f0ddf4
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/group_by/group_by.3.query.sqlpp
@@ -0,0 +1,27 @@
+/*
+ * 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.
+ */
+
+USE tpch;
+
+
+SELECT *
+FROM Regions_group_no_agg AS r
+GROUP BY r_name AS name
+ORDER BY name
+;
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/join/join.1.ddl.sqlpp
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/join/join.1.ddl.sqlpp
new file mode 100644
index 0000000..dba927c
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/join/join.1.ddl.sqlpp
@@ -0,0 +1,76 @@
+/*
+ * 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.
+ */
+
+drop database tpch if exists;
+create database tpch;
+
+use tpch;
+
+
+create type tpch.LineItemType as
+ closed {
+ l_orderkey : int64,
+ l_partkey : int64,
+ l_suppkey : int64,
+ l_linenumber : int64,
+ l_quantity : int64,
+ l_extendedprice : double,
+ l_discount : double,
+ l_tax : double,
+ l_returnflag : string,
+ l_linestatus : string,
+ l_shipdate : string,
+ l_commitdate : string,
+ l_receiptdate : string,
+ l_shipinstruct : string,
+ l_shipmode : string,
+ l_comment : string
+}
+
+create type tpch.OrderType as
+ closed {
+ o_orderkey : int64,
+ o_custkey : int64,
+ o_orderstatus : string,
+ o_totalprice : double,
+ o_orderdate : string,
+ o_orderpriority : string,
+ o_clerk : string,
+ o_shippriority : int64,
+ o_comment : string
+}
+
+create type tpch.CustomerType as
+ closed {
+ c_custkey : int64,
+ c_name : string,
+ c_address : string,
+ c_nationkey : int64,
+ c_phone : string,
+ c_acctbal : double,
+ c_mktsegment : string,
+ c_comment : string
+}
+
+create table LineItem(LineItemType) primary key l_orderkey,l_linenumber;
+
+create table Orders(OrderType) primary key o_orderkey;
+
+create table Customer(CustomerType) primary key c_custkey;
+
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/join/join.2.update.sqlpp
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/join/join.2.update.sqlpp
new file mode 100644
index 0000000..dd4aa2f
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/join/join.2.update.sqlpp
@@ -0,0 +1,28 @@
+/*
+ * 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.
+ */
+
+use tpch;
+
+
+load table LineItem using localfs
((`path`=`asterix_nc1://data/tpch0.001/lineitem.tbl`),(`format`=`delimited-text`),(`delimiter`=`|`))
pre-sorted;
+
+load table Orders using localfs
((`path`=`asterix_nc1://data/tpch0.001/orders.tbl`),(`format`=`delimited-text`),(`delimiter`=`|`))
pre-sorted;
+
+load table Customer using localfs
((`path`=`asterix_nc1://data/tpch0.001/customer.tbl`),(`format`=`delimited-text`),(`delimiter`=`|`))
pre-sorted;
+
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/join/join.3.query.sqlpp
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/join/join.3.query.sqlpp
new file mode 100644
index 0000000..5eeee7c
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/join/join.3.query.sqlpp
@@ -0,0 +1,32 @@
+/*
+ * 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.
+ */
+
+USE tpch;
+
+
+SELECT *
+FROM Customer c
+JOIN Orders o ON c_custkey = o_custkey
+JOIN LineItem l ON l_orderkey = o_orderkey
+WHERE c_mktsegment = 'BUILDING'
+ AND o_orderdate < '1995-03-15'
+ AND l_shipdate > '1995-03-15'
+ORDER BY l_linenumber, l_orderkey
+LIMIT 3;
+
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/mixed/mixed.1.ddl.sqlpp
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/mixed/mixed.1.ddl.sqlpp
new file mode 100644
index 0000000..dba927c
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/mixed/mixed.1.ddl.sqlpp
@@ -0,0 +1,76 @@
+/*
+ * 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.
+ */
+
+drop database tpch if exists;
+create database tpch;
+
+use tpch;
+
+
+create type tpch.LineItemType as
+ closed {
+ l_orderkey : int64,
+ l_partkey : int64,
+ l_suppkey : int64,
+ l_linenumber : int64,
+ l_quantity : int64,
+ l_extendedprice : double,
+ l_discount : double,
+ l_tax : double,
+ l_returnflag : string,
+ l_linestatus : string,
+ l_shipdate : string,
+ l_commitdate : string,
+ l_receiptdate : string,
+ l_shipinstruct : string,
+ l_shipmode : string,
+ l_comment : string
+}
+
+create type tpch.OrderType as
+ closed {
+ o_orderkey : int64,
+ o_custkey : int64,
+ o_orderstatus : string,
+ o_totalprice : double,
+ o_orderdate : string,
+ o_orderpriority : string,
+ o_clerk : string,
+ o_shippriority : int64,
+ o_comment : string
+}
+
+create type tpch.CustomerType as
+ closed {
+ c_custkey : int64,
+ c_name : string,
+ c_address : string,
+ c_nationkey : int64,
+ c_phone : string,
+ c_acctbal : double,
+ c_mktsegment : string,
+ c_comment : string
+}
+
+create table LineItem(LineItemType) primary key l_orderkey,l_linenumber;
+
+create table Orders(OrderType) primary key o_orderkey;
+
+create table Customer(CustomerType) primary key c_custkey;
+
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/mixed/mixed.2.update.sqlpp
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/mixed/mixed.2.update.sqlpp
new file mode 100644
index 0000000..dd4aa2f
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/mixed/mixed.2.update.sqlpp
@@ -0,0 +1,28 @@
+/*
+ * 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.
+ */
+
+use tpch;
+
+
+load table LineItem using localfs
((`path`=`asterix_nc1://data/tpch0.001/lineitem.tbl`),(`format`=`delimited-text`),(`delimiter`=`|`))
pre-sorted;
+
+load table Orders using localfs
((`path`=`asterix_nc1://data/tpch0.001/orders.tbl`),(`format`=`delimited-text`),(`delimiter`=`|`))
pre-sorted;
+
+load table Customer using localfs
((`path`=`asterix_nc1://data/tpch0.001/customer.tbl`),(`format`=`delimited-text`),(`delimiter`=`|`))
pre-sorted;
+
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/mixed/mixed.3.query.sqlpp
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/mixed/mixed.3.query.sqlpp
new file mode 100644
index 0000000..95ac04e
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/select-star/mixed/mixed.3.query.sqlpp
@@ -0,0 +1,32 @@
+/*
+ * 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.
+ */
+
+USE tpch;
+
+
+SELECT c_custkey, *, o_orderkey
+FROM Customer c,
+ Orders o,
+ LineItem l
+WHERE c_mktsegment = 'BUILDING' AND c_custkey = o_custkey
+ AND l_orderkey = o_orderkey AND o_orderdate < '1995-03-15'
+ AND l_shipdate > '1995-03-15'
+ORDER BY l_linenumber, l_orderkey
+LIMIT 3;
+
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/results/select-star/from/from.1.adm
b/asterixdb/asterix-app/src/test/resources/runtimets/results/select-star/from/from.1.adm
new file mode 100644
index 0000000..fa3c0bf
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/results/select-star/from/from.1.adm
@@ -0,0 +1,3 @@
+{ "c": { "c_custkey": 73, "c_name": "Customer#000000073", "c_address":
"8IhIxreu4Ug6tt5mog4", "c_nationkey": 0, "c_phone": "10-473-439-3214",
"c_acctbal": 4288.5, "c_mktsegment": "BUILDING", "c_comment": "usual, unusual
packages sleep busily along the furiou" }, "o": { "o_orderkey": 1637,
"o_custkey": 73, "o_orderstatus": "F", "o_totalprice": 180912.15,
"o_orderdate": "1995-02-08", "o_orderpriority": "4-NOT SPECIFIED", "o_clerk":
"Clerk#000000189", "o_shippriority": 0, "o_comment": " final accounts. blithely
silent ideas cajole bravely. carefully express " }, "l": { "l_orderkey": 1637,
"l_partkey": 86, "l_suppkey": 7, "l_linenumber": 1, "l_quantity": 49,
"l_extendedprice": 48317.92, "l_discount": 0.02, "l_tax": 0.03, "l_returnflag":
"N", "l_linestatus": "F", "l_shipdate": "1995-06-08", "l_commitdate":
"1995-04-19", "l_receiptdate": "1995-07-01", "l_shipinstruct": "COLLECT COD",
"l_shipmode": "REG AIR", "l_comment": ". blithely i" } }
+{ "c": { "c_custkey": 64, "c_name": "Customer#000000064", "c_address":
"MbCeGY20kaKK3oalJD,OT", "c_nationkey": 3, "c_phone": "13-558-731-7204",
"c_acctbal": -646.64, "c_mktsegment": "BUILDING", "c_comment": "structions
after the quietly ironic theodolites cajole be" }, "o": { "o_orderkey": 4423,
"o_custkey": 64, "o_orderstatus": "F", "o_totalprice": 4913.06, "o_orderdate":
"1995-02-17", "o_orderpriority": "5-LOW", "o_clerk": "Clerk#000000888",
"o_shippriority": 0, "o_comment": "excuses are ruthless" }, "l": {
"l_orderkey": 4423, "l_partkey": 150, "l_suppkey": 9, "l_linenumber": 1,
"l_quantity": 3, "l_extendedprice": 3150.45, "l_discount": 0.03, "l_tax": 0.0,
"l_returnflag": "A", "l_linestatus": "F", "l_shipdate": "1995-03-22",
"l_commitdate": "1995-04-06", "l_receiptdate": "1995-04-19", "l_shipinstruct":
"NONE", "l_shipmode": "TRUCK", "l_comment": " final theodolites nag after the
bli" } }
+{ "c": { "c_custkey": 32, "c_name": "Customer#000000032", "c_address":
"jD2xZzi UmId,DCtNBLXKj9q0Tlp2iQ6ZcO3J", "c_nationkey": 15, "c_phone":
"25-430-914-2194", "c_acctbal": 3471.53, "c_mktsegment": "BUILDING",
"c_comment": "cial ideas. final, furious requests across the e" }, "o": {
"o_orderkey": 998, "o_custkey": 32, "o_orderstatus": "F", "o_totalprice":
65269.38, "o_orderdate": "1994-11-26", "o_orderpriority": "4-NOT SPECIFIED",
"o_clerk": "Clerk#000000956", "o_shippriority": 0, "o_comment": "ronic
dolphins. ironic, bold ideas haggle furiously furious" }, "l": { "l_orderkey":
998, "l_partkey": 181, "l_suppkey": 2, "l_linenumber": 2, "l_quantity": 7,
"l_extendedprice": 7568.26, "l_discount": 0.1, "l_tax": 0.05, "l_returnflag":
"R", "l_linestatus": "F", "l_shipdate": "1995-03-24", "l_commitdate":
"1995-01-18", "l_receiptdate": "1995-04-03", "l_shipinstruct": "NONE",
"l_shipmode": "MAIL", "l_comment": "nic deposits. even asym" } }
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/results/select-star/group_by/group_by.1.adm
b/asterixdb/asterix-app/src/test/resources/runtimets/results/select-star/group_by/group_by.1.adm
new file mode 100644
index 0000000..a26aeb8
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/results/select-star/group_by/group_by.1.adm
@@ -0,0 +1,5 @@
+{ "name": "AFRICA", "$1": [ { "r": { "r_regionkey": 0, "r_name": "AFRICA",
"r_comment": "lar deposits. blithely final packages cajole. regular waters are
final requests. regular accounts are according to " } } ] }
+{ "name": "AMERICA", "$1": [ { "r": { "r_regionkey": 1, "r_name": "AMERICA",
"r_comment": "hs use ironic, even requests. s" } } ] }
+{ "name": "ASIA", "$1": [ { "r": { "r_regionkey": 2, "r_name": "ASIA",
"r_comment": "ges. thinly even pinto beans ca" } } ] }
+{ "name": "EUROPE", "$1": [ { "r": { "r_regionkey": 3, "r_name": "EUROPE",
"r_comment": "ly final courts cajole furiously final excuse" } } ] }
+{ "name": "MIDDLE EAST", "$1": [ { "r": { "r_regionkey": 4, "r_name": "MIDDLE
EAST", "r_comment": "uickly special accounts cajole carefully blithely close
requests. carefully final asymptotes haggle furiousl" } } ] }
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/results/select-star/join/join.1.adm
b/asterixdb/asterix-app/src/test/resources/runtimets/results/select-star/join/join.1.adm
new file mode 100644
index 0000000..fa3c0bf
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/results/select-star/join/join.1.adm
@@ -0,0 +1,3 @@
+{ "c": { "c_custkey": 73, "c_name": "Customer#000000073", "c_address":
"8IhIxreu4Ug6tt5mog4", "c_nationkey": 0, "c_phone": "10-473-439-3214",
"c_acctbal": 4288.5, "c_mktsegment": "BUILDING", "c_comment": "usual, unusual
packages sleep busily along the furiou" }, "o": { "o_orderkey": 1637,
"o_custkey": 73, "o_orderstatus": "F", "o_totalprice": 180912.15,
"o_orderdate": "1995-02-08", "o_orderpriority": "4-NOT SPECIFIED", "o_clerk":
"Clerk#000000189", "o_shippriority": 0, "o_comment": " final accounts. blithely
silent ideas cajole bravely. carefully express " }, "l": { "l_orderkey": 1637,
"l_partkey": 86, "l_suppkey": 7, "l_linenumber": 1, "l_quantity": 49,
"l_extendedprice": 48317.92, "l_discount": 0.02, "l_tax": 0.03, "l_returnflag":
"N", "l_linestatus": "F", "l_shipdate": "1995-06-08", "l_commitdate":
"1995-04-19", "l_receiptdate": "1995-07-01", "l_shipinstruct": "COLLECT COD",
"l_shipmode": "REG AIR", "l_comment": ". blithely i" } }
+{ "c": { "c_custkey": 64, "c_name": "Customer#000000064", "c_address":
"MbCeGY20kaKK3oalJD,OT", "c_nationkey": 3, "c_phone": "13-558-731-7204",
"c_acctbal": -646.64, "c_mktsegment": "BUILDING", "c_comment": "structions
after the quietly ironic theodolites cajole be" }, "o": { "o_orderkey": 4423,
"o_custkey": 64, "o_orderstatus": "F", "o_totalprice": 4913.06, "o_orderdate":
"1995-02-17", "o_orderpriority": "5-LOW", "o_clerk": "Clerk#000000888",
"o_shippriority": 0, "o_comment": "excuses are ruthless" }, "l": {
"l_orderkey": 4423, "l_partkey": 150, "l_suppkey": 9, "l_linenumber": 1,
"l_quantity": 3, "l_extendedprice": 3150.45, "l_discount": 0.03, "l_tax": 0.0,
"l_returnflag": "A", "l_linestatus": "F", "l_shipdate": "1995-03-22",
"l_commitdate": "1995-04-06", "l_receiptdate": "1995-04-19", "l_shipinstruct":
"NONE", "l_shipmode": "TRUCK", "l_comment": " final theodolites nag after the
bli" } }
+{ "c": { "c_custkey": 32, "c_name": "Customer#000000032", "c_address":
"jD2xZzi UmId,DCtNBLXKj9q0Tlp2iQ6ZcO3J", "c_nationkey": 15, "c_phone":
"25-430-914-2194", "c_acctbal": 3471.53, "c_mktsegment": "BUILDING",
"c_comment": "cial ideas. final, furious requests across the e" }, "o": {
"o_orderkey": 998, "o_custkey": 32, "o_orderstatus": "F", "o_totalprice":
65269.38, "o_orderdate": "1994-11-26", "o_orderpriority": "4-NOT SPECIFIED",
"o_clerk": "Clerk#000000956", "o_shippriority": 0, "o_comment": "ronic
dolphins. ironic, bold ideas haggle furiously furious" }, "l": { "l_orderkey":
998, "l_partkey": 181, "l_suppkey": 2, "l_linenumber": 2, "l_quantity": 7,
"l_extendedprice": 7568.26, "l_discount": 0.1, "l_tax": 0.05, "l_returnflag":
"R", "l_linestatus": "F", "l_shipdate": "1995-03-24", "l_commitdate":
"1995-01-18", "l_receiptdate": "1995-04-03", "l_shipinstruct": "NONE",
"l_shipmode": "MAIL", "l_comment": "nic deposits. even asym" } }
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/results/select-star/mixed/mixed.1.adm
b/asterixdb/asterix-app/src/test/resources/runtimets/results/select-star/mixed/mixed.1.adm
new file mode 100644
index 0000000..38aff12
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/results/select-star/mixed/mixed.1.adm
@@ -0,0 +1,3 @@
+{ "c_custkey": 73, "c": { "c_custkey": 73, "c_name": "Customer#000000073",
"c_address": "8IhIxreu4Ug6tt5mog4", "c_nationkey": 0, "c_phone":
"10-473-439-3214", "c_acctbal": 4288.5, "c_mktsegment": "BUILDING",
"c_comment": "usual, unusual packages sleep busily along the furiou" }, "o": {
"o_orderkey": 1637, "o_custkey": 73, "o_orderstatus": "F", "o_totalprice":
180912.15, "o_orderdate": "1995-02-08", "o_orderpriority": "4-NOT SPECIFIED",
"o_clerk": "Clerk#000000189", "o_shippriority": 0, "o_comment": " final
accounts. blithely silent ideas cajole bravely. carefully express " }, "l": {
"l_orderkey": 1637, "l_partkey": 86, "l_suppkey": 7, "l_linenumber": 1,
"l_quantity": 49, "l_extendedprice": 48317.92, "l_discount": 0.02, "l_tax":
0.03, "l_returnflag": "N", "l_linestatus": "F", "l_shipdate": "1995-06-08",
"l_commitdate": "1995-04-19", "l_receiptdate": "1995-07-01", "l_shipinstruct":
"COLLECT COD", "l_shipmode": "REG AIR", "l_comment": ". blithely i" },
"o_orderkey": 1637 }
+{ "c_custkey": 64, "c": { "c_custkey": 64, "c_name": "Customer#000000064",
"c_address": "MbCeGY20kaKK3oalJD,OT", "c_nationkey": 3, "c_phone":
"13-558-731-7204", "c_acctbal": -646.64, "c_mktsegment": "BUILDING",
"c_comment": "structions after the quietly ironic theodolites cajole be" },
"o": { "o_orderkey": 4423, "o_custkey": 64, "o_orderstatus": "F",
"o_totalprice": 4913.06, "o_orderdate": "1995-02-17", "o_orderpriority":
"5-LOW", "o_clerk": "Clerk#000000888", "o_shippriority": 0, "o_comment":
"excuses are ruthless" }, "l": { "l_orderkey": 4423, "l_partkey": 150,
"l_suppkey": 9, "l_linenumber": 1, "l_quantity": 3, "l_extendedprice": 3150.45,
"l_discount": 0.03, "l_tax": 0.0, "l_returnflag": "A", "l_linestatus": "F",
"l_shipdate": "1995-03-22", "l_commitdate": "1995-04-06", "l_receiptdate":
"1995-04-19", "l_shipinstruct": "NONE", "l_shipmode": "TRUCK", "l_comment": "
final theodolites nag after the bli" }, "o_orderkey": 4423 }
+{ "c_custkey": 32, "c": { "c_custkey": 32, "c_name": "Customer#000000032",
"c_address": "jD2xZzi UmId,DCtNBLXKj9q0Tlp2iQ6ZcO3J", "c_nationkey": 15,
"c_phone": "25-430-914-2194", "c_acctbal": 3471.53, "c_mktsegment": "BUILDING",
"c_comment": "cial ideas. final, furious requests across the e" }, "o": {
"o_orderkey": 998, "o_custkey": 32, "o_orderstatus": "F", "o_totalprice":
65269.38, "o_orderdate": "1994-11-26", "o_orderpriority": "4-NOT SPECIFIED",
"o_clerk": "Clerk#000000956", "o_shippriority": 0, "o_comment": "ronic
dolphins. ironic, bold ideas haggle furiously furious" }, "l": { "l_orderkey":
998, "l_partkey": 181, "l_suppkey": 2, "l_linenumber": 2, "l_quantity": 7,
"l_extendedprice": 7568.26, "l_discount": 0.1, "l_tax": 0.05, "l_returnflag":
"R", "l_linestatus": "F", "l_shipdate": "1995-03-24", "l_commitdate":
"1995-01-18", "l_receiptdate": "1995-04-03", "l_shipinstruct": "NONE",
"l_shipmode": "MAIL", "l_comment": "nic deposits. even asym" }, "o_orderkey":
998 }
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/testsuite_sqlpp.xml
b/asterixdb/asterix-app/src/test/resources/runtimets/testsuite_sqlpp.xml
index a34689e..70ddbeb 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/testsuite_sqlpp.xml
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/testsuite_sqlpp.xml
@@ -4494,6 +4494,28 @@
</test-case>
-->
</test-group>
+ <test-group name="select-star">
+ <test-case FilePath="select-star">
+ <compilation-unit name="group_by">
+ <output-dir compare="Text">group_by</output-dir>
+ </compilation-unit>
+ </test-case>
+ <test-case FilePath="select-star">
+ <compilation-unit name="from">
+ <output-dir compare="Text">from</output-dir>
+ </compilation-unit>
+ </test-case>
+ <test-case FilePath="select-star">
+ <compilation-unit name="join">
+ <output-dir compare="Text">join</output-dir>
+ </compilation-unit>
+ </test-case>
+ <test-case FilePath="select-star">
+ <compilation-unit name="mixed">
+ <output-dir compare="Text">mixed</output-dir>
+ </compilation-unit>
+ </test-case>
+ </test-group>
<test-group name="semistructured">
<test-case FilePath="semistructured">
<compilation-unit name="count-nullable">
diff --git
a/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/rewrites/SqlppQueryRewriter.java
b/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/rewrites/SqlppQueryRewriter.java
index fab5c07..9b78d41 100644
---
a/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/rewrites/SqlppQueryRewriter.java
+++
b/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/rewrites/SqlppQueryRewriter.java
@@ -296,7 +296,9 @@
@Override
public Void visit(Projection projection, Void arg) throws
AsterixException {
- projection.getExpression().accept(this, arg);
+ if (!projection.star()) {
+ projection.getExpression().accept(this, arg);
+ }
return null;
}
diff --git
a/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/rewrites/visitor/InlineColumnAliasVisitor.java
b/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/rewrites/visitor/InlineColumnAliasVisitor.java
index 2918a90..6b74d3f 100644
---
a/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/rewrites/visitor/InlineColumnAliasVisitor.java
+++
b/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/rewrites/visitor/InlineColumnAliasVisitor.java
@@ -130,6 +130,9 @@
@Override
public Void visit(Projection projection, Boolean
overwriteWithGbyKeyVarRefs) throws AsterixException {
+ if (projection.star()) {
+ return null;
+ }
projection.getExpression().accept(this, overwriteWithGbyKeyVarRefs);
VariableExpr columnAlias = new VariableExpr(
SqlppVariableUtil.toInternalVariableIdentifier(projection.getName()));
diff --git
a/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/util/SqlppVariableUtil.java
b/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/util/SqlppVariableUtil.java
index 12a2d20..ebf4b06 100644
---
a/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/util/SqlppVariableUtil.java
+++
b/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/util/SqlppVariableUtil.java
@@ -52,8 +52,10 @@
public static VarIdentifier toUserDefinedVariableName(String varName) {
if (varName.startsWith(USER_VAR_PREFIX)) {
return new VarIdentifier(varName.substring(1));
+ } else {
+ // At the user land, system generated variable is $-prefixed.
+ return new VarIdentifier(USER_VAR_PREFIX + varName.substring(1));
}
- return new VarIdentifier(varName);
}
public static String toUserDefinedName(String varName) {
diff --git
a/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/visitor/CheckSql92AggregateVisitor.java
b/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/visitor/CheckSql92AggregateVisitor.java
index 7c46d73..669b0a8 100644
---
a/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/visitor/CheckSql92AggregateVisitor.java
+++
b/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/visitor/CheckSql92AggregateVisitor.java
@@ -201,6 +201,9 @@
@Override
public Boolean visit(Projection projection, ILangExpression
parentSelectBlock) throws AsterixException {
+ if (projection.star()) {
+ return false;
+ }
return projection.getExpression().accept(this, parentSelectBlock);
}
diff --git
a/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/visitor/base/AbstractSqlppSimpleExpressionVisitor.java
b/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/visitor/base/AbstractSqlppSimpleExpressionVisitor.java
index 262b260..2098156 100644
---
a/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/visitor/base/AbstractSqlppSimpleExpressionVisitor.java
+++
b/asterixdb/asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/visitor/base/AbstractSqlppSimpleExpressionVisitor.java
@@ -107,7 +107,9 @@
@Override
public Expression visit(Projection projection, ILangExpression arg) throws
AsterixException {
- projection.setExpression(projection.getExpression().accept(this, arg));
+ if (!projection.star()) {
+ projection.setExpression(projection.getExpression().accept(this,
arg));
+ }
return null;
}
diff --git a/asterixdb/asterix-lang-sqlpp/src/main/javacc/SQLPP.jj
b/asterixdb/asterix-lang-sqlpp/src/main/javacc/SQLPP.jj
index f587e50..9e35fc9 100644
--- a/asterixdb/asterix-lang-sqlpp/src/main/javacc/SQLPP.jj
+++ b/asterixdb/asterix-lang-sqlpp/src/main/javacc/SQLPP.jj
@@ -2358,7 +2358,7 @@
| <MUL> {star = true; }
)
{
- if(name == null){
+ if(!star && name == null){
name =
SqlppVariableUtil.toUserDefinedName(ExpressionToVariableUtil.getGeneratedIdentifier(expr));
}
return new Projection(expr, name, star, exprStar);
--
To view, visit https://asterix-gerrit.ics.uci.edu/971
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: Ifa77431912670b55387fd5a722c2184341400a50
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Yingyi Bu <[email protected]>
