Method transaction

src/Databases/MySQL/MaterializeMetadata.cpp:241–269

}

void MaterializeMetadata::transaction(const MySQLReplication::Position & position, const std::function<void()> & fun)
{
    binlog_file = position.binlog_name;
    binlog_position = position.binlog_pos;
    executed_gtid_set = position.gtid_sets.toString();

    if (!persistent_path.empty())
    {
        String persistent_tmp_path = persistent_path + ".tmp";

        {
            WriteBufferFromFile out(persistent_tmp_path, DBMS_DEFAULT_BUFFER_SIZE, O_WRONLY | O_TRUNC | O_CREAT);

            /// TSV format metadata file.
            writeString("Version:\t" + toString(meta_version), out);
            writeString("\nBinlog File:\t" + binlog_file, out);
            writeString("\nExecuted GTID:\t" + executed_gtid_set, out);
            writeString("\nBinlog Position:\t" + toString(binlog_position), out);

            out.next();
            out.sync();
            out.close();
        }

        commitMetadata(std::move(fun), persistent_tmp_path, persistent_path);
    }
    else
        fun();
}

void MaterializeMetadata::getTablesWithCreateQueryFromMySql(mysqlxx::PoolWithFailover::Entry & connection,
                                                            const String & database,