# Do inserts and selects

    out_pkeys_ref = [temp_prefix+'_out_pkeys']

    while True:

        try:

            cur = insert_select(db, out_table, mapping.keys(),

                add_row_num(db, out_pkeys_ref[0]) # for joining with input pkeys

            # Get input pkeys corresponding to rows in insert

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

                into_ref=in_pkeys_ref)

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