Function writeDbStats

src/Interpreters/InterpreterShowStatsQuery.cpp:129–169

}

void writeDbStats(ContextPtr context, const String & db_name, const String & path)
{
    DbStats db_stats;
    db_stats.set_db_name(db_name);
    db_stats.set_version(PROTO_VERSION);
    auto catalog = createCatalogAdaptor(context);
    auto tables = catalog->getAllTablesID(db_name);
    for (auto & table : tables)
    {
        StatisticsCollector collector(context, catalog, table);
        collector.readAllFromCatalog();
        auto table_collection = collector.getTableStats().writeToCollection();
        if (table_collection.empty())
        {
            continue;
        }

        auto table_pb = db_stats.add_tables();
        table_pb->set_table_name(table.getTableName());
        for (auto & [k, v] : table_collection)
        {
            table_pb->mutable_blobs()->operator[](static_cast<int64_t>(k)) = v->serialize();
        }
        for (auto & [col_name, col_stats] : collector.getColumnsStats())
        {
            auto column_pb = table_pb->add_columns();
            auto column_collection = col_stats.writeToCollection();
            if (column_collection.empty())
            {
                continue;
            }
            column_pb->set_column_name(col_name);
            for (auto & [k, v] : column_collection)
            {
                column_pb->mutable_blobs()->operator[](static_cast<int64_t>(k)) = v->serialize();
            }
        }
    }
    std::ofstream fout(path, std::ios::binary);
    db_stats.SerializeToOstream(&fout);
}
void writeDbStatsToJson(ContextPtr context, const String & db_name, const String & folder)
{
    DDLDumper ddl_dumper(folder);