internalExecutor

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 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 struct {
	// contains filtered or unexported fields
}

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