io.debezium.connector.mysql

Class GtidUtils

java.lang.Object

io.debezium.connector.mysql.GtidUtils

public class GtidUtils
extends Object

Utils for handling GTIDs.

Constructor Summary

Constructors

Constructor and Description
GtidUtils()

Method Summary

Modifier and Type	Method and Description
static io.debezium.connector.mysql.GtidSet	fixRestoredGtidSet(io.debezium.connector.mysql.GtidSet serverGtidSet, io.debezium.connector.mysql.GtidSet restoredGtidSet) This method corrects the GTID set that has been restored from a state or checkpoint using the GTID set fetched from the server via SHOW MASTER STATUS.
static io.debezium.connector.mysql.GtidSet	mergeGtidSetInto(io.debezium.connector.mysql.GtidSet base, io.debezium.connector.mysql.GtidSet toMerge) This method merges one GTID set (toMerge) into another (base), without overwriting the existing elements in the base GTID set.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GtidUtils

public GtidUtils()

Method Detail

fixRestoredGtidSet

public static io.debezium.connector.mysql.GtidSet fixRestoredGtidSet(io.debezium.connector.mysql.GtidSet serverGtidSet,
                                                                     io.debezium.connector.mysql.GtidSet restoredGtidSet)

This method corrects the GTID set that has been restored from a state or checkpoint using the GTID set fetched from the server via SHOW MASTER STATUS. During the correction process, the restored GTID set is adjusted according to the server's GTID set to ensure it does not exceed the latter. For each UUID in the restored GTID set, if it exists in the server's GTID set, then it will be adjusted according to the server's GTID set; if it does not exist in the server's GTID set, it will be directly added to the new GTID set.

mergeGtidSetInto

public static io.debezium.connector.mysql.GtidSet mergeGtidSetInto(io.debezium.connector.mysql.GtidSet base,
                                                                   io.debezium.connector.mysql.GtidSet toMerge)

This method merges one GTID set (toMerge) into another (base), without overwriting the existing elements in the base GTID set.