if not create: raise

        return put(db, table, row, pkey, row_ct_ref) # insert new row

    table_is_esc=False):

    '''Recovers from errors.

    Only works under PostgreSQL (uses INSERT RETURNING).

    @param in_tables The main input table to select from, followed by a list of

        tables to join with it using the main input table's pkey

        available

    '''

    out_table_clean = clean_name(out_table)

    pkeys = out_table_clean+'_pkeys'

    # Join together input tables

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

    in_tables0 = in_tables.pop(0) # first table is separate

    out_pkeys = out_table_clean+'_out_pkeys'

    def insert_():

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

            into=out_pkeys, recover=True, table_is_esc=table_is_esc)

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

            row_ct_ref[0] += cur.rowcount

        # Join together out_pkeys and in_pkeys

        run_query_into(db, *mk_select(db,

            [in_pkeys, (out_pkeys, {row_num_col: join_using})],

    try:

        # Insert and capture output pkeys

        with_parsed_errors(db, insert_)

    except DuplicateKeyException, e: raise

##### Data cleanup