internalExecutor

Documentation

Index

• type InternalExecResult
• type InternalExecutor
• type OptsBuilder
  • func NewOptsBuilder() *OptsBuilder
  • func (s *OptsBuilder) Database(db string) *OptsBuilder
  • func (s *OptsBuilder) Finish() SessionOverrideOptions
  • func (s *OptsBuilder) Internal(b bool) *OptsBuilder
  • func (s *OptsBuilder) Username(name string) *OptsBuilder
• type SessionOverrideOptions

Types

type InternalExecResult

type InternalExecResult interface {
	Error() error
	ColumnCount() uint64
	Column(context.Context, uint64) (string, uint8, bool, error) // type refer: pkg/defines/type.go & func convertEngineTypeToMysqlType
	RowCount() uint64
	Row(context.Context, uint64) ([]interface{}, error)
	Value(context.Context, uint64, uint64) (interface{}, error)
	ValueByName(context.Context, uint64, string) (interface{}, error)
	StringValueByName(context.Context, uint64, string) (string, error)
	Float64ValueByName(context.Context, uint64, string) (float64, error)
}

type InternalExecutor

type InternalExecutor interface {
	// exec sql without returning results set
	Exec(context.Context, string, SessionOverrideOptions) error
	// exec sql and return results set
	Query(context.Context, string, SessionOverrideOptions) InternalExecResult
	// override session for the executor scope
	ApplySessionOverride(SessionOverrideOptions)
}

type OptsBuilder

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

func NewOptsBuilder

func NewOptsBuilder() *OptsBuilder

func (*OptsBuilder) Database

func (s *OptsBuilder) Database(db string) *OptsBuilder

func (*OptsBuilder) Finish

func (s *OptsBuilder) Finish() SessionOverrideOptions

func (*OptsBuilder) Internal

func (s *OptsBuilder) Internal(b bool) *OptsBuilder

func (*OptsBuilder) Username

func (s *OptsBuilder) Username(name string) *OptsBuilder

type SessionOverrideOptions

type SessionOverrideOptions struct {
	Database   *string
	Username   *string
	IsInternal *bool
}