execute

Documentation

Index

• Constants
• func Start(ec *config.ExecuteConfig, dbc *config.DBConfig)
• type Executor
  • func NewExecutor(ec *config.ExecuteConfig, dbc *config.DBConfig) *Executor
  • func (this *Executor) IncrCount()
  • func (this *Executor) Start() error
• type SqlContext
  • func NewSqlContext(sql string, tag int64) *SqlContext

Constants

const (
	DEFAULT_READ_SIZE = 8192
)

Functions

func Start

func Start(ec *config.ExecuteConfig, dbc *config.DBConfig)

Types

type Executor

type Executor struct {
	EmitSuccess bool
	ExecSuccess bool
	ParseCount  int64
	ExecCount   int64
	// contains filtered or unexported fields
}

func NewExecutor

func NewExecutor(ec *config.ExecuteConfig, dbc *config.DBConfig) *Executor

func (*Executor) IncrCount

func (this *Executor) IncrCount()

func (*Executor) Start

func (this *Executor) Start() error

type SqlContext

type SqlContext struct {
	Sql string
	Tag int64
}

func NewSqlContext

func NewSqlContext(sql string, tag int64) *SqlContext