dbHandle.py 文件源码

def ResetMaster(self,groupname):
        try:
            '''????binlog????'''
            master_log_file,read_master_log_pos,master_host = self.CheckPos(get_host=True)
            if master_host:
                readbinlog_status = str([groupname,master_log_file,read_master_log_pos])
                from zk_handle.zkHandler import zkHander
                from contextlib import closing
                with closing(zkHander()) as zkhander:
                    zkhander.SetReadBinlog(master_host,readbinlog_status)
            ''''''

            #self.mysql_cur.execute('set global read_only=0;')
            self.mysql_cur.execute('stop slave')
            self.mysql_cur.execute('reset slave all;')

        except MySQLdb.Warning,e:
            logging.warning(traceback.format_exc())
        except MySQLdb.Error,e:
            logging.warning(traceback.format_exc())

        """????,????????????????zk????????"""
        import AdditionTask
        addition = AdditionTask.Addition(self.host)
        addition_master = addition.GetRepl()
        if addition_master:
            exe_addition = AdditionTask.ExecuteAdditionTask(self.host,self.port)
            for region in addition_master:
                exe_addition.Change(region,addition_master[region])
        """"""