part

Dec 23, 2025

Changes in this version

type ErrTx

+ func (t *ErrTx) WithRaw(raw *SqlFunc) *ErrTx

Dec 17, 2025

Changes in this version

type TxPool

+ func (t *TxPool) RMutex(m RWMutex) *TxPool

Dec 17, 2025

Changes in this version

+ type RWMutex interface

+ Lock func()

+ RLock func()

+ RUnlock func()

+ Unlock func()

type SqlTx

+ func (t *SqlTx) RMutex(m RWMutex) *SqlTx

Dec 14, 2025

Changes in this version

type SqlTx

+ func (t *SqlTx) FinF(f func()) *SqlTx

Dec 11, 2025

Changes in this version

type Row

+ func DealRowMap(rows *sql.Rows, caseSwitchF ...CaseSwitchF) *Row[map[string]any]

+ func DealRow[T any](rows *sql.Rows) *Row[T]

type SqlTx

+ func (t *SqlTx) AddToTxs(txs *SqlTxs) *SqlTx

+ func (t *SqlTx) Run() (errTx error)

+ type SqlTxs struct

+ func NewSqlTxs() *SqlTxs

+ func (t *SqlTxs) AddTx(tx *SqlTx) *SqlTxs

+ func (t *SqlTxs) Run() (errTxI int, e error)

Dec 10, 2025

Changes in this version

+ func HasErrTx[T any](err any, errs ...error) bool

type ErrTx

+ func (t *ErrTx[T]) ForwardRange() iter.Seq[*ErrTx[T]]

type SqlTx

+ func (t *SqlTx[T]) StopWithErr(e error) *SqlTx[T]

Dec 10, 2025

Changes in this version

+ var ErrPreErrWrong = errors.New("ErrPreErrWrong")

Dec 1, 2025

Changes in this version

+ func ErrTxAllSkip[T any](err any) (allskip bool)

type ErrTx

+ SkipSet bool

Nov 27, 2025

Changes in this version

+ var ErrAfterExec = errors.New("ErrAfterExec")

+ var ErrAfterQuery = errors.New("ErrAfterQuery")

+ var ErrBeforeF = errors.New("ErrBeforeF")

+ var ErrBeginTx = errors.New("ErrBeginTx")

+ var ErrCommit = errors.New("ErrCommit")

+ var ErrExec = errors.New("ErrExec")

+ var ErrHadFin = errors.New("ErrHadFin")

+ var ErrQuery = errors.New("ErrQuery")

+ var ErrRollback = errors.New("ErrRollback")

+ var ErrTypNil = errors.New("ErrTypNil")

+ var ErrUndefinedTy = errors.New("ErrUndefinedTy")

+ type ErrTx struct

+ Err error

+ Raw *SqlFunc[T]

+ Typ error

+ func NewErrTx[T any](preErrTx error, Raw *SqlFunc[T], Typ, Err error) (n *ErrTx[T])

+ func (t *ErrTx[T]) Error() (s string)

+ func (t *ErrTx[T]) Is(e error) bool

type SqlFunc

+ BeforeF BeforeF[T]

+ func ParseErrTx[T any](err error) *SqlFunc[T]

+ func (t *SqlFunc[T]) Clear()

+ func (t *SqlFunc[T]) Copy(dest *SqlFunc[T])

type SqlTx

+ func (t *SqlTx[T]) RawDo(sqlF func(sqlf *SqlFunc[T])) *SqlTx[T]

+ type TxPool struct

+ func NewTxPool[T any](db *sql.DB) *TxPool[T]

+ func (t *TxPool[T]) BeginTx(ctx context.Context, opts ...*sql.TxOptions) *SqlTx[T]

Nov 23, 2025

Changes in this version

+ func DealRowsMapIter(rows *sql.Rows, caseSwitchF ...CaseSwitchF) iter.Seq[*Row[map[string]any]]

+ type CaseSwitchF func(string) string

+ var ToCamel CaseSwitchF = func(s string) string { ... }

+ type Row struct

+ Err error

+ Index int

+ Raw T

Nov 11, 2025

Changes in this version

+ func DealRowsIter[T any](rows *sql.Rows) iter.Seq2[*T, error]

type ReplaceF

+ var PlaceHolderC ReplaceF = func(index int, holder string) (replaceTo string) { ... }

type SqlTx

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

Jan 14, 2025

Changes in this version

+ type ReplaceF func(index int, holder string) (replaceTo string)

+ var PlaceHolderA ReplaceF = func(index int, holder string) (replaceTo string) { ... }

+ var PlaceHolderB ReplaceF = func(index int, holder string) (replaceTo string) { ... }

Nov 11, 2024

Changes in this version

type SqlFunc

+ Sql string

+ type Type int

Nov 25, 2023

Changes in this version

type SqlTx

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

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

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

May 2, 2023

Changes in this version

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

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

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

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

type SqlTx

+ 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]) DoPlaceHolder(sqlf SqlFunc[T], ptr any) *SqlTx[T]

Apr 26, 2023

Changes in this version

+ const Execf

+ const Queryf

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

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

+ type CanTx interface

+ BeginTx func(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

+ type SqlFunc struct

+ AfterEF func(dataP *T, result sql.Result, txE error) (dataPR *T, stopErr error)

+ AfterQF func(dataP *T, rows *sql.Rows, txE error) (dataPR *T, stopErr error)

+ Args []any

+ BeforeEF func(dataP *T, sqlf *SqlFunc[T], txE error) (dataPR *T, stopErr error)

+ BeforeQF func(dataP *T, sqlf *SqlFunc[T], txE error) (dataPR *T, stopErr error)

+ Ctx context.Context

+ Query string

+ SkipSqlErr bool

+ Ty int

+ type SqlTx struct

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

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

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