diff options
Diffstat (limited to 'mdbc-server/src/main/java/org/onap/music/mdbc/query/QueryProcessor.java')
-rw-r--r-- | mdbc-server/src/main/java/org/onap/music/mdbc/query/QueryProcessor.java | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/mdbc-server/src/main/java/org/onap/music/mdbc/query/QueryProcessor.java b/mdbc-server/src/main/java/org/onap/music/mdbc/query/QueryProcessor.java index a31a2a0..6d6c661 100644 --- a/mdbc-server/src/main/java/org/onap/music/mdbc/query/QueryProcessor.java +++ b/mdbc-server/src/main/java/org/onap/music/mdbc/query/QueryProcessor.java @@ -35,6 +35,7 @@ import org.apache.calcite.sql.SqlInsert; import org.apache.calcite.sql.SqlJoin; import org.apache.calcite.sql.SqlKind; import org.apache.calcite.sql.SqlNode; +import org.apache.calcite.sql.SqlOrderBy; import org.apache.calcite.sql.SqlSelect; import org.apache.calcite.sql.SqlUpdate; import org.apache.calcite.sql.fun.SqlInOperator; @@ -122,6 +123,9 @@ public class QueryProcessor { case SELECT: parseSelect((SqlSelect) sqlNode, tableOpsMap); break; + case ORDER_BY: + parseSelect((SqlSelect)((SqlOrderBy) sqlNode).query, tableOpsMap); + break; default: logger.error("Unhandled sql query type " + sqlNode.getKind() +" for query " + query); } |