Method initialize

src/Databases/MySQL/MaterializedMySQLSyncThreadManager.cpp:737–779

}

void MaterializedMySQLSyncThreadManager::initialize()
{
    setSyncType(MaterializedMySQLSyncType::PreparingSync);
    auto manager_metadata = catalog->getOrSetMaterializedMySQLManagerMetadata(storage_id);

    /// Update materialized_tables_list with include/exclude setting
    updateSyncTableList();

    if (manager_metadata->dumped_first_time())
    {
        updateResyncTables();
        manager_metadata->clear_materialized_tables();
        for (const auto & name: materialized_tables_list)
            manager_metadata->add_materialized_tables(name);
        catalog->updateMaterializedMySQLManagerMetadata(storage_id, *manager_metadata);
    }
    else
        initializeMaterializedMySQL(manager_metadata);

    if (materialized_tables_list.empty())
    {
        LOG_WARNING(log, "No tables found in mysql to be synced");
        return;
    }

    /// here the tables have been created and dumped for the first time
    std::lock_guard resync_lock(resync_mutex);
    std::lock_guard lock(status_info_mutex);

    threads_info.clear();
    for (const auto & table : materialized_tables_list)
    {
        threads_info.emplace_back();
        auto & thread_info = threads_info.back();
        thread_info = std::make_shared<SyncThreadScheduleInfo>();

        thread_info->assigned_materialized_table = table;

        if (manager_metadata->dumped_first_time() && !resync_tables.count(table))
            getBinlogMetadataFromCatalog(thread_info->binlog_info, table);
    }
    resync_table_task->activateAndSchedule();
}

void MaterializedMySQLSyncThreadManager::createReadonlyReplicaClient(const String & replica_info, const String & mysql_database_name)
{