Method quickExec

server/src/main/java/io/crate/session/Session.java:239–293

Execute a query in one step, avoiding the parse/bind/execute/sync procedure. Opposed to using parse/bind/execute/sync this method is thread-safe. This is used for system calls and statement_timeout is not accounted for here.

(String statement, ResultReceiver<?> resultReceiver, Row params)

     * This is used for system calls and statement_timeout is not accounted for here.
     */
    public void quickExec(String statement, ResultReceiver<?> resultReceiver, Row params) {
        lastStmt = statement;
        CoordinatorTxnCtx txnCtx = new CoordinatorTxnCtx(sessionSettings);
        validateStatementLength(statement);
        Statement parsedStmt = SqlParser.createStatement(statement);
        AnalyzedStatement analyzedStatement = analyzer.analyze(
            parsedStmt,
            sessionSettings,
            ParamTypeHints.EMPTY,
            cursors
        );
        RoutingProvider routingProvider = new RoutingProvider(Randomness.get().nextInt(), planner.getAwarenessAttributes());
        mostRecentJobID = UUIDs.dirtyUUID();
        final UUID jobId = mostRecentJobID;
        PlannerContext plannerContext = planner.createContext(
            routingProvider,
            jobId,
            txnCtx,
            0,
            params,
            cursors,
            currentTransactionState,
            TimeoutToken.noopToken()
        );
        Plan plan;
        try {
            plan = planner.plan(analyzedStatement, plannerContext);
        } catch (Throwable t) {
            jobsLogs.logPreExecutionFailure(jobId, id, statement, SQLExceptions.messageOf(t), sessionSettings.sessionUser());
            throw t;
        }

        StatementClassifier.Classification classification = StatementClassifier.classify(plan);
        jobsLogs.logExecutionStart(jobId, id, statement, sessionSettings.sessionUser(), classification);
        JobsLogsUpdateListener jobsLogsUpdateListener = new JobsLogsUpdateListener(jobId, jobsLogs);
        if (!analyzedStatement.isWriteOperation()) {
            resultReceiver = new RetryOnFailureResultReceiver<>(
                tempErrorRetryCount,
                executor.clusterService(),
                resultReceiver,
                jobId,
                (newJobId, retryResultReceiver) -> retryQuery(
                    newJobId,
                    analyzedStatement,
                    routingProvider,
                    new RowConsumerToResultReceiver(retryResultReceiver, 0, jobsLogsUpdateListener),
                    params,
                    txnCtx,
                    TimeoutToken.noopToken()
                )
            );
        }
        RowConsumerToResultReceiver consumer = new RowConsumerToResultReceiver(resultReceiver, 0, jobsLogsUpdateListener);
        Plan.execute(plan, executor, plannerContext, consumer, params, SubQueryResults.EMPTY);
    }

    private void retryQuery(UUID jobId,
                            AnalyzedStatement stmt,