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

        order_by=None), recover=recover, log_level=3))

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

        recover=recover, log_level=4)))

    try: return value(select(db, tables, cols, conds, order_by=order_by,

        limit=1, log_level=4))

def pkey_col_(db, table, *args, **kw_args):

    return sql_gen.Col(pkey(db, table, *args, **kw_args), table)

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

    '''Name assumed to be the value of not_null_col. If not found, uses pkey.'''

    else: return pkey(db, table, recover)

def constraint_cond(db, constraint):

        index should be added on the first column.

        * If already_indexed, the pkey is assumed to have already been added

    '''

    if has_pkey:

        if has_pkey is not already_indexed: add_pkey(db, table)

        cols = cols[1:]

def cleanup_table(db, table):

    table = sql_gen.as_Table(table)

    cols = [sql_gen.as_Col(strings.ustr(c), table)

    cols = filter(lambda c: sql_gen.is_text_col(db, c), cols)

    try: cols.remove(sql.pkey_col_(db, table))

    except ValueError: pass

##### Import

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

    def log(msg, level=1): db.log_debug(msg, level)

        else:

            out_table_cols = sql_gen.ColDict(db, out_table)

            out_table_cols.update(util.dict_subset_right_join({},

            in_cols = []

            cond = sql.map_expr(db, cond, mapping, in_cols)