-- Insert the value and error for *each* source column.

            FOR "column" IN

'''+sql.mk_select(db, sql_gen.NamedValues('c', None, [[c.name] for c in srcs]),

            LOOP

                BEGIN

'''+sql.mk_insert_select(db, errors_table, errors_table_cols,

    # Place in new table for speed and so don't modify input if values edited

    in_table = sql_gen.Table('in')

    mapping = dicts.join(mapping, sql.flatten(db, in_table, input_joins,

    input_joins = [in_table]

    db.log_debug('Temp table: '+strings.as_tt(in_table.to_str(db)), level=2)

        full_in_table_cols.append(default)

        default = sql_gen.with_table(default, full_in_table)

    sql.run_query_into(db, sql.mk_select(db, in_table, full_in_table_cols,

    sql.add_pkey(db, full_in_table)

    pkeys_names = [in_pkey, out_pkey]

        distinct_on = []

        if distinct: distinct_on=[in_pkey_col]

        query = sql.mk_select(db, joins, cols, distinct_on=distinct_on,

        if pkeys_table_exists_ref[0]:

            sql.insert_select(db, into, pkeys_names, query, **kw_args)

    def mk_main_select(joins, cols):

        conds_ = [(sql_gen.with_table(k, insert_in_table), v) for k, v in conds]

        return sql.mk_select(db, joins, cols, conds_, limit=limit_ref[0],

    exc_strs = set()

    def log_exc(e):