part

Documentation

Index

• func DealRows[T any](rows *sql.Rows, newT func() T) ([]T, error)
• func IsFin[T any](t *SqlTx[T]) bool
• type AfterEF
• type AfterQF
• type BeforeF
• type CanTx
• type SqlFunc
• type SqlTx
  • func BeginTx[T any](canTx CanTx, ctx context.Context, opts ...*sql.TxOptions) *SqlTx[T]
  • func (t *SqlTx[T]) AfterEF(f AfterEF[T]) *SqlTx[T]
  • func (t *SqlTx[T]) AfterQF(f AfterQF[T]) *SqlTx[T]
  • func (t *SqlTx[T]) BeforeF(f BeforeF[T]) *SqlTx[T]
  • func (t *SqlTx[T]) Do(sqlf SqlFunc[T]) *SqlTx[T]
  • func (t *SqlTx[T]) DoPlaceHolder(sqlf SqlFunc[T], ptr any, ...) *SqlTx[T]
  • func (t *SqlTx[T]) Fin() (ctxVP T, e error)
  • func (t *SqlTx[T]) SimpleDo(sql string, args ...any) *SqlTx[T]
  • func (t *SqlTx[T]) SimplePlaceHolderA(sql string, ptr any) *SqlTx[T]
  • func (t *SqlTx[T]) SimplePlaceHolderB(sql string, ptr any) *SqlTx[T]
• type Type

Functions

func DealRows

func DealRows[T any](rows *sql.Rows, newT func() T) ([]T, error)

func IsFin

func IsFin[T any](t *SqlTx[T]) bool

Types

type AfterEF

type AfterEF[T any] func(ctxVP *T, result sql.Result, e *error)

type AfterQF

type AfterQF[T any] func(ctxVP *T, rows *sql.Rows, e *error)

func(ctxVP *T, rows *sql.Rows, e *error)

type BeforeF

type BeforeF[T any] func(ctxVP *T, sqlf *SqlFunc[T], e *error)

type CanTx

type CanTx interface {
	BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
}

type SqlFunc

type SqlFunc[T any] struct {
	// 	Execf or Queryf, default: auto detection
	Ty Type
	// default: use transaction Ctx
	Ctx        context.Context
	Sql        string
	Args       []any
	SkipSqlErr bool
	// contains filtered or unexported fields
}

type SqlTx

type SqlTx[T any] struct {
	// contains filtered or unexported fields
}

func BeginTx

func BeginTx[T any](canTx CanTx, ctx context.Context, opts ...*sql.TxOptions) *SqlTx[T]

func (*SqlTx[T]) AfterEF

func (t *SqlTx[T]) AfterEF(f AfterEF[T]) *SqlTx[T]

func (*SqlTx[T]) AfterQF

func (t *SqlTx[T]) AfterQF(f AfterQF[T]) *SqlTx[T]

func (*SqlTx[T]) BeforeF

func (t *SqlTx[T]) BeforeF(f BeforeF[T]) *SqlTx[T]

func (*SqlTx[T]) Do

func (t *SqlTx[T]) Do(sqlf SqlFunc[T]) *SqlTx[T]

func (*SqlTx[T]) DoPlaceHolder

func (t *SqlTx[T]) DoPlaceHolder(sqlf SqlFunc[T], ptr any, replaceF ...func(index int, holder string) (replaceTo string)) *SqlTx[T]

func (*SqlTx[T]) Fin

func (t *SqlTx[T]) Fin() (ctxVP T, e error)

func (*SqlTx[T]) SimpleDo

func (t *SqlTx[T]) SimpleDo(sql string, args ...any) *SqlTx[T]

func (*SqlTx[T]) SimplePlaceHolderA

func (t *SqlTx[T]) SimplePlaceHolderA(sql string, ptr any) *SqlTx[T]

PlaceHolder will replaced by ?

func (*SqlTx[T]) SimplePlaceHolderB

func (t *SqlTx[T]) SimplePlaceHolderB(sql string, ptr any) *SqlTx[T]

PlaceHolder will replaced by $%d

type Type

type Type int

const (
	Execf Type
	Queryf
)