From 9686269498477d0b56caf06166a975a25248b1c1 Mon Sep 17 00:00:00 2001 From: Stefan Majewsky Date: Tue, 8 Sep 2026 18:26:05 +0200 Subject: gsql: change WithinTransaction methods to take sql.TxOptions This makes them usable as replacements for BeginTx + Commit/Rollback. --- gsql/std.go | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) (limited to 'gsql') diff --git a/gsql/std.go b/gsql/std.go index 1896725..bf4c718 100644 --- a/gsql/std.go +++ b/gsql/std.go @@ -58,8 +58,8 @@ func (db *DB) Conn(ctx context.Context) (*Conn, error) { // // This is equivalent to the GSQLTransact() method of the DB's [ConnectionHandle] implementation, // but the callback receives the concrete type [*Tx] instead of a generic [Handle]. -func (db *DB) WithinTransaction(ctx context.Context, action func(*Tx) error) error { - return withinTransaction(ctx, db.DB, action) +func (db *DB) WithinTransaction(ctx context.Context, opts *sql.TxOptions, action func(*Tx) error) error { + return withinTransaction(ctx, db.DB, opts, action) } // Conn wraps [*sql.Conn] into a [Handle]. @@ -87,8 +87,8 @@ func (conn *Conn) BeginTx(ctx context.Context, opts *sql.TxOptions) (*Tx, error) // // This is equivalent to the GSQLTransact() method of conn's [ConnectionHandle] implementation, // but the callback receives the concrete type [*Tx] instead of a generic [Handle]. -func (conn *Conn) WithinTransaction(ctx context.Context, action func(*Tx) error) error { - return withinTransaction(ctx, conn.Conn, action) +func (conn *Conn) WithinTransaction(ctx context.Context, opts *sql.TxOptions, action func(*Tx) error) error { + return withinTransaction(ctx, conn.Conn, opts, action) } // Tx wraps [*sql.Tx] into a [Handle]. @@ -209,14 +209,14 @@ func (h sqlConnectionHandle[T]) GSQLClose(ctx context.Context) error { // GSQLTransact implements the [ConnectionHandle] interface. func (h sqlConnectionHandle[T]) GSQLTransact(ctx context.Context, action func(tx Handle) error) error { - return withinTransaction(ctx, h.Base, func(tx *Tx) error { + return withinTransaction(ctx, h.Base, nil, func(tx *Tx) error { return action(tx) }) } // withinTransaction implements the method of that name that exists on all types based on [sqlConnectionHandle]. -func withinTransaction(ctx context.Context, conn sqlConnection, action func(*Tx) error) error { - tx, err := conn.BeginTx(ctx, nil) +func withinTransaction(ctx context.Context, conn sqlConnection, opts *sql.TxOptions, action func(*Tx) error) error { + tx, err := conn.BeginTx(ctx, opts) if err != nil { return err } -- cgit v1.3.1