Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

executor

package

Go to main page

Versions in this module

v1

v1.0.0

Mar 31, 2021

Changes in this version

type Executor

+ Dsn func() string

type ExecutorImpl

+ func (e *ExecutorImpl) Dsn() string

type Pool

+ Dsn func() string

type PoolImpl

+ func (p *PoolImpl) Dsn() string

v0

v0.9.2

Sep 21, 2020

v0.9.1

Sep 10, 2020

v0.9.0

Aug 20, 2020

Changes in this version

+ func PlanOutOfRange(err error) bool

+ func Warning(row Row) (warning error, err error)

+ type CardinalityInfo struct

+ QError float64

+ func CollectEstAndActRows(ei *ExplainAnalyzeInfo) []*CardinalityInfo

+ type Comparable interface

+ Equal func(other Comparable) bool

+ type Executor interface

+ Exec func(query string) (Result, error)

+ Explain func(query string) (Rows, []error, error)

+ ExplainAnalyze func(query string) (Rows, []error, error)

+ GetHints func(query string) (Hints, error)

+ Query func(query string) (Rows, error)

+ QueryStream func(query string) (RowStream, error)

+ type ExecutorImpl struct

+ func (e *ExecutorImpl) Exec(query string) (result Result, err error)

+ func (e *ExecutorImpl) Explain(query string) (rows Rows, warnings []error, err error)

+ func (e *ExecutorImpl) ExplainAnalyze(query string) (rows Rows, warnings []error, err error)

+ func (e *ExecutorImpl) GetHints(query string) (hints Hints, err error)

+ func (e *ExecutorImpl) Query(query string) (rows Rows, err error)

+ func (e *ExecutorImpl) QueryStream(query string) (stream RowStream, err error)

+ type ExplainAnalyzeInfo struct

+ ActRows float64

+ EstRows float64

+ Items []*ExplainAnalyzeInfo

+ Op string

+ OpInfo string

+ func NewExplainAnalyzeInfo(data Rows) *ExplainAnalyzeInfo

+ type Hints struct

+ func NewHints(raw string) Hints

+ func (h Hints) Equal(other Hints) bool

+ func (h Hints) String() string

+ type Pool interface

+ Executor func() Executor

+ Transaction func() (Transaction, error)

+ func NewPool(dsn string, options *PoolOptions) (pool Pool, err error)

+ type PoolImpl struct

+ func (p *PoolImpl) Executor() Executor

+ func (p *PoolImpl) Transaction() (Transaction, error)

+ type PoolOptions struct

+ MaxIdleConns uint

+ MaxLifeSeconds uint

+ MaxOpenConns uint

+ type QueryMode uint8

+ type RawExecutor interface

+ Exec func(query string, args ...interface{}) (sql.Result, error)

+ Query func(query string, args ...interface{}) (*sql.Rows, error)

+ type RawTransaction interface

+ Commit func() error

+ Rollback func() error

+ type Result struct

+ LastInsertId int64

+ RowsAffected int64

+ func NewResult(result sql.Result) (ret Result, err error)

+ func (r Result) Equal(other Comparable) bool

+ func (r Result) String() string

+ type Row [][]byte

+ func (r Row) Equal(other Row) bool

+ func (r Row) ToTableRow() table.Row

+ type RowStream struct

+ Columns Row

+ ColumnsMap map[string]int

+ func NewRowStream(rows *sql.Rows) (ret RowStream, err error)

+ func (s *RowStream) Next() (row Row, err error)

+ func (s *RowStream) NextBatch(size uint) (rows []Row, err error)

+ type Rows struct

+ ColumnMap map[string]int

+ Columns Row

+ Data []Row

+ func NewRows(rows *sql.Rows) (ret Rows, err error)

+ func (r Rows) ColumnNums() int

+ func (r Rows) Equal(other Comparable) bool

+ func (r Rows) RowCount() int

+ func (r Rows) String() string

+ type Transaction interface

+ Commit func() error

+ Rollback func() error

+ type TransactionImpl struct

+ func (t *TransactionImpl) Commit() error

+ func (t *TransactionImpl) Rollback() error