'''

    if into_ref == None: return run_query(db, query, params, *args, **kw_args)

    else: # place rows in temp table

        kw_args['recover'] = True

        while True:

            try:

                create_query = 'CREATE'

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

                create_query += ' TABLE '+into+' AS '+query

                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

        assert isinstance(in_table_col, sql_gen.Col)

    temp_prefix = out_table.name

    # Create input joins from list of input tables

    in_tables_ = in_tables[:] # don't modify input!

    pkeys_table_exists_ref = [False]

    def run_query_into_pkeys(query, params):

        if pkeys_table_exists_ref[0]:

        else:

            run_query_into(db, query, params, into_ref=pkeys_ref)

            pkeys_table_exists_ref[0] = True

    # Do inserts and selects

    join_cols = {}

    while True:

        has_joins = join_cols != {}

        run_query_into_pkeys(*mk_select(db, select_joins, pkeys_cols,

            start=0))

    else:

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

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

            into_ref=in_pkeys_ref)

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

            {row_num_col: sql_gen.join_same_not_null})]

        run_query_into_pkeys(*mk_select(db, pkey_joins, pkeys, start=0))

    db.log_debug("Setting missing rows' pkeys to NULL")

        {in_pkey: sql_gen.join_same_not_null}, sql_gen.filter_out)]

        # must use join_same_not_null or query will take forever

    run_query_into_pkeys(*mk_select(db, missing_rows_joins,

        [in_pkey_col, sql_gen.NamedCol(out_pkey, None)], start=0))

##### Data cleanup