Встроенные функции GTID_SUBSET() и GTID_SUBTRACT() можно использовать для проверки того, что реплика применила, как минимум, каждую транзакцию, примененную источником.

Для выполнения этой проверки с GTID_SUBSET() выполните следующую команду на реплике:

SELECT GTID_SUBSET(source_gtid_executed, replica_gtid_executed);

Если возвращаемое значение равно 0 (false), это означает, что некоторые GTID в source_gtid_executed отсутствуют в replica_gtid_executed, и что реплика еще не применила транзакции, примененные на источнике, что означает, что реплика не актуальна.

Для выполнения той же проверки с GTID_SUBTRACT() выполните следующую команду на реплике:

SELECT GTID_SUBTRACT(source_gtid_executed, replica_gtid_executed);

Эта команда возвращает любые GTID, которые есть в source_gtid_executed, но отсутствуют в replica_gtid_executed. Если возвращаются какие-либо GTID, это означает, что источник применил некоторые транзакции, которые реплика еще не применила, и, следовательно, реплика не актуальна.

Хранимые функции GTID_IS_EQUAL(), GTID_IS_DISJOINT() и GTID_IS_DISJOINT_UNION() могут использоваться для проверки операций резервного копирования и восстановления, включающих несколько баз данных и серверов. В этом сценарии server1 содержит базу данных db1, а server2 содержит базу данных db2. Цель — скопировать базу данных db2 в server1, и результат на server1 должен быть объединением обеих баз данных. Используемый метод заключается в создании резервной копии server2 с помощью mysqldump, а затем восстановлении этой резервной копии на server1.

При условии, что mysqldump был запущен с --set-gtid-purged, установленным в ON или AUTO (по умолчанию), выход содержит оператор SET @@GLOBAL.gtid_purged, который добавляет набор gtid_executed из server2 в набор gtid_purged на server1. gtid_purged содержит GTID всех транзакций, которые были завершены на определенном сервере, но которые не существуют ни в одном файле бинарного журнала на сервере. При копировании базы данных db2 в server1 GTID транзакций, завершенных на server2, которые отсутствуют в файлах бинарного журнала на server1, должны быть добавлены в gtid_purged, чтобы server1 сделать набор полным.

Хранимые функции можно использовать для помощи в следующих этапах этого сценария:

Функция хранения данных GTID_UNION() может использоваться для определения наиболее актуальной реплики из набора реплик, для выполнения ручного failover после неожиданной остановки сервера источника. Если некоторые реплики испытывают задержку репликации, эта функция может быть использована для вычисления наиболее актуальной реплики без ожидания, пока все реплики применяют свои существующие релейные журналы, и, следовательно, для минимизации времени failover. Функция может вернуть объединение 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 также имеет свою собственную реплику. Реплика также получает и применяет транзакции из source1, если source2 настроено с log_replica_updates=ON, но не делает этого, если source2 использует log_replica_updates=OFF. В любом случае, мы сейчас хотим только узнать, является ли реплика актуальной по отношению к source2. В этой ситуации GTID_INTERSECTION_WITH_UUID() может использоваться для идентификации транзакций, которые source2 генерировал, отбрасывая транзакции, которые source2 реплицировал из source1. Встроенная функция GTID_SUBSET() затем может быть использована для сравнения результата с набором gtid_executed на реплике. Если реплика актуальна по отношению к source2, то набор gtid_executed на реплике содержит все транзакции в пересекающемся наборе (транзакции, которые исходили от source2).

Для выполнения этой проверки сохраните значения gtid_executed и идентификатора UUID сервера из source2, а также значение 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() для идентификации и возврата только тех GTID из набора GTID, которые исходили от source2, исключая те, которые исходили от source1. Полученный набор GTID затем сравнивается с набором всех выполненных GTID на реплике, используя GTID_SUBSET(). Если эта команда возвращает ненулевое значение (истина), все идентифицированные GTID из source2 (первый входной набор) также находятся в gtid_executed реплики, что означает, что реплика получила и выполнила все транзакции, исходящие от source2.