executor

Documentation

Index

• Constants
• func Ping(entry *logrus.Entry, instance *mdriver.DSN) error
• type BaseConn
  • func (c *BaseConn) Close()
  • func (c *BaseConn) Exec(query string) (driver.Result, error)
  • func (c *BaseConn) Logger() *logrus.Entry
  • func (c *BaseConn) Ping() error
  • func (c *BaseConn) Query(query string, args ...interface{}) ([]map[string]sql.NullString, error)
  • func (c *BaseConn) QueryWithContext(ctx context.Context, query string, args ...interface{}) (column []string, row [][]sql.NullString, err error)
  • func (c *BaseConn) Transact(qs ...string) ([]driver.Result, error)
• type Db
• type Executor
  • func NewExecutor(entry *logrus.Entry, instance *mdriver.DSN, schema string) (*Executor, error)
  • func NewMockExecutor() (*Executor, sqlmock.Sqlmock, error)
  • func (c *Executor) Explain(query string) (columns []string, rows [][]sql.NullString, err error)
  • func (c *Executor) FetchMasterBinlogPos() (string, int64, error)
  • func (c *Executor) GetExplainRecord(query string) ([]*ExplainRecord, error)
  • func (c *Executor) GetTableColumnsInfo(schema, tableName string) ([]*TableColumnsInfo, error)
  • func (c *Executor) GetTableIndexesInfo(schema, tableName string) ([]*TableIndexesInfo, error)
  • func (c *Executor) IsLowerCaseTableNames() bool
  • func (c *Executor) SetLowerCaseTableNames(lowerCaseTableNames bool)
  • func (c *Executor) ShowCreateTable(schema, tableName string) (string, error)
  • func (c *Executor) ShowCreateView(tableName string) (string, error)
  • func (c *Executor) ShowDatabases(ignoreSysDatabase bool) ([]string, error)
  • func (c *Executor) ShowDefaultConfiguration(sql, column string) (string, error)
  • func (c *Executor) ShowMasterStatus() ([]map[string]sql.NullString, error)
  • func (c *Executor) ShowSchemaTables(schema string) ([]string, error)
  • func (c *Executor) ShowSchemaViews(schema string) ([]string, error)
  • func (c *Executor) ShowTableSizeMB(schema, table string) (float64, error)
• type ExplainRecord
• type TableColumnsInfo
• type TableIndexesInfo

Constants

const (
	ExplainRecordExtraUsingFilesort  = "Using filesort"
	ExplainRecordExtraUsingTemporary = "Using temporary"

	ExplainRecordAccessTypeAll   = "ALL"
	ExplainRecordAccessTypeIndex = "index"
)

https://dev.mysql.com/doc/refman/5.7/en/explain-output.html#explain_rows

const DAIL_TIMEOUT = 5 * time.Second

Functions

func Ping

func Ping(entry *logrus.Entry, instance *mdriver.DSN) error

Types

type BaseConn

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

func (*BaseConn) Close

func (c *BaseConn) Close()

func (*BaseConn) Exec

func (c *BaseConn) Exec(query string) (driver.Result, error)

func (*BaseConn) Logger

func (c *BaseConn) Logger() *logrus.Entry

func (*BaseConn) Ping

func (c *BaseConn) Ping() error

func (*BaseConn) Query

func (c *BaseConn) Query(query string, args ...interface{}) ([]map[string]sql.NullString, error)

func (*BaseConn) QueryWithContext

func (c *BaseConn) QueryWithContext(ctx context.Context, query string, args ...interface{}) (column []string, row [][]sql.NullString, err error)

func (*BaseConn) Transact

func (c *BaseConn) Transact(qs ...string) ([]driver.Result, error)

type Db

type Db interface {
	Close()
	Ping() error
	Exec(query string) (driver.Result, error)
	Transact(qs ...string) ([]driver.Result, error)
	Query(query string, args ...interface{}) ([]map[string]sql.NullString, error)
	QueryWithContext(ctx context.Context, query string, args ...interface{}) (column []string, row [][]sql.NullString, err error)
	Logger() *logrus.Entry
}

type Executor

type Executor struct {
	Db Db
	// contains filtered or unexported fields
}

func NewExecutor

func NewExecutor(entry *logrus.Entry, instance *mdriver.DSN, schema string) (*Executor, error)

func NewMockExecutor

func NewMockExecutor() (*Executor, sqlmock.Sqlmock, error)

NewMockExecutor returns a new mock executor.

func (*Executor) Explain

func (c *Executor) Explain(query string) (columns []string, rows [][]sql.NullString, err error)

func (*Executor) FetchMasterBinlogPos

func (c *Executor) FetchMasterBinlogPos() (string, int64, error)

func (*Executor) GetExplainRecord

func (c *Executor) GetExplainRecord(query string) ([]*ExplainRecord, error)

func (*Executor) GetTableColumnsInfo

func (c *Executor) GetTableColumnsInfo(schema, tableName string) ([]*TableColumnsInfo, error)

func (*Executor) GetTableIndexesInfo

func (c *Executor) GetTableIndexesInfo(schema, tableName string) ([]*TableIndexesInfo, error)

func (*Executor) IsLowerCaseTableNames

func (c *Executor) IsLowerCaseTableNames() bool

func (*Executor) SetLowerCaseTableNames

func (c *Executor) SetLowerCaseTableNames(lowerCaseTableNames bool)

func (*Executor) ShowCreateTable

func (c *Executor) ShowCreateTable(schema, tableName string) (string, error)

When using keywords as table names, you need to pay attention to wrapping them in quotation marks

func (*Executor) ShowCreateView

func (c *Executor) ShowCreateView(tableName string) (string, error)

When using keywords as view names, you need to pay attention to wrapping them in quotation marks

func (*Executor) ShowDatabases

func (c *Executor) ShowDatabases(ignoreSysDatabase bool) ([]string, error)

func (*Executor) ShowDefaultConfiguration

func (c *Executor) ShowDefaultConfiguration(sql, column string) (string, error)

func (*Executor) ShowMasterStatus

func (c *Executor) ShowMasterStatus() ([]map[string]sql.NullString, error)

func (*Executor) ShowSchemaTables

func (c *Executor) ShowSchemaTables(schema string) ([]string, error)

func (*Executor) ShowSchemaViews

func (c *Executor) ShowSchemaViews(schema string) ([]string, error)

func (*Executor) ShowTableSizeMB

func (c *Executor) ShowTableSizeMB(schema, table string) (float64, error)

type ExplainRecord

type ExplainRecord struct {
	Id           string `json:"id"`
	SelectType   string `json:"select_type"`
	Table        string `json:"table"`
	Partitions   string `json:"partitions"`
	Type         string `json:"type"`
	PossibleKeys string `json:"possible_keys"`
	Key          string `json:"key"`
	KeyLen       string `json:"key_len"`
	Ref          string `json:"ref"`
	Rows         int64  `json:"rows"`
	Filtered     string `json:"filtered"`
	Extra        string `json:"extra"`
}

type TableColumnsInfo

type TableColumnsInfo struct {
	ColumnName       string
	ColumnType       string
	CharacterSetName string
	IsNullable       string
	ColumnKey        string
	ColumnDefault    string
	Extra            string
	ColumnComment    string
}

type TableIndexesInfo

type TableIndexesInfo struct {
	ColumnName  string
	KeyName     string
	NonUnique   string
	SeqInIndex  string
	Cardinality string
	Null        string
	IndexType   string
	Comment     string
}