内置函数 GTID_SUBSET() 和 GTID_SUBTRACT() 可用于检查副本是否已应用至少源应用的每个事务。

要使用 GTID_SUBSET() 执行此检查，请在副本上执行以下语句

SELECT GTID_SUBSET(source_gtid_executed, replica_gtid_executed);

如果返回值为 0（假），则表示 source_gtid_executed 中的一些 GTID 不存在于 replica_gtid_executed 中，并且副本尚未应用在源上应用的事务，这意味着副本未更新。

要在副本上使用 GTID_SUBTRACT() 执行相同的检查，请执行以下语句

SELECT GTID_SUBTRACT(source_gtid_executed, replica_gtid_executed);

此语句将返回 source_gtid_executed 中但不在 replica_gtid_executed 中的任何 GTID。如果返回任何 GTID，则表示源已应用副本未应用的一些事务，因此副本不是最新的。

存储函数 GTID_IS_EQUAL()、GTID_IS_DISJOINT() 和 GTID_IS_DISJOINT_UNION() 可用于验证涉及多个数据库和服务器的备份和还原操作。在此示例场景中，server1 包含数据库 db1，而 server2 包含数据库 db2。目标是将数据库 db2 复制到 server1，并且 server1 上的结果应该是这两个数据库的并集。使用的过程是使用 mysqldump 备份 server2，然后将此备份还原到 server1 上。

如果 mysqldump 在运行时将 --set-gtid-purged 设置为 ON 或 AUTO（默认值），则输出将包含一个 SET @@GLOBAL.gtid_purged 语句，该语句将 gtid_executed 集从 server2 添加到 server1 上的 gtid_purged 集中。 gtid_purged 包含在给定服务器上已提交但在服务器上任何二进制日志文件中不存在的所有事务的 GTID。当数据库 db2 被复制到 server1 时，必须将 server2 上已提交的事务的 GTID（不在 server1 上的二进制日志文件中）添加到 server1 的 gtid_purged 中以使该集合完整。

存储函数可用于协助此场景中的以下步骤

存储函数 GTID_UNION() 可用于从一组副本中识别最最新的副本，以便在源服务器意外停止后执行手动故障转移操作。如果一些副本正在经历复制延迟，则此存储函数可用于计算最最新的副本，而无需等待所有副本应用其现有中继日志，从而最大限度地减少故障转移时间。该函数可以返回每个副本上 gtid_executed 与副本收到的事务集的并集，这些事务集记录在 Performance Schema 的 replication_connection_status 表中。您可以比较这些结果，以找到哪个副本的事务记录是最新的，即使并非所有事务都已提交。

在每个副本上，通过发出以下语句计算完整的事务记录

SELECT GTID_UNION(RECEIVED_TRANSACTION_SET, @@GLOBAL.gtid_executed)
    FROM performance_schema.replication_connection_status
    WHERE channel_name = 'name';

然后，您可以比较每个副本的结果，以查看哪个副本拥有最最新的事务记录，并使用此副本作为新的源。

存储函数 GTID_SUBTRACT_UUID() 可用于检查副本是否已收到未来自其指定源或来源的事务。如果有，则您的复制设置或代理、路由器或负载均衡器可能存在问题。此函数通过从 GTID 集中删除来自指定源服务器的所有 GTID，并返回剩余的 GTID（如果有）来工作。

对于具有单个源的副本，请发出以下语句，给出源的标识符，通常与 server_uuid 相同

SELECT GTID_SUBTRACT_UUID(@@GLOBAL.gtid_executed, server_uuid_of_source);

如果结果不为空，则返回的事务是未来自指定源的额外事务。

对于多源拓扑中的副本，请在函数调用中包含每个源的服务器 UUID，如下所示

SELECT 
  GTID_SUBTRACT_UUID(GTID_SUBTRACT_UUID(@@GLOBAL.gtid_executed,
                                        server_uuid_of_source_1),
                                        server_uuid_of_source_2);

如果结果不为空，则返回的事务是未来自任何指定源的额外事务。

存储函数 GTID_INTERSECTION_WITH_UUID() 可用于验证服务器是否未生成任何 GTID 并且处于只读状态。该函数仅返回来自 GTID 集的那些来自具有指定标识符的服务器的 GTID。如果此服务器的 gtid_executed 中列出的任何事务使用服务器自己的标识符，则服务器本身已生成这些事务。您可以在服务器上发出以下语句进行检查

SELECT GTID_INTERSECTION_WITH_UUID(@@GLOBAL.gtid_executed, my_server_uuid);

存储函数 GTID_INTERSECTION_WITH_UUID() 可用于找出附加到多源复制设置的副本是否已应用来自特定源的所有事务。在此场景中，source1 和 source2 都是源和副本，它们相互复制。 source2 也有自己的副本。如果 source2 配置为使用 log_replica_updates=ON，则该副本还会接收和应用来自 source1 的事务，但如果 source2 使用 log_replica_updates=OFF，则不会这样做。无论哪种情况，我们目前只想知道副本是否与 source2 最新。在这种情况下，GTID_INTERSECTION_WITH_UUID() 可用于识别 source2 生成的事务，丢弃 source2 从 source1 复制的事务。然后可以使用内置函数 GTID_SUBSET() 将结果与副本上的 gtid_executed 集进行比较。如果副本与 source2 最新，则副本上的 gtid_executed 集包含交集集中的所有事务（来自 source2 的事务）。

要执行此检查，请将来自 source2 的 gtid_executed 和服务器 UUID 的值以及来自副本的 gtid_executed 的值存储到用户变量中，如下所示

source2> SELECT @@GLOBAL.gtid_executed INTO @source2_gtid_executed;

source2> SELECT @@GLOBAL.server_uuid INTO @source2_server_uuid;

replica> SELECT @@GLOBAL.gtid_executed INTO @replica_gtid_executed;

然后使用这些变量作为输入，使用 GTID_INTERSECTION_WITH_UUID() 和 GTID_SUBSET()，如下所示

SELECT 
  GTID_SUBSET(
    GTID_INTERSECTION_WITH_UUID(@source2_gtid_executed,
                                @source2_server_uuid),
                                @replica_gtid_executed);

来自 source2 的服务器标识符 (@source2_server_uuid) 与 GTID_INTERSECTION_WITH_UUID() 一起使用，用于识别和返回仅来自 source2 上的 GTID 集的那些 GTID，省略来自 source1 的那些 GTID。然后使用 GTID_SUBSET() 将生成的 GTID 集与副本上所有已执行 GTID 的集合进行比较。如果此语句返回非零（true），则来自 source2 的所有已识别 GTID（第一个输入集）也存在于副本的 gtid_executed 中，这意味着副本已接收并执行了来自 source2 的所有事务。