Method bind

server/src/main/java/io/crate/session/Session.java:403–453

(String portalName,
                     String statementName,
                     List<Object> params,
                     FormatCodes.@Nullable FormatCode[] resultFormatCodes)

    }

    public void bind(String portalName,
                     String statementName,
                     List<Object> params,
                     FormatCodes.@Nullable FormatCode[] resultFormatCodes) {
        if (LOGGER.isDebugEnabled()) {
            LOGGER.debug("method=bind portalName={} statementName={} params={}", portalName, statementName, params);
        }
        PreparedStmt preparedStmt;
        try {
            preparedStmt = getSafeStmt(statementName);
        } catch (Throwable t) {
            jobsLogs.logPreExecutionFailure(UUIDs.dirtyUUID(), id, "", SQLExceptions.messageOf(t), sessionSettings.sessionUser());
            throw t;
        }

        Portal portal = new Portal(
            portalName,
            preparedStmt,
            params,
            resultFormatCodes);
        Portal oldPortal = portals.put(portalName, portal);
        if (oldPortal != null) {
            // According to the wire protocol spec named portals should be removed explicitly and only
            // unnamed portals are implicitly closed/overridden.
            // We don't comply with the spec because we allow batching of statements, see #execute
            oldPortal.closeActiveConsumer();
        }

        // Clients might try to describe a declared query, need to store a portal to allow that.
        if (preparedStmt.analyzedStatement() instanceof AnalyzedDeclare analyzedDeclare) {
            Declare declare = analyzedDeclare.declare();
            String cursorName = declare.cursorName();
            if (!cursorName.equals(portalName)) {
                var parameterTypes = ParameterTypes.extract(analyzedDeclare.query()).toArray(new DataType[0]);
                PreparedStmt preparedQuery = new PreparedStmt(
                    declare.query(),
                    analyzedDeclare.query(),
                    SqlFormatter.formatSql(declare.query()),
                    parameterTypes,
                    preparedStmt.timeoutToken()
                );
                Portal queryPortal = new Portal(
                    cursorName,
                    preparedQuery,
                    List.of(),
                    resultFormatCodes
                );
                portals.put(cursorName, queryPortal);
            }
        }
    }

    public DescribeResult describe(char type, String portalOrStatement) {
        if (LOGGER.isDebugEnabled()) {