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

        put()'s node param, but with the input column name prefixed by "$" in

        place of the column value.

    @param commit Whether to commit after each query

        available

    '''

    def esc_name(name): return sql.esc_name(db, name)

        return put_table(db, node, in_table, in_schema, commit, row_ct_ref)

    out_table = name_of(node)

    row = {}

    children = []

    in_tables = [qual_name(in_table)]

                row[child_name] = '$'+col

                in_tables.append(table)

            else: children.append(child)

    except KeyError: pass

    # Divide fields into input columns and literal values

        else: row[out_col] = (value, out_col) # value is literal value

    # Insert node

        row_ct_ref, table_is_esc=True)

    if commit: db.db.commit()