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

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

SELECT GTID_SUBSET(source_gtid_executed, replica_gtid_executed);

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