(ctx context.Context, query string, args ...any)
| 86 | } |
| 87 | |
| 88 | func (e *SharedTx) QueryRow(ctx context.Context, query string, args ...any) pgx.Row { |
| 89 | e.lock() |
| 90 | // no unlock until row scan |
| 91 | |
| 92 | row := e.inner.QueryRow(ctx, query, args...) |
| 93 | |
| 94 | // executor is unlocked when row is scanned |
| 95 | return &SharedTxRow{sharedTxDerivative{sharedTx: e}, row} |
| 96 | } |
| 97 | |
| 98 | // |
| 99 | // These are implemented so SharedTx can satisfy pgx.Tx. |