Postgres pgx驱动程序在提交时挂起

Question

我有一个功能，可以更新表格中的记录，并使用pgx Postgres驱动程序请求它。此函数在提交时挂起。你知道为什么会发生这样的事情吗？为什么我不能在这种情况下使用事务？

当然，因为查询是原子的，所以我可以删除事务。但它仍然不清楚-为什么会发生这种情况，以及如果我需要一个事务怎么办。

func (r *Repository) GetUpdatedItems(ctx context.Context, filters []string) ([]Item, error) {
    conn, err := r.pool.Acquire(ctx)
    // error handling
    defer conn.Release()
    
    tx, err := conn.Begin(ctx)
    // error handling
    defer func() {
        closeCtx, cancel := context.WithTimeout(context.Background(), 15*time.Second)
        defer cancel()
        _ = tx.Rollback(closeCtx) 
    }()

    query := fmt.Sprintf(`UPDATE %s
    SET fieldOne = $1, fieldTwo = $2
    WHERE otheField = '' OR otherField IS NULL
    RETURNING fieldOne, fieldTwo, otheField, someMoreField;`,
        r.tableName, sqlArray(aggregatesTypes))

    rows, err := conn.Query(ctx, query, filters[0], filters[1])
    // error handling
    defer rows.Close()

    var retItems []reaper.Item

    for rows.Next() {

        var fieldOne string
        var fieldTwo string
        var otheField string
        var someMoreField string
        

        if err := rows.Scan(&id, &fieldOne, &fieldTwo, &otheField, &someMoreField); err != nil {
            return nil, fmt.Errorf("failed to scan item: %w", err)
        }

        item := Item{
            FieldOne:       fieldOne,
            FieldTwo:       fieldTwo,
            OtheField:      otheField,
            SomeMoreField:  someMoreField
        }

        retItems = append(retItems, item)
    }

    if err := tx.Commit(ctx); err != nil {
        return nil, fmt.Errorf("failed to commit transaction: %w", err)
    }
    
    return retItems, nil
}

Answer 1

必须使用tx.Query而不是conn.Query。

谢谢你的帮助！