# Do inserts and selects

    distinct_on = None

    while True:

        try:

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

                *mk_select_(mapping.values(), distinct_on), returning=out_pkey,

                into_ref=out_pkeys_ref, recover=True, table_is_esc=table_is_esc)

            if row_ct_ref != None and cur.rowcount >= 0:

                row_ct_ref[0] += cur.rowcount

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

            # Get input pkeys corresponding to rows in insert

            in_pkeys_ref = ['in_pkeys_'+temp_suffix]

            run_query_into(db, *mk_select_([in_pkey]), into_ref=in_pkeys_ref)

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

            # Join together output and input pkeys

            run_query_into_pkeys(*mk_select(db, [in_pkeys_ref[0],

                (out_pkeys_ref[0], {row_num_col: join_using})], pkeys_cols,

                start=0))

            break # insert successful

        except DuplicateKeyException, e:

            join_cols = util.dict_subset_right_join(mapping, e.cols)

            select_joins = insert_joins + [(out_table, join_cols)]

            # Get pkeys of already existing rows

            run_query_into_pkeys(*mk_select(db, select_joins, pkeys_cols,

                order_by=None, start=0, table_is_esc=table_is_esc))

            # Save existing pkeys in temp table for joining on

            existing_pkeys_ref = ['existing_pkeys_'+temp_suffix]

            run_query_into(db, *mk_select(db, pkeys_ref[0], [in_pkey],

                order_by=None, start=0, table_is_esc=True),

                into_ref=existing_pkeys_ref)

                # need table_is_esc=True to make table name case-insensitive

            # rerun loop with additional constraints

            break # but until NullValueExceptions are handled, end loop here