MySQL MGR集群单主模式的自动搭建和自动化故障修(2)

完成的实现代码如下，花了一个下午写的，目前来说存在以下不足
1，创建复制用户的时候，没有指定具体的slave机器，目前直接指定的%：create user repl@'%' identified by repl
2，对于slave的修复，目前无法整体修复，只能一台一台修复，其实就是少了一个循环slave机器判断的过程
3，目前搭建之前都会reset master（不管主从，主要是清理可能的残留GTID），因此只适合新环境的搭建
4，目前只支持offline和gtid事物冲突的错误类型修复，无法支持其他MGR错误类型的修复
5，开发环境是单机多实例模式测试，没有在多机单实例模式下充分测试
以上都会逐步改善&加强。

# -*- coding: utf-8 -*-

import pymysql
import logging
import time
import decimal

def execute_query(conn_dict,sql):
    conn = pymysql.connect(host=conn_dict['host'],
                          port=conn_dict['port'],
                          user=conn_dict['user'],
                          passwd=conn_dict['password'],
                          db=conn_dict['db'])
    cursor = conn.cursor(pymysql.cursors.DictCursor)
    cursor.execute(sql)
    list = cursor.fetchall()
    cursor.close()
    conn.close()
    return list

def execute_noquery(conn_dict,sql):
    conn = pymysql.connect(host=conn_dict['host'],
                          port=conn_dict['port'],
                          user=conn_dict['user'],
                          passwd=conn_dict['password'],
                          db=conn_dict['db'])
    cursor = conn.cursor()
    cursor.execute(sql)
    conn.commit()
    cursor.close()
    conn.close()
    return list

def get_gtid(conn_dict):
    sql = "show master status;"
    list = execute_query(conn_dict,sql)
    return list