engine

Dec 25, 2024

Changes in this version

+ func ParseTableName(sql string) string

+ func SetExecutorContext(ctx context.Context, ec *ExecutorContext) context.Context

+ type AfterHandler func(ctx context.Context, ec *ExecutorContext, er *ExecutorResult)

+ type Chain struct

+ func NewHookChain(hooks ...Hook) *Chain

+ func (c *Chain) After(ctx context.Context, ec *ExecutorContext, er *ExecutorResult)

+ func (c *Chain) Before(ctx context.Context, ec *ExecutorContext) error

+ type Execer interface

+ ExecContext func(ctx context.Context, execSQL string, args ...any) (sql.Result, error)

+ NamedExecContext func(ctx context.Context, execSQL string, arg any) (sql.Result, error)

+ type Executor interface

+ type ExecutorContext struct

+ Args []any

+ NameArgs any

+ SQL string

+ Start time.Time

+ TableName string

+ Type SQLType

+ func GetExecutorContext(ctx context.Context) *ExecutorContext

+ type ExecutorResult struct

+ Affected int64

+ Duration time.Duration

+ Err error

+ QueryRows int64

+ type Hook interface

+ After func(ctx context.Context, ec *ExecutorContext, er *ExecutorResult)

+ Before func(ctx context.Context, ec *ExecutorContext) error

+ type Queryer interface

+ GetContext func(ctx context.Context, dest any, query string, args ...any) error

+ QueryContext func(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ SelectContext func(ctx context.Context, dest any, query string, args ...any) error

+ type SQLType string

+ const DELETE

+ const INSERT

+ const SELECT

+ const UNKNOWN

+ const UPDATE

+ func ParseSQLType(query string) SQLType