wip: see if we use multiple savepoints

block · Jul 23, 2024 · 7a1a04e · 7a1a04e
1 parent 899be16
commit 7a1a04e
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/backend/controller/sql/conn.go b/backend/controller/sql/conn.go
@@ -51,6 +51,9 @@ func (t *Tx) Tx() pgx.Tx { return t.tx }
 func (t *Tx) Begin(ctx context.Context) (*Tx, error) {
 	savepoint := fmt.Sprintf("savepoint_%d", len(t.savepoints))
 	t.savepoints = append(t.savepoints, savepoint)
+	if len(t.savepoints) > 1 {
+		panic("checking if this is used")
+	}
 	_, err := t.tx.Exec(ctx, `SAVEPOINT `+savepoint)
 	if err != nil {
 		return nil, err