(self, curs, op_map)
Process insert list
Process insert list
Process insert list
def process_insert(self, curs, op_map):
        """Process insert list"""
        data = op_map['I']
        cnt = len(data)
        # merged method loads inserts together with updates
        if (cnt == 0) or (self.method == METH_MERGED):
            return
        self.log.debug("bulk: Inserting %d rows into %s", cnt, self.table)
        # copy into target table (no temp used)
        self.bulk_insert(curs, data, table = self.qtable)
def process_insert ( self , curs , op_map ) : data = op_map [ 'I' ] cnt = len ( data ) # merged method loads inserts together with updates if ( cnt == 0 ) or ( self . method == METH_MERGED ) : return self . log . debug ( "bulk: Inserting %d rows into %s" , cnt , self . table ) # copy into target table (no temp used) self . bulk_insert ( curs , data , table = self . qtable )