executemany fetchall not returning upserted results.

[GollyJer]

I had to do the

for value in values:
    cur.execute(query, value)

to process each query separately and get the count because the commented out code using fetchall() returns no result available when rows are upserted.

I'd like to use the executemany. Am I doing it wrong? Thanks!

def upsert_sales_data(self, transactions):
    query = """
            INSERT INTO sale (
                id_marketplace,
                id_inscription,
                sold_at,
                price_btc,
                price_eth,
                price_usd,
                from_address,
                to_address,
                transaction_id
            )
            VALUES (
                %s, %s, %s, %s, %s, %s, %s, %s, %s
            )
            ON CONFLICT (transaction_id) DO NOTHING
            RETURNING *
            """

    values = [
        (
            t.id_marketplace,
            t.id_inscription,
            t.sold_at,
            t.price_btc,
            t.price_eth,
            t.price_usd,
            t.from_address,
            t.to_address,
            t.transaction_id,
        )
        for t in transactions
    ]

    inserted_rows = []
    with self._pool.connection() as conn, conn.cursor() as cur:
        for value in values:
            cur.execute(query, value)
            inserted_rows.extend(cur.fetchall())
        conn.commit()

    #   cur.executemany(query, values)
    #   inserted_rows = cur.fetchall()
    #   conn.commit()

    # Sort by sold_at date
    inserted_rows.sort(key=lambda x: x[2])
    return inserted_rows or []

[dvarrazzo]

The feature is not available in psycopg2. You have to use psycopg 3.

[GollyJer]

@dvarrazzo This is happening with these versions.

[dvarrazzo]

Then 1) the ticket is open to the wrong repository, and 2) the documentation tells you what to do.

[GollyJer]

I'm an idiot. Thanks.