Function readDbStats

src/Interpreters/InterpreterShowStatsQuery.cpp:177–242

}

void readDbStats(ContextPtr context, const String & original_db_name, const String & path)
{
    std::ifstream fin(path, std::ios::binary);
    DbStats db_stats;
    db_stats.ParseFromIstream(&fin);

    auto version = db_stats.has_version() ? db_stats.version() : DbStats_Version_V1;
    if (version == DbStats_Version_V1)
    {
        version = DbStats_Version_V2;
    }
    if (version != PROTO_VERSION)
    {
        throw Exception("stats version is incorrect", ErrorCodes::LOGICAL_ERROR);
    }

    auto db_name = original_db_name;
    auto catalog = createCatalogAdaptor(context);
    auto logger = &Poco::Logger::get("load stats");

    auto load_ts = AutoStats::convertToDateTime64(AutoStats::nowTimePoint());
    for (auto & table_pb : db_stats.tables())
    {
        auto table_name = table_pb.table_name();
        auto table_id_opt = catalog->getTableIdByName(db_name, table_name);
        if (!table_id_opt)
        {
            auto msg = "table " + table_name + " not exist in database " + db_name;
            logger->warning(msg);
            continue;
        }

        StatisticsCollector collector(context, catalog, table_id_opt.value());

        {
            StatsCollection collection;
            for (auto & [k, v] : table_pb.blobs())
            {
                auto tag = static_cast<StatisticsTag>(k);
                auto obj = createStatisticsBase(tag, v);
                if (obj)
                    collection[tag] = std::move(obj);
            }
            StatisticsCollector::TableStats table_stats;
            table_stats.readFromCollection(collection);
            table_stats.basic->setTimestamp(load_ts);
            collector.setTableStats(std::move(table_stats));
        }

        for (auto & column_pb : table_pb.columns())
        {
            auto column_name = column_pb.column_name();
            StatsCollection collection;
            for (auto & [k, v] : column_pb.blobs())
            {
                auto tag = static_cast<StatisticsTag>(k);
                auto obj = createStatisticsBase(tag, v);
                collection[tag] = std::move(obj);