incoming

Documentation

Index

• func BuildSimpleBinaryResultset(names []string, values [][]interface{}) (*mysql.Resultset, error)
• func BuildSimpleResultset(names []string, values [][]interface{}, binary bool) (*mysql.Resultset, error)
• func BuildSimpleTextResultset(names []string, values [][]interface{}) (*mysql.Resultset, error)
• func FormatTextValue(value interface{}) ([]byte, error)
• type LimitOffset
  • func (node *LimitOffset) Format(buf *sqlparser.TrackedBuffer)
• type ModificationSpec
• type ModifiedSelect
  • func (node *ModifiedSelect) Format(buf *sqlparser.TrackedBuffer)
• type MysqlIncomingHandler
  • func NewMysqlIncomingHandler(addr string, pgbackend *PgBackend) *MysqlIncomingHandler
  • func (m *MysqlIncomingHandler) Startup() error
• type PgBackend
  • func NewPgBackend(connString string) (*PgBackend, error)
  • func (b *PgBackend) HandleSelect(selectQuery string) (*mysql.Result, error)
• type SelectResultSetDataMapping
• type SelectResultSetDataMappings
  • func (s SelectResultSetDataMappings) Run(in [][]interface{}) ([][]interface{}, error)
• type SelectSQLModification
• type SelectSQLModificationTool
  • func (s SelectSQLModificationTool) AddQuotesToSupportIdentifierCaseSensitive(in string) (string, ModificationSpec, error)
  • func (s SelectSQLModificationTool) FixDistinctOrderByFieldShouldBeInSelectExpr(in string) (string, ModificationSpec, error)
  • func (s SelectSQLModificationTool) LimitAndOffset(in string) (string, ModificationSpec, error)
• type SelectSQLModifications
  • func (m SelectSQLModifications) Run(in string) (string, ModificationSpec, error)

Functions

func BuildSimpleBinaryResultset

func BuildSimpleBinaryResultset(names []string, values [][]interface{}) (*mysql.Resultset, error)

func BuildSimpleResultset

func BuildSimpleResultset(names []string, values [][]interface{}, binary bool) (*mysql.Resultset, error)

func BuildSimpleTextResultset

func BuildSimpleTextResultset(names []string, values [][]interface{}) (*mysql.Resultset, error)

func FormatTextValue

func FormatTextValue(value interface{}) ([]byte, error)

Types

type LimitOffset

type LimitOffset struct {
	sqlparser.Limit
}

func (*LimitOffset) Format

func (node *LimitOffset) Format(buf *sqlparser.TrackedBuffer)

type ModificationSpec

type ModificationSpec struct {
	AddedLastMetaColumnCnt int
}

type ModifiedSelect

type ModifiedSelect struct {
	Cache       string
	Comments    sqlparser.Comments
	Distinct    string
	Hints       string
	SelectExprs sqlparser.SelectExprs
	From        sqlparser.TableExprs
	Where       *sqlparser.Where
	GroupBy     sqlparser.GroupBy
	Having      *sqlparser.Where
	OrderBy     sqlparser.OrderBy
	Limit       *LimitOffset
	Lock        string
}

func (*ModifiedSelect) Format

func (node *ModifiedSelect) Format(buf *sqlparser.TrackedBuffer)

type MysqlIncomingHandler

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

func NewMysqlIncomingHandler

func NewMysqlIncomingHandler(addr string, pgbackend *PgBackend) *MysqlIncomingHandler

func (*MysqlIncomingHandler) Startup

func (m *MysqlIncomingHandler) Startup() error

type PgBackend

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

func NewPgBackend

func NewPgBackend(connString string) (*PgBackend, error)

func (*PgBackend) HandleSelect

func (b *PgBackend) HandleSelect(selectQuery string) (*mysql.Result, error)

type SelectResultSetDataMapping

type SelectResultSetDataMapping struct {
}

type SelectResultSetDataMappings

type SelectResultSetDataMappings []func([][]interface{}) [][]interface{}

func (SelectResultSetDataMappings) Run

func (s SelectResultSetDataMappings) Run(in [][]interface{}) ([][]interface{}, error)

type SelectSQLModification

type SelectSQLModification func(in string) (string, ModificationSpec, error)

type SelectSQLModificationTool

type SelectSQLModificationTool struct {
}

func (SelectSQLModificationTool) AddQuotesToSupportIdentifierCaseSensitive

func (s SelectSQLModificationTool) AddQuotesToSupportIdentifierCaseSensitive(in string) (string, ModificationSpec, error)

func (SelectSQLModificationTool) FixDistinctOrderByFieldShouldBeInSelectExpr

func (s SelectSQLModificationTool) FixDistinctOrderByFieldShouldBeInSelectExpr(in string) (string, ModificationSpec, error)

func (SelectSQLModificationTool) LimitAndOffset

func (s SelectSQLModificationTool) LimitAndOffset(in string) (string, ModificationSpec, error)

type SelectSQLModifications

type SelectSQLModifications []SelectSQLModification

func (SelectSQLModifications) Run

func (m SelectSQLModifications) Run(in string) (string, ModificationSpec, error)