part

Documentation

Index

• Constants
• func DealRows[T any](rows *sql.Rows, createF func() T) (*[]T, error)
• func IsFin[T any](t *SqlTx[T]) bool
• func SimpleQ[T any](canTx CanTx, query string, ptr *T) (*[]T, error)
• 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() (dataP *T, e error)

Constants

const (
	Execf
	Queryf
)

Functions

func DealRows

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

func IsFin

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

func SimpleQ

func SimpleQ[T any](canTx CanTx, query string, ptr *T) (*[]T, error)

Types

type AfterEF

type AfterEF[T any] func(dataP *T, result sql.Result, txE error) (dataPR *T, stopErr error)

type AfterQF

type AfterQF[T any] func(dataP *T, rows *sql.Rows, txE error) (dataPR *T, stopErr error)

type BeforeF

type BeforeF[T any] func(dataP *T, sqlf *SqlFunc[T], txE error) (dataPR *T, stopErr error)

type CanTx

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

type SqlFunc

type SqlFunc[T any] struct {
	Ty         int
	Ctx        context.Context
	Query      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) *SqlTx[T]

func (*SqlTx[T]) Fin

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