INSTALL PLUGIN clone SONAME 'mysql_clone.so';

CREATE USER `clone_user`@`192.168.1.%` IDENTIFIED by 'clone_user'; 
GRANT BACKUP_ADMIN ON *.* TO `clone_user`@`192.168.1.%`   # BACKUP_ADMIN是MySQL8.0 才有的备份锁的权限

CREATE USER clone_user@'192.168.1.%' IDENTIFIED by 'clone_user'; 
GRANT CLONE_ADMIN ON *.* TO 'clone_user'@'192.168.1.%'; 

SET GLOBAL clone_valid_donor_list = '192.168.1.11:3306';

CLONE INSTANCE FROM clone_user@'192.168.1.11':3306 IDENTIFIED BY 'clone_user';

SELECT STAGE, STATE, END_TIME FROM performance_schema.clone_progress;

SELECT BINLOG_FILE, BINLOG_POSITION FROM performance_schema.clone_status;

select 
stage,
state,
cast(begin_time as DATETIME) as "START TIME",
cast(end_time as DATETIME) as "FINISH TIME",
lpad(sys.format_time(power(10,12) * (unix_timestamp(end_time) - unix_timestamp(begin_time))), 10, ' ') as DURATION,
lpad(concat(format(round(estimate/1024/1024,0), 0), "MB"), 16, ' ') as "Estimate",
case when begin_time is NULL then LPAD('%0', 7, ' ')
when estimate > 0 then
lpad(concat(round(data*100/estimate, 0), "%"), 7, ' ')
when end_time is NULL then lpad('0%', 7, ' ')
else lpad('100%', 7, ' ')
end as "Done(%)"
from performance_schema.clone_progress;

CHANGE MASTER TO MASTER_HOST='10.0.14.141', MASTER_PORT=61106 ,MASTER_USER='repl',MASTER_PASSWORD='xxxxxxxx',MASTER_AUTO_POSITION = 1;

#!/usr/bin/env bash

CLONE_ADMIN_USER="clone_user@'192.168.x.%'"
CLONE_VALID_DONOR_LIST="192.168.x.x"
MYSQL_PORT=3306
ROOT_PASSWORD="123456"

# 仅支持GTID模式
# GTID_MODE=1
#删除旧文件
function  del_old_file() {
    systemctl stop mysqld && rm -rf /data/logs/* && rm -rf /data1/data* && rm -rf /data/data/binlog/* && rm -rf /data/data/relaylog/*
}

function start_mysqld() {
    systemctl start mysqld
    OLDPASSWORD=`grep 'temporary password' /data/logs//mysqld.log | awk '{printf $NF}'`
    SETPASSWDTXT="set global validate_password.policy='LOW';alter user root@localhost identified by '${ROOT_PASSWORD}';"
    mysql -h localhost -P${MYSQL_PORT} -uroot -p${OLDPASSWORD} -e "${SETPASSWDTXT}" --connect-expired-password
}

function install_plugin() {
    INSTALL_PLUGIN_SQL="INSTALL PLUGIN clone SONAME 'mysql_clone.so'"
    mysql -h localhost -P${MYSQL_PORT} -uroot -p${ROOT_PASSWORD} -e "${INSTALL_PLUGIN_SQL}" --connect-expired-password
}
function set_clone_user() {
    SET_CLONE_USER_SQL="set global validate_password.policy='LOW';CREATE USER IF NOT EXISTS ${CLONE_ADMIN_USER} IDENTIFIED by 'clone_user';GRANT BACKUP_ADMIN,CLONE_ADMIN ON *.* TO ${CLONE_ADMIN_USER};"
    mysql -h localhost -P${MYSQL_PORT} -uroot -p${ROOT_PASSWORD} -e "${SET_CLONE_USER_SQL}" --connect-expired-password
}

function begin_clone() {
    CLONE_SQL="SET GLOBAL clone_valid_donor_list = '${CLONE_VALID_DONOR_LIST}:${MYSQL_PORT}';CLONE INSTANCE FROM clone_user@'${CLONE_VALID_DONOR_LIST}':${MYSQL_PORT} IDENTIFIED BY 'clone_user';"
    mysql -h localhost -P${MYSQL_PORT} -uroot -p${ROOT_PASSWORD} -e "${CLONE_SQL}" --connect-expired-password && echo "CLONE ENDS ... "
}
function change_master() {
    CHANGE_MASTER_SQL="STOP SLAVE;CHANGE MASTER TO MASTER_HOST='${CLONE_VALID_DONOR_LIST}', MASTER_PORT=${MYSQL_PORT} ,MASTER_USER='repl',MASTER_PASSWORD='repl20150602',MASTER_AUTO_POSITION = 1;START SLAVE;"
    mysql -h localhost -P${MYSQL_PORT} -uroot -p${ROOT_PASSWORD} -e "${CHANGE_MASTER_SQL}" --connect-expired-password
}

function execute_all() {
    del_old_file
    start_mysqld
    install_plugin
    set_clone_user
    begin_clone
    change_master
}
function usage() {
    echo "mysql-clone {-h|-d|-s|-u|-c|-m|-a}"
    echo "del_old_file(-d)               -- stop mysqld and delete old mysql-datafiles"
    echo "start_mysqld(-s)               -- start mysqld and set newpassword"
    echo "install_plugin(-i)               -- install clone plgin"
    echo "set_clone_user(-u)             -- set clone user"
    echo "begin_clone(-c)                -- set clone donor and clone"
    echo "change_master(-m)                -- change master"
    echo "execute_all(-a)                -- execute all"
}

case "$1" in
    '-d')
        del_old_file
        ;;
    '-s')
        start_mysqld
        ;;
    '-i')
        install_plugin
        ;;
    '-u')
        set_clone_user
        ;;
    '-c')
        begin_clone
        ;;
    '-m')
        change_master
        ;;
    '-a')
        execute_all
        ;;
    *)
        usage
esac