Exec checks if tx is closed

#1350
jackc · Oct 24, 2022 · 3ad9995 · 3ad9995
1 parent 3e825ec
commit 3ad9995
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/tx.go b/tx.go
@@ -201,6 +201,10 @@ func (tx *dbTx) Rollback(ctx context.Context) error {
 
 // Exec delegates to the underlying *Conn
 func (tx *dbTx) Exec(ctx context.Context, sql string, arguments ...any) (commandTag pgconn.CommandTag, err error) {
+	if tx.closed {
+		return pgconn.CommandTag{}, ErrTxClosed
+	}
+
 	return tx.conn.Exec(ctx, sql, arguments...)
 }