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

def put_table(db, out_table, in_tables, mapping, limit=None, start=0,

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

    '''

    temp_prefix = clean_name(out_table)

    # Join together input tables

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

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

    insert_joins = [in_tables0]+[sql_gen.Join(v, {in_pkey: sql_gen.join_using})

        for v in in_tables]

    pkeys = [in_pkey, out_pkey]

    pkeys_cols = [in_pkey_col, out_pkey_col]

    distinct_on = []

    def mk_main_select(cols):

        return mk_select(db, insert_joins, cols, conds, distinct_on,

    def log_ignore(in_col, value):

        db.log_debug('Ignoring rows with '+in_col+' = '+value)

                select_joins = insert_joins+[sql_gen.Join(out_table, join_cols)]

                db.log_debug('Getting pkeys of already existing rows')

                run_query_into_pkeys(*mk_select(db, select_joins, pkeys_cols,

                # Prepare to insert new rows

                input_join_cols = join_cols.values()

            db.log_debug('Inserting new rows')

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

                *mk_main_select(mapping.values()), returning=out_pkey,

            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

                db.log_debug('Missing mapping for '+out_col)

                run_query_into_pkeys(*mk_select(db, insert_joins,

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

                break

            else:

                log_ignore(in_col, 'NULL')