Method bulkExec

server/src/main/java/io/crate/session/Session.java:717–782

(List<DeferredExecution> toExec)

    }

    private CompletableFuture<?> bulkExec(List<DeferredExecution> toExec) {
        assert !toExec.isEmpty() : "Must have at least 1 deferred execution for bulk exec";
        mostRecentJobID = UUIDs.dirtyUUID();
        final UUID jobId = mostRecentJobID;
        var routingProvider = new RoutingProvider(Randomness.get().nextInt(), planner.getAwarenessAttributes());
        var txnCtx = new CoordinatorTxnCtx(sessionSettings);
        PreparedStmt firstPreparedStatement = toExec.get(0).portal().preparedStmt();
        TimeoutToken timeoutToken = firstPreparedStatement.timeoutToken();
        timeoutToken.enable();

        var plannerContext = planner.createContext(
            routingProvider,
            jobId,
            txnCtx,
            0,
            null,
            cursors,
            currentTransactionState,
            timeoutToken
        );


        AnalyzedStatement analyzedStatement = firstPreparedStatement.analyzedStatement();
        lastStmt = firstPreparedStatement.rawStatement();

        Plan plan;
        try {
            plan = planner.plan(analyzedStatement, plannerContext);
            timeoutToken.check("bulkExec:plan");
        } catch (Throwable t) {
            jobsLogs.logPreExecutionFailure(
                jobId,
                id,
                firstPreparedStatement.rawStatement(),
                SQLExceptions.messageOf(t),
                sessionSettings.sessionUser());
            throw t;
        }
        jobsLogs.logExecutionStart(
            jobId,
            id,
            firstPreparedStatement.rawStatement(),
            sessionSettings.sessionUser(),
            StatementClassifier.classify(plan)
        );

        var bulkArgs = Lists.map(toExec, x -> (Row) new RowN(x.portal().params().toArray()));
        CompletableFuture<BulkResponse> result = plan.executeBulk(
            executor,
            plannerContext,
            bulkArgs,
            SubQueryResults.EMPTY
        );
        List<CompletableFuture<?>> resultReceiverFutures = Lists.map(toExec, x -> x.resultReceiver().completionFuture());
        CompletableFuture<Void> allResultReceivers = CompletableFuture.allOf(resultReceiverFutures.toArray(new CompletableFuture[0]));

        result
            .thenAccept(bulkResp -> emitRowCountsToResultReceivers(jobId, jobsLogs, toExec, bulkResp, 0, 0))