if cols == None:

            row = [sql_gen.Col(sql_gen.all_cols, 'row')]

            row_vars = [sql_gen.Table('row')]

        else:

            row_vars = row = [sql_gen.Col(c.name, 'row') for c in cols]

        query = sql_gen.CustomCode('''\

DECLARE

    row '''+table.to_str(db)+'''%ROWTYPE;

BEGIN

    /* Need an EXCEPTION block for each individual row because "When an error is

    caught by an EXCEPTION clause, [...] all changes to persistent database

    state within the block are rolled back."

    This is unfortunate because "A block containing an EXCEPTION clause is

    significantly more expensive to enter and exit than a block without one."

    (http://www.postgresql.org/docs/8.3/static/plpgsql-control-structures.html\

#PLPGSQL-ERROR-TRAPPING)

    */

    FOR '''+(', '.join((v.to_str(db) for v in row_vars)))+''' IN

'''+select_query+'''

    LOOP

        BEGIN

            RETURN QUERY

'''+mk_insert(sql_gen.Values(row).to_str(db))+'''

;

        EXCEPTION

            WHEN unique_violation THEN NULL; -- continue to next row

        END;

    END LOOP;

END;\

''')

        query.lang = 'plpgsql'