Function loadSystemDatabaseImpl

src/Interpreters/loadMetadata.cpp:342–373

}

static void loadSystemDatabaseImpl(ContextMutablePtr context, const String & database_name, const String & default_engine)
{
    /// If it is already loaded.
    if (DatabaseCatalog::instance().isDatabaseExist(database_name))
        return;

    auto default_db_disk = Context::getGlobalContextInstance()->getDatabaseDisk();
    auto metadata_file = DatabaseCatalog::getMetadataFilePath(database_name);
    auto metadata_tmp_file = DatabaseCatalog::getMetadataTmpFilePath(database_name);
    default_db_disk->removeFileIfExists(metadata_tmp_file);

    LOG_TEST(
        getLogger("loadSystemDatabase"),
        "metadata_file_path {}, existsFile {}",
        metadata_file,
        default_db_disk->existsFile(metadata_file));
    if (default_db_disk->existsFile(metadata_file))
    {
        /// 'has_force_restore_data_flag' is true, to not fail on loading query_log table, if it is corrupted.
        loadDatabase(context, database_name, metadata_file, true);
    }
    else
    {
        checkUnsupportedVersion(context, database_name);
        /// Initialize system database manually
        String database_create_query = "CREATE DATABASE ";
        database_create_query += database_name;
        database_create_query += " ENGINE=";
        database_create_query += default_engine;
        executeCreateQuery(database_create_query, context, database_name, "<no file>", true, true);
    }
}

static void convertOrdinaryDatabaseToAtomic(LoggerPtr log, ContextMutablePtr context, const DatabasePtr & database,
                                            const String & name, const String tmp_name)