Method simpleQuery

server/src/main/java/io/crate/session/Session.java:629–642

(String queryString)

    }

    public List<Statement> simpleQuery(String queryString) {
        try {
            return SqlParser.createStatementsForSimpleQuery(
                queryString,
                str -> PgArrayParser.parse(
                    str,
                    bytes -> new String(bytes, StandardCharsets.UTF_8)
                )
            );
        } catch (Throwable t) {
            jobsLogs.logPreExecutionFailure(UUIDs.dirtyUUID(), id, queryString, SQLExceptions.messageOf(t), sessionSettings.sessionUser());
            throw t;
        }
    }

    private void addStatementTimeout(CompletableFuture<?> result, TimeoutToken timeoutToken) {
        long durationNs = timeoutToken.disable();