Replication.py 文件源码

def __init__(self, block=None, server_id=None, log_file=None,
                 log_pos=None, host=None, user=None, passwd=None, rollback=None,
                 port=None, gtid=None, _thread_id=None, stop_pos=None):
        import pymysql
        _remote_filed._gtid = gtid
        _remote_filed._thread_id = _thread_id

        self._stop_pos = stop_pos
        self._log_file = log_file
        self._log_pos = log_pos
        self.block = block if block != None else False
        self.server_id = server_id if server_id != None else 133
        self.port = port if port != None else 3306
        self.connection = pymysql.connect(host=host,
                                          user=user,
                                          password=passwd, port=self.port,
                                          db='',
                                          charset='utf8mb4',
                                          cursorclass=pymysql.cursors.DictCursor)
        if rollback:
            _remote_filed._rollback_status = True
            _rollback._myfunc = GetRollStatement(host=host, user=user, passwd=passwd, port=self.port)

        self.ReadPack()