Skip to content

Commit 7f4bbfd

Browse files
authored
Add Begin to pgx db template
1 parent ecc6178 commit 7f4bbfd

File tree

1 file changed

+16
-0
lines changed

1 file changed

+16
-0
lines changed

internal/codegen/golang/templates/pgx/dbCode.tmpl

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
{{define "dbCodeTemplatePgx"}}
22

33
type DBTX interface {
4+
Begin(context.Context) (pgx.Tx, error)
5+
BeginTx(context.Context, txOptions TxOptions) (pgx.Tx, error)
46
Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
57
Query(context.Context, string, ...interface{}) (pgx.Rows, error)
68
QueryRow(context.Context, string, ...interface{}) pgx.Row
@@ -33,5 +35,19 @@ func (q *Queries) WithTx(tx pgx.Tx) *Queries {
3335
db: tx,
3436
}
3537
}
38+
func (q *Queries) Begin(ctx context.Context) (*Queries, error) {
39+
tx, err := q.db.Begin(ctx)
40+
if (err != nil {
41+
return nil, err
42+
}
43+
return q.WithTx(tx), nil
44+
}
45+
func (q *Queries) BeginTx(ctx context.Context, txOptions TxOptions) (*Queries, error) {
46+
tx, err := q.db.BeginTx(ctx, txOptions)
47+
if (err != nil {
48+
return nil, err
49+
}
50+
return q.WithTx(tx), nil
51+
}
3652
{{end}}
3753
{{end}}

0 commit comments

Comments
 (0)