exec

type BaseExecutor struct {
	// contains filtered or unexported fields
}

type CallbackWithNamedValue func(ctx context.Context, query string, args []driver.NamedValue) (types.ExecResult, error)

type CallbackWithValue func(ctx context.Context, query string, args []driver.Value) (types.ExecResult, error)

type SQLExecutor interface {
	// Interceptors
	Interceptors(interceptors []SQLHook)
	// Exec
	ExecWithNamedValue(ctx context.Context, execCtx *types.ExecContext, f CallbackWithNamedValue) (types.ExecResult, error)
	// Exec
	ExecWithValue(ctx context.Context, execCtx *types.ExecContext, f CallbackWithValue) (types.ExecResult, error)
}

type SQLHook interface {
	Type() types.SQLType

	// Before
	Before(ctx context.Context, execCtx *types.ExecContext) error

	// After
	After(ctx context.Context, execCtx *types.ExecContext) error
}

type SelectForUpdateExecutor struct {
	builder.BasicUndoLogBuilder
}