commit dc43ac87078f01365a71d12135240886d8f9bc25
author Dmitry Lychagin <dmitry.lychagin@couchbase.com> Thu Jan 09 16:48:30 2020 -0800
committer Dmitry Lychagin <dmitry.lychagin@couchbase.com> Fri Jan 10 18:29:05 2020 +0000
tree 175f4c8c196dd38caf72679abc98d86c86ca5b8c
parent 2a0848e2f38edc79072004b7838398056be807b3

[NO ISSUE][COMP] Minor QueryTranslator refactoring

- user model changes: no
- storage format changes: no
- interface changes: no

Details:
- Allow product extensions to override
  QueryTranslator.validateStatements()

Change-Id: Ib04f09df6f8073ca3e146e7eb73d6cd703c01641
Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/4644
Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Reviewed-by: Dmitry Lychagin <dmitry.lychagin@couchbase.com>
Reviewed-by: Michael Blow <mblow@apache.org>

asterixdb/asterix-app/src/main/java/org/apache/asterix/app/translator/QueryTranslator.java

diff --git a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/translator/QueryTranslator.java b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/translator/QueryTranslator.java
index dcea54a..b35d022 100644
--- a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/translator/QueryTranslator.java
+++ b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/translator/QueryTranslator.java
@@ -279,8 +279,7 @@
 
     @Override
     public void compileAndExecute(IHyracksClientConnection hcc, IRequestParameters requestParameters) throws Exception {
-        validateStatements(statements, requestParameters.isMultiStatement(),
-                requestParameters.getStatementCategoryRestrictionMask());
+        validateStatements(requestParameters);
         trackRequest(requestParameters);
         int resultSetIdCounter = 0;
         FileSplit outputFile = null;
@@ -3087,6 +3086,11 @@
         appCtx.getRequestTracker().track(clientRequest);
     }
 
+    protected void validateStatements(IRequestParameters requestParameters) throws CompilationException {
+        validateStatements(statements, requestParameters.isMultiStatement(),
+                requestParameters.getStatementCategoryRestrictionMask());
+    }
+
     public static void validateStatements(List<Statement> statements, boolean allowMultiStatement,
             int stmtCategoryRestrictionMask) throws CompilationException {
         if (!allowMultiStatement) {