incoming

package
v0.0.0-...-c0343d2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 24, 2023 License: LGPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

type SelectSQLModifications

type SelectSQLModifications []SelectSQLModification

func (SelectSQLModifications) Run

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL