Replication.py 文件源码

def UpateEvent(self, after_values, befor_values):
        _set = []
        _where = []
        if self._is_pri:
            _where.append(self.__join(self._is_pri[0][0], after_values[self._is_pri[0][1]]))
        else:
            for i, column in enumerate(self.column_list):
                _where.append(self.__join(column[0], after_values[i]))

        for i, column in enumerate(self.column_list):
            _set.append(self.__join(column[0], befor_values[i]))
        sql = 'update {}.{} set {} where {}'.format(_rollback.database, _rollback.table,
                                                    ','.join(_set).replace(" ", ""), ','.join(_where))
        if _remote_filed._rollback_status:
            print '{: >21}{}{}'.format('', '-- ', sql)
        else:
            self.__tmppack(sql, 2)