def append_csv(db, table, stream_info, stream, use_copy_from=True):

    if use_copy_from:

        log('Using COPY FROM')

        # Wrap in standardizing stream

        cols_ct = len(stream_info.header)

        stream = csvs.InputRewriter(csvs.ColCtFilter(csvs.make_reader(stream,

            dialect), cols_ct))

        dialect = stream.dialect # use default dialect

        # Create COPY FROM statement

        copy_from = ('COPY '+table.to_str(db)+' FROM STDIN DELIMITER '

            +db.esc_value(dialect.delimiter)+' NULL '+db.esc_value(''))

        assert not csvs.is_tsv(dialect)

        copy_from += ' CSV'

        if dialect.quoting != csv.QUOTE_NONE:

            quote_str = db.esc_value(dialect.quotechar)

            copy_from += ' QUOTE '+quote_str

            if dialect.doublequote: copy_from += ' ESCAPE '+quote_str

        copy_from += ';\n'

        log(copy_from, level=2)

        try: db.db.cursor().copy_expert(copy_from, stream)

        except Exception, e: sql.parse_exception(db, e, recover=True)

    else:

        log('Using INSERT')

        cols_ct = len(stream_info.header)

        row_ct = 0

        inserted_row_ct = 0

        for row in csvs.make_reader(stream, dialect):

            row_ct += 1

            row = map(strings.to_unicode, row)

            util.list_set_length(row, cols_ct) # truncate extra cols

            if sql.insert(db, table, row, ignore=True, cacheable=False,

                log_level=5) != None:

                inserted_row_ct += 1

        log('Inserted '+str(inserted_row_ct)+' of '+str(row_ct)+' rows')