(self, curs, op_map)
Process delete list
Process delete list
Process delete list
def process_delete(self, curs, op_map):
        """Process delete list"""
        data = op_map['D']
        cnt = len(data)
        if (cnt == 0):
            return
        self.log.debug("bulk: Deleting %d rows from %s", cnt, self.table)
        # copy rows to temp
        self.bulk_insert(curs, data)
        # delete rows using temp
        self.delete(curs)
        # check if right amount of rows deleted (only in direct mode)
        if self.conf.table_mode == 'direct' and cnt != curs.rowcount:
            self.log.warning("%s: Delete mismatch: expected=%s deleted=%d",
                    self.table, cnt, curs.rowcount)
def process_delete ( self , curs , op_map ) : data = op_map [ 'D' ] cnt = len ( data ) if ( cnt == 0 ) : return self . log . debug ( "bulk: Deleting %d rows from %s" , cnt , self . table ) # copy rows to temp self . bulk_insert ( curs , data ) # delete rows using temp self . delete ( curs ) # check if right amount of rows deleted (only in direct mode) if self . conf . table_mode == 'direct' and cnt != curs . rowcount : self . log . warning ( "%s: Delete mismatch: expected=%s deleted=%d" , self . table , cnt , curs . rowcount )