При использовании 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 пустой транзакции сохраняется, но сама транзакция удаляется путём очистки файлов двоичного журнала.

Для пропуска транзакций, которые завершаются ошибкой, когда GTIDs не используются или находятся в стадии ввода в действие (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, не знают транзакций как таковых, а вместо этого работают с событиями. Двоичный журнал организован как последовательность групп, известных как группы событий, и каждая группа событий состоит из последовательности событий.

Одна транзакция может содержать изменения в таблицах как с транзакциями, так и без них.

Когда вы используете оператор 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;