(self, tablename, src_curs, dst_curs, column_list)
return skytools.full_copy(tablename, src_curs, dst_curs,
                                  _src_cols, condition,
                                  dst_tablename = self.dest_table,
                                  dst_column_list = _dst_cols,
                                  write_hook = _write_hook)
do actual table copy and return tuple with number of bytes and rows
        copied
do actual table copy and return tuple with number of bytes and rows
        copied
do actual table copy and return tuple with number of bytes and rows copied
def real_copy(self, tablename, src_curs, dst_curs, column_list):
        """do actual table copy and return tuple with number of bytes and rows
        copied
        """
        _src_cols = _dst_cols = column_list
        condition = self.get_copy_condition (src_curs, dst_curs)

        if self.conf.skip_fields:
            _src_cols = [col for col in column_list
                         if col not in self.conf.skip_fields]
            _dst_cols = _src_cols

        if self.conf.field_map:
            _src_cols = [col for col in _src_cols if col in self.conf.field_map]
            _dst_cols = [self.conf.field_map[col] for col in _src_cols]

        if self.encoding_validator:
            def _write_hook(obj, data):
                return self.encoding_validator.validate_copy(data, _src_cols, tablename)
        else:
            _write_hook = None

        return skytools.full_copy(tablename, src_curs, dst_curs,
                                  _src_cols, condition,
                                  dst_tablename = self.dest_table,
                                  dst_column_list = _dst_cols,
                                  write_hook = _write_hook)
def real_copy ( self , tablename , src_curs , dst_curs , column_list ) : _src_cols = _dst_cols = column_list condition = self . get_copy_condition ( src_curs , dst_curs ) if self . conf . skip_fields : _src_cols = [ col for col in column_list if col not in self . conf . skip_fields ] _dst_cols = _src_cols if self . conf . field_map : _src_cols = [ col for col in _src_cols if col in self . conf . field_map ] _dst_cols = [ self . conf . field_map [ col ] for col in _src_cols ] if self . encoding_validator : def _write_hook ( obj , data ) : return self . encoding_validator . validate_copy ( data , _src_cols , tablename ) else : _write_hook = None return skytools . full_copy ( tablename , src_curs , dst_curs , _src_cols , condition , dst_tablename = self . dest_table , dst_column_list = _dst_cols , write_hook = _write_hook )