Method execute

src/Interpreters/InterpreterDropStatsQuery.cpp:37–99

}

BlockIO InterpreterDropStatsQuery::execute()
{
    auto context = getContext();
    auto query = query_ptr->as<const ASTDropStatsQuery>();
    auto catalog = Statistics::createCatalogAdaptor(context);

    auto cache_policy = query->cache_policy;

    if (cache_policy == StatisticsCachePolicy::Default)
    {
        // use context settings
        cache_policy = context->getSettingsRef().statistics_cache_policy;
    }

    // when enable_memory_catalog is true, we won't use cache
    if (catalog->getSettingsRef().enable_memory_catalog)
    {
        if (cache_policy != StatisticsCachePolicy::Default)
            throw Exception("memory catalog don't support cache policy", ErrorCodes::BAD_ARGUMENTS);
    }


    if (query->table == "__reset")
    {
        if (cache_policy != StatisticsCachePolicy::Cache)
            throw Exception("__reset is only valid at cache mode", ErrorCodes::NOT_IMPLEMENTED);

        // dummy means all
        StatsTableIdentifier dummy(StorageID("", "__reset", UUID{}));
        catalog->invalidateClusterStatsCache(dummy);

        return {};
    }

    catalog->checkHealth(/*is_write=*/true);

    auto proxy = Statistics::createCachedStatsProxy(catalog, cache_policy);
    auto db = context->resolveDatabase(query->database);

    if (!DatabaseCatalog::instance().isDatabaseExist(db, context))
    {
        auto msg = fmt::format(FMT_STRING("Unknown database ({})"), db);
        throw Exception(msg, ErrorCodes::UNKNOWN_DATABASE);
    }

    auto tables = getTablesFromAST(context, query);


    if (tables.size() == 1 && !query->columns.empty())
    {
        auto table = tables[0];
        dropStatsColumns(context, table, query->columns, cache_policy, true);
    }
    else
    {
        for (auto table : tables)
        {
            dropStatsTable(context, table, cache_policy, true);