Method getTableDataBuffer

src/Databases/MySQL/MaterializeMySQLSyncThread.cpp:821–844

}

MaterializeMySQLSyncThread::Buffers::BufferAndUniqueColumnsPtr MaterializeMySQLSyncThread::Buffers::getTableDataBuffer(
    const String & table_name, ContextPtr context)
{
    const auto & iterator = data.find(table_name);
    if (iterator == data.end())
    {
        StoragePtr storage = DatabaseCatalog::instance().getTable(StorageID(database, table_name + "_" + table_suffix), context);

        const StorageInMemoryMetadata & metadata = storage->getInMemoryMetadata();
        BufferAndUniqueColumnsPtr & buffer_and_unique_columns = data.try_emplace(
            table_name, std::make_shared<BufferAndUniqueColumns>(metadata.getSampleBlockWithDeleteFlag(), std::vector<size_t>{})).first->second;

        /// We need to use unique key instead of sorting key as user could use table override func
        Names required_for_unique_key = metadata.getColumnsRequiredForUniqueKey();

        for (const auto & required_name_for_unique_key : required_for_unique_key)
            buffer_and_unique_columns->second.emplace_back(
                buffer_and_unique_columns->first.getPositionByName(required_name_for_unique_key));

        return buffer_and_unique_columns;
    }

    return iterator->second;
}

String MaterializeMySQLSyncThread::Buffers::printBuffersInfo()
{