Method flushBuffersData

src/Databases/MySQL/MaterializeMySQLSyncThread.cpp:354–364

}

void MaterializeMySQLSyncThread::flushBuffersData(Buffers & buffers, MaterializeMetadata & metadata)
{
    if (buffers.data.empty())
        return;

    auto position = client.getPosition();

    metadata.transaction(position, [&]() { buffers.commit(getContext(), position); });

    LOG_INFO(log, "Finish flushing and MySQL executed position: \n {}", dumpPosition(position));
}

static inline void fillSignColumnsData(Block & data, Int8 sign_value, size_t fill_size)
{