Function performAtomicRename

src/Client/ClientBase.cpp:218–243

}

void performAtomicRename(const DB::ASTPtr & parsed_query, const String & out_file)
{
    if (const auto * query_with_output = dynamic_cast<const DB::ASTQueryWithOutput *>(parsed_query.get()))
    {
        if (query_with_output->isOutfileTruncate() && query_with_output->out_file)
        {
            const auto & tmp_file_node = query_with_output->out_file->as<DB::ASTLiteral &>();
            String tmp_file = tmp_file_node.value.safeGet<std::string>();

            try
            {
                fs::rename(tmp_file, out_file);
            }
            catch (const fs::filesystem_error & e)
            {
                /// Clean up temporary file
                if (fs::exists(tmp_file))
                    fs::remove(tmp_file);

                throw DB::Exception(DB::ErrorCodes::CANNOT_WRITE_TO_FILE,
                    "Cannot rename temporary file {} to {}: {}",
                    tmp_file, out_file, e.what());
            }
        }
    }
}

}