Class AlterServerPlan

server/src/main/java/io/crate/planner/AlterServerPlan.java:51–154

import io.crate.planner.operators.SubQueryResults;

public class AlterServerPlan implements Plan {

    private final ForeignDataWrappers foreignDataWrappers;
    private final AnalyzedAlterServer alterServer;

    public AlterServerPlan(ForeignDataWrappers foreignDataWrappers,
                           AnalyzedAlterServer alterServer) {
        this.foreignDataWrappers = foreignDataWrappers;
        this.alterServer = alterServer;
    }

    @Override
    public StatementType type() {
        return StatementType.DDL;
    }

    @Override
    public void executeOrFail(DependencyCarrier dependencies,
                              PlannerContext plannerContext,
                              RowConsumer consumer,
                              Row params,
                              SubQueryResults subQueryResults) throws Exception {

        CoordinatorTxnCtx transactionContext = plannerContext.transactionContext();
        Function<Symbol, Object> convert = new SymbolEvaluator(
            transactionContext,
            plannerContext.nodeContext(),
            subQueryResults
        ).bind(params);

        Metadata metadata = plannerContext.clusterState().metadata();
        ServersMetadata servers = metadata.custom(ServersMetadata.TYPE);
        if (servers == null) {
            throw new ResourceNotFoundException(
                String.format(Locale.ENGLISH, "Server `%s` not found", alterServer.name()));
        }
        ServersMetadata.Server server = servers.get(alterServer.name());

        ForeignDataWrapper fdw = foreignDataWrappers.get(server.fdw());

        HashSet<String> optionNames = new HashSet<>();
        Settings.Builder optionsAdded = Settings.builder();
        Settings.Builder optionsUpdated = Settings.builder();
        List<String> optionsRemoved = new ArrayList<>();

        Map<String, Setting<?>> mandatoryOptions = fdw.mandatoryServerOptions().stream()
            .collect(Collectors.toMap(Setting::getKey, Function.identity()));

        for (var option : alterServer.options()) {
            if (mandatoryOptions.get(option.key()) == null) {
                throw new IllegalArgumentException(String.format(
                    Locale.ENGLISH,
                    "Unsupported server options for foreign data wrapper `%s`: %s. Valid options are: %s",
                    server.fdw(),
                    option.key(),
                    fdw.mandatoryServerOptions().stream()
                        .map(Setting::getKey)
                        .collect(Collectors.joining(", "))