Class DropViewPlan

server/src/main/java/io/crate/planner/DropViewPlan.java:37–66

import io.crate.planner.operators.SubQueryResults;

public class DropViewPlan implements Plan {

    private final AnalyzedDropView dropView;

    DropViewPlan(AnalyzedDropView dropView) {
        this.dropView = dropView;
    }

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

    @Override
    public void executeOrFail(DependencyCarrier dependencies,
                              PlannerContext plannerContext,
                              RowConsumer consumer,
                              Row params,
                              SubQueryResults subQueryResults) {
        DropViewRequest request = new DropViewRequest(dropView.views(), dropView.ifExists());
        Function<DropViewResponse, Row> responseToRow = resp -> {
            if (dropView.ifExists() || resp.missing().isEmpty()) {
                return new Row1((long) dropView.views().size() - resp.missing().size());
            }
            throw new RelationsUnknown(resp.missing());
        };
        dependencies.client().execute(TransportDropView.ACTION, request)
            .whenComplete(new OneRowActionListener<>(consumer, responseToRow));
    }
}