MySQL5.7配置Pseudo-GTID完整步骤

-- 登录 MySQL（所有节点：192.168.56.80、61、60）
mysql -uroot -p

-- 创建 meta 数据库（如果不存在）
CREATE DATABASE IF NOT EXISTS meta;

-- 切换到 meta 数据库
USE meta;

-- 确保事件调度器已开启
SET GLOBAL event_scheduler = ON;

-- 创建伪 GTID 注入事件
DELIMITER $$

CREATE EVENT IF NOT EXISTS create_pseudo_gtid_event
ON SCHEDULE EVERY 10 SECOND
STARTS CURRENT_TIMESTAMP
ON COMPLETION PRESERVE
ENABLED
COMMENT 'Inject Pseudo-GTID markers for Orchestrator'
DO
BEGIN
    DECLARE lock_result INT;
    
    -- 获取锁，确保同一时间只有一个会话执行注入
    SELECT GET_LOCK('pseudo_gtid_lock', 0) INTO lock_result;
    
    IF lock_result = 1 THEN
        -- 执行一个会产生 binlog 事件的语句
        -- DROP VIEW 即使视图不存在也会记录 binlog
        DROP VIEW IF EXISTS `meta`.`pseudo_gtid_view`;
        
        -- 释放锁
        DO RELEASE_LOCK('pseudo_gtid_lock');
    END IF;
END$$

DELIMITER ;

-- 查看事件是否创建成功
SHOW EVENTS FROM meta\G

-- 查看事件调度器状态（应为 ON）
SHOW VARIABLES LIKE 'event_scheduler';

-- 查看事件的具体定义
SELECT 
    EVENT_NAME,
    STATUS,
    STARTS,
    INTERVAL_VALUE,
    INTERVAL_FIELD,
    EXECUTE_AT
FROM information_schema.EVENTS 
WHERE EVENT_SCHEMA = 'meta';

# 编辑 MySQL 配置文件
vim /etc/my.cnf

# 添加以下配置
[mysqld]
# 确保事件调度器开机自启
event_scheduler = ON

# 可选：优化 binlog 格式
binlog_format = ROW  # 推荐使用 ROW 格式
binlog_rows_query_log_events = ON  # 记录原始 SQL，便于调试

systemctl restart mysqld

# 验证重启后事件调度器状态
mysql -e "SHOW VARIABLES LIKE 'event_scheduler';"

# 找到最新的 binlog 文件
mysql -e "SHOW MASTER STATUS\G"

# 查看 binlog 中的 Pseudo-GTID 标记
mysqlbinlog /var/lib/mysql/mysql-bin.000001 | grep -A 3 -B 3 "DROP VIEW" | head -20

# at 12345678
#230101 10:00:00 server id 1113306  end_log_pos 12345689  Query thread_id=123 exec_time=0 error_code=0
SET TIMESTAMP=1704070800/*!*/;
DROP VIEW IF EXISTS `meta`.`pseudo_gtid_view`/*!*/;

# 使用 orchestrator-client 查看集群拓扑
orchestrator-client -c topology -i 192.168.56.80:3306

# 在 Orchestrator 日志中查看伪 GTID 相关信息
tail -f /var/log/orchestrator.log | grep -i pseudo

DELIMITER $$

CREATE EVENT IF NOT EXISTS create_pseudo_gtid_event_advanced
ON SCHEDULE EVERY 10 SECOND
STARTS CURRENT_TIMESTAMP
ON COMPLETION PRESERVE
ENABLED
DO
BEGIN
    DECLARE lock_result INT;
    DECLARE pseudo_gtid_value VARCHAR(50);
    
    -- 生成一个唯一值
    SET pseudo_gtid_value = CONCAT('pseudo_gtid_', UNIX_TIMESTAMP(), '_', RAND());
    
    SELECT GET_LOCK('pseudo_gtid_lock', 0) INTO lock_result;
    
    IF lock_result = 1 THEN
        -- 创建一个包含唯一值的注释和 DROP VIEW 语句
        SET @pseudo_gtid_sql = CONCAT('/* ', pseudo_gtid_value, ' */ DROP VIEW IF EXISTS `meta`.`pseudo_gtid_view`');
        PREPARE stmt FROM @pseudo_gtid_sql;
        EXECUTE stmt;
        DEALLOCATE PREPARE stmt;
        
        DO RELEASE_LOCK('pseudo_gtid_lock');
    END IF;
END$$

DELIMITER ;

#!/bin/bash

# 检查事件是否存在且启用
MYSQL_CMD="mysql -uroot -pYourPassword -e"

EVENT_STATUS=$($MYSQL_CMD "SHOW EVENTS FROM meta LIKE 'create_pseudo_gtid_event'" 2>/dev/null | grep ENABLED)

if [ -z "$EVENT_STATUS" ]; then
    echo "ERROR: Pseudo-GTID event is not enabled or missing"
    exit 1
fi

# 检查最近是否有注入
LAST_INJECT=$($MYSQL_CMD "SELECT MAX(STR_TO_DATE(event_time, '%Y%m%d %H:%i:%s')) 
    FROM (SELECT SUBSTRING_INDEX(SUBSTRING_INDEX(event_time, '# at', -1), ' ', 2) as event_time 
          FROM mysql.general_log WHERE argument LIKE '%DROP VIEW%' LIMIT 100) t" 2>/dev/null)

CURRENT_TIME=$(date +%s)
LAST_INJECT_TIME=$(date -d "$LAST_INJECT" +%s)

if [ $((CURRENT_TIME - LAST_INJECT_TIME)) -gt 30 ]; then
    echo "WARNING: No Pseudo-GTID injection in last 30 seconds"
    exit 2
fi

echo "OK: Pseudo-GTID is working properly"
exit 0

{
  "AutoPseudoGTID": true,
  "PseudoGTIDPattern": "DROP VIEW IF EXISTS `meta`.`pseudo_gtid_view`",
  "PseudoGTIDPatternIsFixedSubstring": true,
  "PseudoGTIDMonotonicHint": "order:asc",
  "DetectPseudoGTIDQuery": "SELECT max(SUBSTRING_INDEX(SUBSTRING_INDEX(event_time, '# at', -1), ' ', 2)) as pseudo_gtid FROM mysql.general_log WHERE argument LIKE '%DROP VIEW IF EXISTS `meta`.`pseudo_gtid_view`%'",
  
  "RecoverMasterBinlogFileLocation": true,
  "RecoverMasterClusterFilters": ["*"],
  "InstancePollSeconds": 5
}

-- 检查事件状态
SELECT 
    EVENT_NAME,
    STATUS,
    LAST_EXECUTED,
    LAST_ALTERED
FROM information_schema.EVENTS 
WHERE EVENT_SCHEMA = 'meta';

-- 手动执行事件测试
CALL meta.create_pseudo_gtid_event();

-- 查看是否有锁冲突
SHOW PROCESSLIST;
SELECT * FROM performance_schema.metadata_locks;

-- 确保监控用户有足够的权限
GRANT DROP ON meta.* TO 'orch_topology_user'@'192.168.56.%';
GRANT SELECT ON mysql.general_log TO 'orch_topology_user'@'192.168.56.%';
FLUSH PRIVILEGES;

-- 如果不想开启 general_log，可以授予对 binlog 的访问权限
GRANT REPLICATION CLIENT ON *.* TO 'orch_topology_user'@'192.168.56.%';

-- 查看事件执行耗时
SELECT 
    EVENT_NAME,
    AVG_EXEC_TIME,
    MAX_EXEC_TIME,
    COUNT_EXEC
FROM performance_schema.events_statements_summary_by_account_by_event_name
WHERE EVENT_NAME LIKE '%create_pseudo_gtid_event%';

-- 查看 binlog 增长速度
SHOW MASTER STATUS;
-- Pseudo-GTID 每10秒产生约 200-300 字节的 binlog 事件
-- 每天约增加 2-3 MB，影响可忽略不计