if returning != None: cols = [returning]

        func_table = sql_gen.NamedTable('f', sql_gen.FunctionCall(function),

            cols) # AS clause requires function alias

    return query

def table_row_count(db, table, recover=None):

    return value(run_query(db, mk_select(db, table, [sql_gen.row_count],

def table_cols(db, table, recover=None):

    return list(col_names(select(db, table, limit=0, order_by=None,

        add_index(db, distinct_on, new_table, unique=True)

        add_index(db, distinct_on, table) # for join optimization

    analyze(db, new_table)

    return new_table

            -- 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):