#!/bin/bash

#Mysql sync

#chenglee

#master机器ip

MasterIP="192.168.137.174"

#slave机器ip

SlaveIp="192.168.137.170"

#主从同步账号密码

MASTER_USER="sync"

MASTER_PASSWORD="sync"

#master机mysql登录账号密码

Muser="root"

Mpass="123456"

#slave机mysql登录账号密码

Suser="root"

Spass="123456"

#slave机ssh的登录账号密码

SSHuser="root"

SSHpass="lizhenghua"

function Master(){

    #MASTER

    function create(){

        mysql --protocol=TCP -u ${Muser} -p''${Mpass}'' --connect-expired-password -e "flush PRIVILEGES;" >/dev/null 2>&1

        mysql --protocol=TCP -u ${Muser} -p''${Mpass}'' --connect-expired-password -e "CREATE USER '${MASTER_USER}'@'${SlaveIp}' IDENTIFIED BY '${MASTER_PASSWORD}';" >/dev/null 2>&1

        mysql --protocol=TCP -u ${Muser} -p''${Mpass}'' --connect-expired-password -e "grant replication slave on *.* to '${MASTER_USER}'@'${SlaveIp}' identified by '${MASTER_PASSWORD}';" >/dev/null 2>&1

        mysql --protocol=TCP -u ${Muser} -p''${Mpass}'' --connect-expired-password -e "flush PRIVILEGES;" >/dev/null 2>&1

    }

    #my.cnf

    function addbin(){

        number=`cat -n /etc/my.cnf | grep -F "[mysqld]" | awk '{print$1}'`

        serverID=`echo ${MasterIP} | awk -F'.' '{print$NF}'`

        text1="server-id=${serverID}"

        text2="log-bin=mysql-bin"

        text3="lower_case_table_names=1"

        sed -i "${number}a\\${text1}\n${text2}\n${text3}" /etc/my.cnf

    }

    #restart

    function Mrestart(){

        service mysql restart

    }

    #ssh

    function mstscSSH(){

        echo -e "\033[43;35m 开始配置双机交互，请按回车后输入slave机登录密码 \033[0m"

        ssh-keygen -N ''

        ssh-copy-id ${SSHuser}@${SlaveIp}

    }

echo "创建同步账号"

create

echo "添加master端id到my.cnf文件"

addbin

echo "重启master端数据库"

Mrestart

echo "开始账号交互"

mstscSSH

}

#SLAVE

function Slave(){

    #my.cnf

    function addbin2(){

        Snumber2=`ssh ${SSHuser}@${SlaveIp} "cat -n /etc/my.cnf | grep -F "[mysqld]" | awk '{print$1}'" | awk '{print$1}'`

        SserverID2=`echo ${SlaveIp} | awk -F'.' '{print$NF}'`

        Stext1="server-id=${SserverID2}"

        Stext3="lower_case_table_names=1"

        ssh ${SSHuser}@${SlaveIp} "sed -i '${Snumber2}a\\${Stext1}\n${Stext3}' /etc/my.cnf"

    }

    #restart

    function Srestart(){

        ssh ${SSHuser}@${SlaveIp} "service mysql restart"

    }

    function Ssync(){

        mkdir logs

        mysql --protocol=TCP -u ${Suser} -p''${Spass} --connect-expired-password -e "show master status;" > logs/chenglee.logs

        MASTER_HOST=${MasterIP}

        MASTER_LOG_FILE=`cat logs/chenglee.logs | tail -n 1 | awk '{print$1}'`

        MASTER_LOG_POS=`cat logs/chenglee.logs | tail -n 1 | awk '{print$2}'`

        ssh ${SSHuser}@${SlaveIp} "mysql --protocol=TCP -u ${Suser} -p''${Spass} --connect-expired-password -e \"stop slave;\"" >/dev/null 2>&1

        ssh ${SSHuser}@${SlaveIp} "mysql --protocol=TCP -u ${Suser} -p''${Spass} --connect-expired-password -e \"reset slave;\"" >/dev/null 2>&1

        ssh ${SSHuser}@${SlaveIp} "mysql --protocol=TCP -u ${Suser} -p''${Spass} --connect-expired-password -e \"reset slave all;\"" >/dev/null 2>&1

        ssh ${SSHuser}@${SlaveIp} "mysql --protocol=TCP -u ${Suser} -p''${Spass} --connect-expired-password -e \"change master to master_host='${MasterIP}', master_user='${MASTER_USER}', master_password='${MASTER_PASSWORD}', master_log_file='${MASTER_LOG_FILE}', master_log_pos=${MASTER_LOG_POS}, MASTER_CONNECT_RETRY=10;\"" >/dev/null 2>&1

        ssh ${SSHuser}@${SlaveIp} "mysql --protocol=TCP -u ${Suser} -p''${Spass} --connect-expired-password -e \"start slave;\"" >/dev/null 2>&1

        ssh ${SSHuser}@${SlaveIp} "mysql --protocol=TCP -u ${Suser} -p''${Spass} --connect-expired-password -e \"show slave status \G;\"" > logs/slave_sync.logs

}

echo "添加master端id到my.cnf文件"

addbin2

echo "重启slave端数据库"

Srestart

echo "开始同步配置"

Ssync

}

#校准同步

#:提示

#当发现主从同步失败的时候， 开启此选项则自动检测并重新配置同步

function calibrate(){

    mysql --protocol=TCP -u ${Suser} -p''${Spass} --connect-expired-password -e "show master status;" > logs/chenglee.logs

    ssh ${SSHuser}@${SlaveIp} "mysql --protocol=TCP -u ${Suser} -p''${Spass} --connect-expired-password -e \"show slave status \G;\"" > logs/slave_sync.logs

    MASTER_HOST=${MasterIP}

    MASTER_LOG_FILE=`cat logs/chenglee.logs | tail -n 1 | awk '{print$1}'`

    MASTER_LOG_POS=`cat logs/chenglee.logs | tail -n 1 | awk '{print$2}'`

    string1=`cat logs/slave_sync.logs | sed -n '12,13p' | awk -F ':' '{print$2}' | head -n 1`

    string2=`cat logs/slave_sync.logs | sed -n '12,13p' | awk -F ':' '{print$2}' | head -n 2 | tail -n 1`

    if [ ${string1} = ${string2} ];then

        if ( echo ${string1} |grep -q 'Yes' && echo ${string2} |grep -q 'Yes' );then

            echo "主从已同步，无需校准"

        else

            echo "1主从已断开，准备校准"

            ssh ${SSHuser}@${SlaveIp} "mysql --protocol=TCP -u ${Suser} -p''${Spass} --connect-expired-password -e \"stop slave;\""

            ssh ${SSHuser}@${SlaveIp} "mysql --protocol=TCP -u ${Suser} -p''${Spass} --connect-expired-password -e \"reset slave;\""

            ssh ${SSHuser}@${SlaveIp} "service mysql restart"

            ssh ${SSHuser}@${SlaveIp} "mysql --protocol=TCP -u ${Suser} -p''${Spass} --connect-expired-password -e \"change master to master_host='${MasterIP}', master_user='${MASTER_USER}', master_password='${MASTER_PASSWORD}', master_log_file='${MASTER_LOG_FILE}', master_log_pos=${MASTER_LOG_POS}\""

            ssh ${SSHuser}@${SlaveIp} "mysql --protocol=TCP -u ${Suser} -p''${Spass} --connect-expired-password -e \"start slave;\""

            echo "1校准成功"

        fi

        exit

    else

        echo "2主从已断开，准备校准"

        ssh ${SSHuser}@${SlaveIp} "mysql --protocol=TCP -u ${Suser} -p''${Spass} --connect-expired-password -e \"stop slave;\""

        ssh ${SSHuser}@${SlaveIp} "mysql --protocol=TCP -u ${Suser} -p''${Spass} --connect-expired-password -e \"reset slave;\""

        ssh ${SSHuser}@${SlaveIp} "service mysql restart"

        ssh ${SSHuser}@${SlaveIp} "mysql --protocol=TCP -u ${Suser} -p''${Spass} --connect-expired-password -e \"change master to master_host='${MasterIP}', master_user='${MASTER_USER}', master_password='${MASTER_PASSWORD}', master_log_file='${MASTER_LOG_FILE}', master_log_pos=${MASTER_LOG_POS}\""

        ssh ${SSHuser}@${SlaveIp} "mysql --protocol=TCP -u ${Suser} -p''${Spass} --connect-expired-password -e \"start slave;\""

        echo "2校准成功"

    fi

}

function main(){

    Master

    Slave

    #calibrate

}

main