executor

type CardinalityInfo struct {
	*ExplainAnalyzeInfo
	QError float64
}

type Comparable interface {
	fmt.Stringer
	Equal(other Comparable) bool
}

type Executor interface {
	Dsn() string
	Query(query string) (Rows, error)
	QueryStream(query string) (RowStream, error)
	Exec(query string) (Result, error)
	GetHints(query string) (Hints, error)
	Explain(query string) (Rows, []error, error)
	ExplainAnalyze(query string) (Rows, []error, error)
}

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

type ExplainAnalyzeInfo struct {
	Op      string
	EstRows float64
	ActRows float64
	OpInfo  string
	Items   []*ExplainAnalyzeInfo
	// contains filtered or unexported fields
}

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

type Pool interface {
	Dsn() string
	Executor() Executor
	Transaction() (Transaction, error)
}

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

type PoolOptions struct {
	MaxOpenConns   uint `json:"max_open_conns"`
	MaxIdleConns   uint `json:"max_idle_conns"`
	MaxLifeSeconds uint `json:"max_life_seconds"`
}

type QueryMode uint8

type RawExecutor interface {
	Query(query string, args ...interface{}) (*sql.Rows, error)
	Exec(query string, args ...interface{}) (sql.Result, error)
}

type RawTransaction interface {
	RawExecutor
	Commit() error
	Rollback() error
}

type Result struct {
	LastInsertId, RowsAffected int64
}

type Row [][]byte

type RowStream struct {
	ColumnsMap map[string]int
	Columns    Row
	// contains filtered or unexported fields
}

type Rows struct {
	ColumnMap map[string]int
	Columns   Row
	Data      []Row
}

type Transaction interface {
	Executor
	Commit() error
	Rollback() error
}

type TransactionImpl struct {
	ExecutorImpl
	// contains filtered or unexported fields
}