Если используются GTID (gtid_mode равно ON), GTID для завершённой транзакции сохраняется на реплике, даже если содержимое транзакции отфильтровано. Это свойство предотвращает получение репликой ранее отфильтрованных транзакций при повторном подключении к источнику с помощью автоматического позиционирования по GTID. Также его можно использовать для пропуска транзакции на реплике, выполнив пустую транзакцию вместо ошибочной транзакции.

Этот метод пропуска транзакций не подходит, если вы включили назначение GTID на канале репликации с помощью параметра ASSIGN_GTIDS_TO_ANONYMOUS_TRANSACTIONS оператора CHANGE REPLICATION SOURCE TO.

Если ошибочная транзакция сгенерировала ошибку в потоке обработчика, её GTID можно получить напрямую из поля APPLYING_TRANSACTION в таблице Performance Schema replication_applier_status_by_worker. Чтобы увидеть, что представляет собой транзакция, выполните SHOW RELAYLOG EVENTS на реплике или SHOW BINLOG EVENTS на источнике и найдите в выводе транзакцию, предваряемую этим GTID.

После оценки ошибочной транзакции на предмет других необходимых действий (таких как соображения безопасности) для пропуска транзакции выполните пустую транзакцию на реплике, имеющую тот же GTID, что и ошибочная транзакция. Например:

SET GTID_NEXT='aaa-bbb-ccc-ddd:N';
BEGIN;
COMMIT;
SET GTID_NEXT='AUTOMATIC';

Наличие этой пустой транзакции на реплике означает, что при выполнении оператора START REPLICA для перезапуска репликации реплика использует функцию автоматического пропуска для игнорирования ошибочной транзакции, поскольку она видит, что транзакция с этим GTID уже применена. Если реплика является репликой с несколькими источниками, вам не нужно указывать имя канала при выполнении пустой транзакции, но вам нужно указать имя канала при выполнении START REPLICA.

Обратите внимание, что если на этой реплике используется двоичное протоколирование, пустая транзакция попадает в поток репликации, если реплика становится источником или главным в будущем. Если вам нужно избежать этой возможности, рассмотрите возможность очистки и удаления двоичных журналов реплики, как в этом примере:

FLUSH LOGS;
PURGE BINARY LOGS TO 'binlog.000146';

GTID пустой транзакции сохраняется, но сама транзакция удаляется путём очистки двоичных файлов журнала.

Для пропуска транзакций с ошибками, когда GTID не используются или внедряются постепенно (gtid_mode имеет значение OFF, OFF_PERMISSIVE или ON_PERMISSIVE), можно пропустить указанное количество событий, выполнив SET GLOBAL sql_replica_skip_counter. В качестве альтернативы, можно пропустить событие или события, выполнив оператор CHANGE REPLICATION SOURCE TO для перемещения позиции исходного двоичного журнала вперёд.

Эти методы также подходят, когда вы включили назначение GTID на канале репликации с помощью опции ASSIGN_GTIDS_TO_ANONYMOUS_TRANSACTIONS оператора CHANGE REPLICATION SOURCE TO.

При использовании этих методов важно понимать, что вы не обязательно пропускаете полную транзакцию, как это всегда происходит с методом, основанным на GTID, описанным ранее. Эти методы, не основанные на GTID, не знают о транзакциях как таковых, а вместо этого работают с событиями. Двоичный журнал организован как последовательность групп, известных как группы событий, а каждая группа событий состоит из последовательности событий.

Хотя одна транзакция может содержать изменения как в транзакционных, так и в не транзакционных таблицах, поддержка таких транзакций устарела, и вы должны ожидать её удаления в будущих версиях MySQL. См. Раздел 19.5.1.36, «Репликация и транзакции». Некоторые причины этой устарелости см. в Раздел 19.1.3.7, «Ограничения репликации с GTID».

Когда вы используете оператор SET GLOBAL sql_replica_skip_counter для пропуска событий, и полученная позиция находится в середине группы событий, реплика продолжает пропускать события до достижения конца группы. Затем выполнение начинается с следующей группы событий. У оператора CHANGE REPLICATION SOURCE TO такой функции нет, поэтому нужно быть внимательным, чтобы определить правильное место для перезапуска репликации в начале группы событий. Однако, использование CHANGE REPLICATION SOURCE TO означает, что вам не нужно подсчитывать события, которые нужно пропустить, как это нужно с SET GLOBAL sql_replica_skip_counter, а вместо этого вы можете указать место для перезапуска.

SET GLOBAL sql_replica_skip_counter = N

CHANGE REPLICATION SOURCE TO SOURCE_LOG_FILE='source_log_name', SOURCE_LOG_POS=source_log_pos;

CHANGE REPLICATION SOURCE TO SOURCE_AUTO_POSITION=0, SOURCE_LOG_FILE='binlog.000145', SOURCE_LOG_POS=235;
CHANGE REPLICATION SOURCE TO SOURCE_AUTO_POSITION=1;