if not create: raise

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

    '''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

    @param mapping dict(out_table_col=in_table_col, ...)

        * out_table_col: sql_gen.Col|str

        * in_table_col: sql_gen.Col Wrap literal values in a sql_gen.NamedCol

    @return sql_gen.Col Where the output pkeys are made available

    '''

    out_table = sql_gen.as_Table(out_table)

    for in_table_col in mapping.itervalues():

        assert isinstance(in_table_col, sql_gen.Col)

    def log_debug(msg): db.log_debug(msg, level=1.5)

    log_debug('Inserting these input columns into '

        +strings.as_tt(out_table.to_str(db))+':\n'+strings.as_table(mapping))

    # Create input joins from list of input tables

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

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

    log_debug('Joining together input tables into temp table')

    # Place in new table for speed and so don't modify input if values edited

    flatten_cols = filter(sql_gen.is_table_col, mapping.values())

    mapping = dicts.join(mapping, flatten(db, in_table, input_joins,

        flatten_cols, preserve=[in_pkey_col], start=0))

    def insert_into_pkeys(joins, cols):

        query, params = mk_select(db, joins, cols, order_by=None, start=0)

        if pkeys_table_exists_ref[0]:

        else:

            pkeys_table_exists_ref[0] = True

    limit_ref = [None]

    # Do inserts and selects

    join_cols = {}

    while True:

        has_joins = join_cols != {}

        insert_into_pkeys(pkey_joins, pkeys_names)

    db.log_debug('Adding pkey on pkeys table to enable fast joins', level=2.5)

    log_debug("Setting pkeys of missing rows 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

    insert_into_pkeys(missing_rows_joins,

        [in_pkey_col, sql_gen.NamedCol(out_pkey, None)])

##### Data cleanup

            row[out_col] = sql_gen.NamedCol(out_col, value)

    # Insert node

    pkeys_loc = sql.put_table(db, out_table, in_tables, row, row_ins_ct_ref,

    if commit: db.db.commit()

    # Insert children with fkeys to parent