sqlwrapper/tx.go at master · beefllama/sqlwrapper · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
package sqlwrapper

import (
	"context"
	"database/sql"
)

type tx struct {
	txSql *sql.Tx
}

func (t *tx) Commit() error {
	return t.txSql.Commit()
}

func (t *tx) Rollback() error {
	return t.txSql.Rollback()
}

func (t *tx) Exec(ctx context.Context, queryBuilder SQLBuilder) (sql.Result, error) {
	return exec(ctx, t.txSql, queryBuilder)
}

func (t *tx) Get(ctx context.Context, dest any, queryBuilder SQLBuilder) error {
	return get(ctx, t.txSql, dest, queryBuilder)
}

func (t *tx) GetOne(ctx context.Context, dest any, queryBuilder SQLBuilder) error {
	return getOne(ctx, t.txSql, dest, queryBuilder)
}

func (t *tx) ExecRaw(ctx context.Context, query string, args ...any) (sql.Result, error) {
	return execRaw(ctx, t.txSql, query, args...)
}

func (t *tx) GetRaw(ctx context.Context, dest any, query string, args ...any) error {
	return getRaw(ctx, t.txSql, dest, query, args...)
}

func (t *tx) GetOneRaw(ctx context.Context, dest any, query string, args ...any) error {
	return getOneRaw(ctx, t.txSql, dest, query, args...)
}