engine

package
v0.0.42 Latest Latest
Warning

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

 Go to latest Published: Sep 21, 2023 License: Apache-2.0 Imports: 57 Imported by: 0

Documentation

Index

Constants

View Source 
const TimeBucketName = "time_bucket"

Variables

View Source 
var (

	// ErrRowTimeout will be returned if the wait for the row is longer than the connection timeout
	ErrRowTimeout = errors.NewKind("row read wait bigger than connection timeout")

	// ErrConnectionWasClosed will be returned if we try to use a previously closed connection
	ErrConnectionWasClosed = errors.NewKind("connection was closed")
)
View Source 
var Columns, Indexed = func() (o []storev1.Column, idx map[string]storev1.Column) {
	idx = make(map[string]storev1.Column)
	for i := storev1.Column_bounce; i <= storev1.Column_utm_term; i++ {
		idx[i.String()] = i
		o = append(o, i)
	}
	return
}()
View Source 
var ErrNoFilter = errors.New("no filters")

Functions

func BuildValueFilter added in v0.0.41 

func BuildValueFilter(ctx context.Context,
	f []ValueFilter,
	source func(v1.Column) arrow.Array) (arrow.Array, error)

func NewTimeBucket added in v0.0.40 

func NewTimeBucket(args ...sql.Expression) (sql.Expression, error)

Types

type DB added in v0.0.28 

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

func NewDB added in v0.0.42 

func NewDB(db db.Provider, rd b3.Reader, e func() *sqle.Engine) *DB

func (*DB) AllViews added in v0.0.42 

func (db *DB) AllViews(ctx *sql.Context) ([]sql.ViewDefinition, error)

func (*DB) CreateView added in v0.0.42 

func (db *DB) CreateView(ctx *sql.Context, name string, selectStatement, createViewStmt string) error

func (*DB) DropView added in v0.0.42 

func (db *DB) DropView(ctx *sql.Context, name string) error

func (*DB) GetTableInsensitive added in v0.0.28 

func (db *DB) GetTableInsensitive(ctx *sql.Context, tblName string) (table sql.Table, ok bool, err error)

func (*DB) GetTableNames added in v0.0.28 

func (db *DB) GetTableNames(ctx *sql.Context) (names []string, err error)

func (*DB) GetViewDefinition added in v0.0.42 

func (db *DB) GetViewDefinition(ctx *sql.Context, viewName string) (sql.ViewDefinition, bool, error)

func (DB) IsReadOnly added in v0.0.28 

func (DB) IsReadOnly() bool

func (DB) Name added in v0.0.28 

func (DB) Name() string

type Engine 

type Engine struct {
	*sqle.Engine
}

func Get 

func Get(ctx context.Context) *Engine

func New 

func New(ctx context.Context) *Engine

func Open 

func Open(ctx context.Context) (context.Context, *Engine)

type FieldHint added in v0.0.42 

type FieldHint struct {
	Field string
	Op    Op
	Value any
}

type FilterIndex added in v0.0.41 

type FilterIndex func(ctx context.Context, idx *blocksv1.ColumnIndex) (*RowGroups, error)

type FilterValue added in v0.0.41 

type FilterValue func(ctx context.Context, b *array.BooleanBuilder, value arrow.Array) (arrow.Array, error)

type Filters added in v0.0.42 

type Filters struct {
	Index []IndexFilter
	Value []ValueFilter
}

type Handler 

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

Handler is a connection handler for a SQLe engine, implementing the Vitess mysql.Handler interface.

func (*Handler) ComInitDB 

func (h *Handler) ComInitDB(c *mysql.Conn, schemaName string) error

func (*Handler) ComMultiQuery 

func (h *Handler) ComMultiQuery(
	c *mysql.Conn,
	query string,
	callback func(*sqltypes.Result, bool) error,
) (string, error)

func (*Handler) ComPrepare 

func (h *Handler) ComPrepare(c *mysql.Conn, query string) ([]*query.Field, error)

ComPrepare parses, partially analyzes, and caches a prepared statement's plan with the given [c.ConnectionID].

func (*Handler) ComQuery 

func (h *Handler) ComQuery(
	c *mysql.Conn,
	query string,
	callback func(*sqltypes.Result, bool) error,
) error

ComQuery executes a SQL query on the SQLe engine.

func (*Handler) ComResetConnection 

func (h *Handler) ComResetConnection(c *mysql.Conn)

func (*Handler) ComStmtExecute 

func (h *Handler) ComStmtExecute(c *mysql.Conn, prepare *mysql.PrepareData, callback func(*sqltypes.Result) error) error

func (*Handler) ConnectionClosed 

func (h *Handler) ConnectionClosed(c *mysql.Conn)

ConnectionClosed reports that a connection has been closed.

func (*Handler) NewConnection 

func (h *Handler) NewConnection(c *mysql.Conn)

NewConnection reports that a new connection has been established.

func (*Handler) ParserOptionsForConnection 

func (h *Handler) ParserOptionsForConnection(c *mysql.Conn) (sqlparser.ParserOptions, error)

func (*Handler) WarningCount 

func (h *Handler) WarningCount(c *mysql.Conn) uint16

WarningCount is called at the end of each query to obtain the value to be returned to the client in the EOF packet. Note that this will be called either in the context of the ComQuery callback if the result does not contain any fields, or after the last ComQuery call completes.

type IndexFilter added in v0.0.41 

type IndexFilter interface {
	Column() v1.Column
	FilterIndex(ctx context.Context, idx *blocksv1.ColumnIndex) (*RowGroups, error)
}

IndexFilter is an interface for choosing row groups and row group pages to read based on a column index.

This filter is first applied before values are read into arrow.Record. Only row groups and row group pages that matches across all IndexFilter are selected for reads

type IndexFilterResult added in v0.0.42 

type IndexFilterResult struct {
	RowGroups []uint
	Pages     []*bitset.BitSet
}

func BuildIndexFilter added in v0.0.41 

func BuildIndexFilter(
	ctx context.Context,
	f []IndexFilter, source func(v1.Column) *blocksv1.ColumnIndex) (*IndexFilterResult, error)

type IndexHint added in v0.0.42 

type IndexHint struct {
	Fields []*FieldHint
}

func (*IndexHint) Visit added in v0.0.42 

func (v *IndexHint) Visit(node sql.Node, expr sql.Expression) sql.NodeVisitor

type IndexMatchFuncs added in v0.0.41 

type IndexMatchFuncs struct {
	Col             v1.Column
	FilterIndexFunc func(ctx context.Context, idx *blocksv1.ColumnIndex) (*RowGroups, error)
}

func (*IndexMatchFuncs) Column added in v0.0.41 

func (i *IndexMatchFuncs) Column() v1.Column

func (*IndexMatchFuncs) FilterIndex added in v0.0.41 

func (i *IndexMatchFuncs) FilterIndex(ctx context.Context, idx *blocksv1.ColumnIndex) (*RowGroups, error)

type MultiStmtMode added in v0.0.38 

type MultiStmtMode int
const (
	MultiStmtModeOff MultiStmtMode = 0
	MultiStmtModeOn  MultiStmtMode = 1
)

type Op added in v0.0.41 

type Op uint
const (
	Eq Op = 1 + iota
	Ne
	Gt
	GtEg
	Lt
	LtEq
	ReEq
	ReNe
)

func (Op) String added in v0.0.41 

func (o Op) String() string

type Partition added in v0.0.28 

type Partition struct {
	Info  blocksv1.BlockInfo
	Hints *IndexHint
}

func (*Partition) Key added in v0.0.28 

func (p *Partition) Key() []byte

type PlaintextAuthPluginFunc added in v0.0.42 

type PlaintextAuthPluginFunc func(db *mysql_db.MySQLDb,
	user string, userEntry *mysql_db.User, pass string) (bool, error)

func (PlaintextAuthPluginFunc) Authenticate added in v0.0.42 

func (f PlaintextAuthPluginFunc) Authenticate(db *mysql_db.MySQLDb,
	user string, userEntry *mysql_db.User, pass string) (bool, error)

type Provider 

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

func (*Provider) AllDatabases 

func (p *Provider) AllDatabases(_ *sql.Context) []sql.Database

func (*Provider) Database 

func (p *Provider) Database(_ *sql.Context, name string) (sql.Database, error)

func (*Provider) Function added in v0.0.40 

func (p *Provider) Function(ctx *sql.Context, name string) (sql.Function, error)

func (*Provider) HasDatabase 

func (p *Provider) HasDatabase(_ *sql.Context, name string) bool

type RowGroups added in v0.0.42 

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

func (*RowGroups) SelectGroup added in v0.0.42 

func (g *RowGroups) SelectGroup(groups *bitset.BitSet, f func(uint, *bitset.BitSet))

func (*RowGroups) Set added in v0.0.42 

func (g *RowGroups) Set(index uint, pages []uint)

type Server added in v0.0.24 

type Server struct {
	*mysql.Listener
}

func Listen added in v0.0.24 

func Listen(ctx context.Context) (*Server, error)

func (*Server) Close added in v0.0.24 

func (s *Server) Close() error

func (*Server) Start added in v0.0.24 

func (s *Server) Start() error

type Table 

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

func (*Table) Collation added in v0.0.28 

func (t *Table) Collation() sql.CollationID

func (*Table) Name added in v0.0.28 

func (t *Table) Name() string

func (*Table) PartitionRows added in v0.0.28 

func (t *Table) PartitionRows(ctx *sql.Context, partition sql.Partition) (sql.RowIter, error)

func (*Table) Partitions added in v0.0.28 

func (t *Table) Partitions(ctx *sql.Context) (sql.PartitionIter, error)

func (*Table) Projections added in v0.0.28 

func (t *Table) Projections() (o []string)

func (*Table) Schema added in v0.0.28 

func (t *Table) Schema() sql.Schema

func (*Table) String added in v0.0.28 

func (t *Table) String() string

func (*Table) WithProjections added in v0.0.28 

func (t *Table) WithProjections(colNames []string) sql.Table

type TimeBucket added in v0.0.40 

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

func (*TimeBucket) Children added in v0.0.40 

func (t *TimeBucket) Children() []sql.Expression

Children implements the sql.Expression interface.

func (*TimeBucket) Description added in v0.0.40 

func (t *TimeBucket) Description() string

Description implements sql.FunctionExpression

func (*TimeBucket) Eval added in v0.0.40 

func (t *TimeBucket) Eval(ctx *sql.Context, row sql.Row) (interface{}, error)

Eval implements the sql.Expression interface.

func (*TimeBucket) FunctionName added in v0.0.40 

func (t *TimeBucket) FunctionName() string

FunctionName implements sql.FunctionExpression

func (*TimeBucket) IsNullable added in v0.0.40 

func (t *TimeBucket) IsNullable() bool

IsNullable implements the sql.Expression interface.

func (*TimeBucket) Resolved added in v0.0.40 

func (t *TimeBucket) Resolved() bool

Resolved implements the sql.Expression interface.

func (*TimeBucket) String added in v0.0.40 

func (t *TimeBucket) String() string

func (*TimeBucket) Type added in v0.0.40 

func (t *TimeBucket) Type() sql.Type

Type implements the sql.Expression interface.

func (*TimeBucket) WithChildren added in v0.0.40 

func (t *TimeBucket) WithChildren(children ...sql.Expression) (sql.Expression, error)

WithChildren implements the Expression interface.

type Value added in v0.0.42 

type Value interface {
	~int64 |
		float64 | string
}

type ValueFilter added in v0.0.41 

type ValueFilter interface {
	Column() v1.Column
	FilterValue(ctx context.Context, value arrow.Array) (arrow.Array, error)
}

func Match added in v0.0.41 

func Match[T Value](col v1.Column, matchValue T, op Op) ValueFilter

type ValueMatchFuncs added in v0.0.41 

type ValueMatchFuncs struct {
	Col             v1.Column
	FilterValueFunc func(ctx context.Context, value arrow.Array) (arrow.Array, error)
}

func (*ValueMatchFuncs) Column added in v0.0.41 

func (i *ValueMatchFuncs) Column() v1.Column

func (*ValueMatchFuncs) FilterValue added in v0.0.41 

func (i *ValueMatchFuncs) FilterValue(ctx context.Context, value arrow.Array) (arrow.Array, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.