File tree Expand file tree Collapse file tree 1 file changed +19
-0
lines changed
internal/codegen/golang/templates/pgx Expand file tree Collapse file tree 1 file changed +19
-0
lines changed Original file line number Diff line number Diff line change 1
1
{{define "dbCodeTemplatePgx"}}
2
2
3
3
type DBTX interface {
4
+ Begin(ctx context.Context) (pgx.Tx, error)
4
5
Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
5
6
Query(context.Context, string, ...interface{}) (pgx.Rows, error)
6
7
QueryRow(context.Context, string, ...interface{}) pgx.Row
@@ -34,4 +35,22 @@ func (q *Queries) WithTx(tx pgx.Tx) *Queries {
34
35
}
35
36
}
36
37
{{end}}
38
+
39
+ {{if not .EmitMethodsWithDBArgument}}
40
+ func (q *Queries) BeginTX(ctx context.Context) (*generated.Queries, func(*error) error, error) {
41
+ tx, err := q.beginer.Begin(ctx)
42
+ if err != nil {
43
+ return nil, nil, err
44
+ }
45
+ return q.WithTx(tx), func(e *error) error {
46
+ if e != nil {
47
+ if err1 := tx.Rollback(ctx); err1 != nil {
48
+ log.Printf("rollback:%v", err1)
49
+ }
50
+ }
51
+ return tx.Commit(ctx)
52
+ }, nil
53
+ }
54
+ {{end}}
55
+
37
56
{{end}}
You can’t perform that action at this time.
0 commit comments