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!

    out_pkey = pkey(db, out_table, recover=True)

    out_pkey_col = sql_gen.as_Col(out_pkey, out_table)

    pkeys_cols = [in_pkey_col, out_pkey_col]

    pkeys_table_exists_ref = [False]

    def run_query_into_pkeys(query, params):

        if pkeys_table_exists_ref[0]:

        else:

            pkeys_table_exists_ref[0] = True

    conds = set()

    # Do inserts and selects

    join_cols = {}

    while True:

        has_joins = join_cols != {}

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

                sql_gen.filter_out))

        else:

        db.log_debug('Inserting new rows')

        try:

    if has_joins:

        select_joins = input_joins+[sql_gen.Join(out_table, join_cols)]

        db.log_debug('Getting output pkeys of existing/inserted rows')

    else:

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

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

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

            {row_num_col: sql_gen.join_same_not_null})]

    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