name = match.group(2)

    return 'v'+str(version)+'_'+name

    '''Outputs a query to a temp table.

    For params, see run_query().

    '''

    else: # place rows in temp table

        kw_args['recover'] = True

        while True:

            try:

                create_query = 'CREATE'

                if not db.debug: create_query += ' TEMP'

                return run_query(db, create_query, params, *args, **kw_args)

                    # CREATE TABLE AS sets rowcount to # rows in query

            except DuplicateTableException, e:

                # try again with next version of name

order_by_pkey = object() # tells mk_select() to order by the pkey

def insert_select(db, *args, **kw_args):

    '''For params, see mk_insert_select() and run_query_into()

    '''

    recover = kw_args.pop('recover', None)

    cacheable = kw_args.pop('cacheable', True)

    query, params = mk_insert_select(db, *args, **kw_args)

        cacheable=cacheable)

default = object() # tells insert() to use the default value for a column

        if pkeys_table_exists_ref[0]:

            insert_select(db, pkeys_ref, pkeys, query, params)

        else:

            pkeys_table_exists_ref[0] = True

    conds = set()

            insert_joins.append(sql_gen.Join(out_table, join_cols,

                sql_gen.filter_out))

        else:

        db.log_debug('Inserting new rows')

        try:

        db.log_debug('Getting input pkeys for rows in insert')

        run_query_into(db, *mk_main_select(input_joins, [in_pkey]),

        add_row_num(db, in_pkeys_ref) # for joining with output pkeys

        db.log_debug('Joining together output and input pkeys')