driver

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

type BinaryRows struct {
	BaseRows
}

type Cond struct {
	// Cond type.
	Type CondType

	// Query string
	Query string

	// Query results
	Result *sqltypes.Result

	// Panic or Not
	Panic bool

	// Return Error if Error is not nil
	Error error

	// Delay(ms) for results return
	Delay int
}

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

type CondType int

type Conn interface {
	Ping() error
	Quit()
	Close() error
	Closed() bool
	Cleanup()
	NextPacket() ([]byte, error)

	// ConnectionID is the connection id at greeting.
	ConnectionID() uint32

	InitDB(db string) error
	Command(command byte) error
	Query(sql string) (Rows, error)
	Exec(sql string) error
	FetchAll(sql string, maxrows int) (*sqltypes.Result, error)
	FetchAllWithFunc(sql string, maxrows int, fn Func) (*sqltypes.Result, error)
	ComStatementPrepare(sql string) (*Statement, error)
}

type Func func(rows Rows) error

type Handler interface {
	ServerVersion() string
	SetServerVersion()
	NewSession(session *Session)
	SessionInc(session *Session)
	SessionDec(session *Session)
	SessionClosed(session *Session)
	SessionCheck(session *Session) error
	AuthCheck(session *Session) error
	ComInitDB(session *Session, database string) error
	ComQuery(session *Session, query string, bindVariables map[string]*querypb.BindVariable, callback func(*sqltypes.Result) error) error
}

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

type RowMode int

type Rows interface {
	Next() bool
	Close() error
	Datas() []byte
	Bytes() int
	RowsAffected() uint64
	LastInsertID() uint64
	LastError() error
	Fields() []*querypb.Field
	RowValues() ([]sqltypes.Value, error)
}

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

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

type Statement struct {
	ID          uint32
	ParamCount  uint16
	PrepareStmt string
	ParamsType  []int32
	ColumnNames []string
	BindVars    map[string]*querypb.BindVariable
	// contains filtered or unexported fields
}

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

type TextRows struct {
	BaseRows
}