korlov42 commented on a change in pull request #712:
URL: https://github.com/apache/ignite-3/pull/712#discussion_r834348541
##########
File path:
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/PrepareServiceImpl.java
##########
@@ -62,43 +64,49 @@ public void stop() throws Exception {
}
/** {@inheritDoc} */
- @Override public QueryPlan prepareSingle(SqlNode sqlNode, PlanningContext
ctx) {
- try {
- assert single(sqlNode);
-
- ctx.planner().reset();
-
- if (SqlKind.DDL.contains(sqlNode.getKind())) {
- return prepareDdl(sqlNode, ctx);
- }
-
- switch (sqlNode.getKind()) {
- case SELECT:
- case ORDER_BY:
- case WITH:
- case VALUES:
- case UNION:
- case EXCEPT:
- case INTERSECT:
- return prepareQuery(sqlNode, ctx);
-
- case INSERT:
- case DELETE:
- case UPDATE:
- case MERGE:
- return prepareDml(sqlNode, ctx);
-
- case EXPLAIN:
- return prepareExplain(sqlNode, ctx);
-
- default:
- throw new IgniteInternalException("Unsupported operation ["
- + "sqlNodeKind=" + sqlNode.getKind() + "; "
- + "querySql=\"" + ctx.query() + "\"]");
- }
- } catch (ValidationException | CalciteContextException e) {
- throw new IgniteInternalException("Failed to validate query. " +
e.getMessage(), e);
- }
+ @Override
+ public CompletableFuture<QueryPlan> prepare(SqlNode sqlNode,
BaseQueryContext ctx) {
+ return CompletableFuture.completedFuture(null)
Review comment:
done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
