Class DropSchemaPlan

server/src/main/java/io/crate/planner/DropSchemaPlan.java:33–58

import io.crate.sql.tree.DropSchema;

public class DropSchemaPlan implements Plan {

    private final AnalyzedDropSchema dropSchema;

    public DropSchemaPlan(AnalyzedDropSchema dropSchema) {
        this.dropSchema = dropSchema;
    }

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

    @Override
    public void executeOrFail(DependencyCarrier dependencies,
                              PlannerContext plannerContext,
                              RowConsumer consumer,
                              Row params,
                              SubQueryResults subQueryResults) throws Exception {
        DropSchema schema = dropSchema.dropSchema();
        DropSchemaRequest request = new DropSchemaRequest(schema.names(), schema.ifExists(), schema.mode());
        dependencies.client()
            .execute(TransportDropSchema.ACTION, request)
            .whenComplete(OneRowActionListener.oneIfAcknowledged(consumer));
    }
}