組込み関数 GTID_SUBSET および GTID_SUBTRACT を使用すると、ソースが適用したすべてのトランザクションにレプリカが適用されているかどうかを確認できます。

GTID_SUBSET でこのチェックを実行するには、レプリカで次のステートメントを実行します:

SELECT GTID_SUBSET(source_gtid_executed, replica_gtid_executed)

これが 0 (false) を返す場合、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 での結果を 2 つのデータベースの和集合にすることです。 使用する手順は、mysqlpump または mysqldump を使用して server2 をバックアップし、server1 でこのバックアップをリストアすることです。

バックアッププログラムオプション --set-gtid-purged が ON に設定されているか、AUTO のデフォルトに設定されている場合、プログラム出力には SET @@GLOBAL.gtid_purged ステートメントが含まれ、gtid_executed セットを server2 から server1 の gtid_purged に追加します。 gtid_purged セットには、サーバー上でコミットされたが、サーバー上のバイナリログファイルに存在しないすべてのトランザクションの GTID が含まれています。 データベース db2 を server1 にコピーする場合、server1 のバイナリログファイルにない server2 でコミットされたトランザクションの GTID を server1 の gtid_purged セットに追加して、セットを完成させる必要があります。

ストアドファンクションを使用すると、このシナリオの次のステップを実行できます:

ストアドファンクション GTID_UNION を使用すると、ソースサーバーが予期せず停止した後に手動フェイルオーバー操作を実行するために、レプリカのセットから最新のレプリカを識別できます。 一部のレプリカでレプリケーションラグが発生している場合、このストアドファンクションを使用すると、すべてのレプリカが既存のリレーログを適用するのを待機せずに最新のレプリカを計算できるため、フェイルオーバー時間を最小限に抑えることができます。 この関数は、「パフォーマンススキーマ」テーブル replication_connection_status に記録されているレプリカが受信したトランザクションのセットを使用して、各レプリカの gtid_executed セットの和集合を戻すことができます。 これらの結果を比較して、すべてのトランザクションがまだコミットされていない場合でも、最新のトランザクションのレプリカレコードを検索できます。

各レプリカで、次のステートメントを発行してトランザクションの完全なレコードを計算します:

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);

結果が空でない場合、返されるトランザクションは、指定されたソースから発生しなかった余分なトランザクションです。

マルチソースレプリケーショントポロジのレプリカの場合は、次の例のように機能を繰り返します:

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_slave_updates=ON で構成されている場合、レプリカはソース source1 からトランザクションを受信して適用しますが、source2 が log_slave_updates=OFF を使用している場合は行いません。 いずれの場合も、現在、レプリカが source2 で最新であるかどうかのみを確認します。 この状況では、ストアドファンクション GTID_INTERSECTION_WITH_UUID を使用して、source2 が発生させたトランザクションを識別し、source2 が source1 からレプリケートしたトランザクションを破棄できます。 その後、組込み関数 GTID_SUBSET を使用して、結果をレプリカ上の gtid_executed セットと比較できます。 レプリカが source2 で最新の場合、レプリカに設定されている gtid_executed には交差セット (source2 から発生したトランザクション) 内のすべてのトランザクションが含まれます。

このチェックを実行するには、次のように、source2 の gtid_executed セット、source2 のサーバー UUID およびレプリカ gtid_executed セットをクライアント側の変数に格納します:

    $source2_gtid_executed :=
      source2> SELECT @@GLOBAL.gtid_executed;
    $source2_server_uuid :=
      source2> SELECT @@GLOBAL.server_uuid;
    $replica_gtid_executed :=
      replica> SELECT @@GLOBAL.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) のサーバー識別子は、source1 で発生した GTID を除外して、source2 の gtid_executed セットからの GTID のみを識別して返すために GTID_INTERSECTION_WITH_UUID とともに使用されます。 結果の GTID セットは、GTID_SUBSET を使用して、レプリカで実行されたすべての GTID のセットと比較されます。 このステートメントがゼロ以外 (true) を返す場合、source2 から識別された GTID (最初のセット入力) もすべてレプリカ gtid_executed セット (2 番目のセット入力) に含まれます。つまり、レプリカは source2 から発生したすべてのトランザクションをレプリケートしています。