rowexec

Documentation

Index

• Constants
• Variables
• func AddAccumulatorIter(ctx *sql.Context, iter sql.RowIter) (sql.RowIter, sql.Schema)
• func AddExpressionCloser(node sql.Node, iter sql.RowIter) sql.RowIter
• func AddTransactionCommittingIter(ctx *sql.Context, qFlags *sql.QueryFlags, iter sql.RowIter) (sql.RowIter, error)
• func AddTriggerRollbackIter(ctx *sql.Context, qFlags *sql.QueryFlags, iter sql.RowIter) sql.RowIter
• func FinalizeIters(ctx *sql.Context, analyzed sql.Node, qFlags *sql.QueryFlags, iter sql.RowIter) (sql.RowIter, sql.Schema, error)
• func GetColumnsAndPrepareExpressions(exprs []sql.Expression) ([]string, []sql.Expression, error)
• func NewLeftMergeJoin(left, right sql.Node, cond sql.Expression) *plan.JoinNode
• func NewMergeJoin(left, right sql.Node, cond sql.Expression) *plan.JoinNode
• func NewOverrideBuilder(override sql.NodeExecBuilder) sql.NodeExecBuilder
• func ProjectRow(ctx *sql.Context, projections []sql.Expression, row sql.Row) (sql.Row, error)
• type BaseBuilder
  • func (b *BaseBuilder) Build(ctx *sql.Context, n sql.Node, r sql.Row) (sql.RowIter, error)
• type EvalPartitionKeyValueIter
  • func NewEvalPartitionKeyValueIter(iter sql.PartitionIndexKeyValueIter, columns []string, exprs []sql.Expression) *EvalPartitionKeyValueIter
  • func (i *EvalPartitionKeyValueIter) Close(ctx *sql.Context) error
  • func (i *EvalPartitionKeyValueIter) Next(ctx *sql.Context) (sql.Partition, sql.IndexKeyValueIter, error)
• type ExecBuilderFunc
• type ExprCloserIter
  • func (eci *ExprCloserIter) Close(ctx *sql.Context) error
  • func (eci *ExprCloserIter) GetIter() sql.RowIter
  • func (eci *ExprCloserIter) Next(ctx *sql.Context) (sql.Row, error)
  • func (eci *ExprCloserIter) WithChildIter(childIter sql.RowIter) sql.RowIter
• type FulltextFilterTable
  • func (f *FulltextFilterTable) Collation() sql.CollationID
  • func (f *FulltextFilterTable) LookupPartitions(ctx *sql.Context, lookup sql.IndexLookup) (sql.PartitionIter, error)
  • func (f *FulltextFilterTable) Name() string
  • func (f *FulltextFilterTable) PartitionRows(ctx *sql.Context, partition sql.Partition) (sql.RowIter, error)
  • func (f *FulltextFilterTable) Partitions(ctx *sql.Context) (sql.PartitionIter, error)
  • func (f *FulltextFilterTable) Schema() sql.Schema
  • func (f *FulltextFilterTable) String() string
• type NameAndSchema
• type ProjectIter
  • func (i *ProjectIter) CanDefer() bool
  • func (i *ProjectIter) Close(ctx *sql.Context) error
  • func (i *ProjectIter) GetChildIter() sql.RowIter
  • func (i *ProjectIter) GetProjections() []sql.Expression
  • func (i *ProjectIter) Next(ctx *sql.Context) (sql.Row, error)
• type TransactionCommittingIter
  • func (t *TransactionCommittingIter) Close(ctx *sql.Context) error
  • func (t *TransactionCommittingIter) GetIter() sql.RowIter
  • func (t *TransactionCommittingIter) Next(ctx *sql.Context) (sql.Row, error)
  • func (t *TransactionCommittingIter) WithChildIter(childIter sql.RowIter) sql.RowIter

Constants

const TriggerSavePointPrefix = "__go_mysql_server_trigger_savepoint__"

Variables

var DefaultBuilder = &BaseBuilder{}

var ErrTableNotLockable = errors.NewKind("table %s is not lockable")

ErrTableNotLockable is returned whenever a lockable table can't be found.

Functions

func AddAccumulatorIter

func AddAccumulatorIter(ctx *sql.Context, iter sql.RowIter) (sql.RowIter, sql.Schema)

func AddExpressionCloser

func AddExpressionCloser(node sql.Node, iter sql.RowIter) sql.RowIter

AddExpressionCloser returns a new iterator that ensures that any expressions that implement sql.Closer are closed. If there are no expressions that implement sql.Closer in the tree, then the original iterator is returned.

func AddTransactionCommittingIter

func AddTransactionCommittingIter(ctx *sql.Context, qFlags *sql.QueryFlags, iter sql.RowIter) (sql.RowIter, error)

func AddTriggerRollbackIter

func AddTriggerRollbackIter(ctx *sql.Context, qFlags *sql.QueryFlags, iter sql.RowIter) sql.RowIter

func FinalizeIters

func FinalizeIters(ctx *sql.Context, analyzed sql.Node, qFlags *sql.QueryFlags, iter sql.RowIter) (sql.RowIter, sql.Schema, error)

FinalizeIters applies the final transformations on sql.RowIter before execution.

func GetColumnsAndPrepareExpressions

func GetColumnsAndPrepareExpressions(
	exprs []sql.Expression,
) ([]string, []sql.Expression, error)

GetColumnsAndPrepareExpressions extracts the unique columns required by all those expressions and fixes the indexes of the GetFields in the expressions to match a row with only the returned columns in that same order.

func NewLeftMergeJoin

func NewLeftMergeJoin(left, right sql.Node, cond sql.Expression) *plan.JoinNode

func NewMergeJoin

func NewMergeJoin(left, right sql.Node, cond sql.Expression) *plan.JoinNode

NewMergeJoin returns a node that performs a presorted merge join on two relations. We require 1) the join filter is an equality with disjoint join attributes, 2) the free attributes for a relation are a prefix for an index that will be used to return sorted rows.

func NewOverrideBuilder

func NewOverrideBuilder(override sql.NodeExecBuilder) sql.NodeExecBuilder

func ProjectRow

func ProjectRow(
	ctx *sql.Context,
	projections []sql.Expression,
	row sql.Row,
) (sql.Row, error)

ProjectRow evaluates a set of projections.

Types

type BaseBuilder

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

BaseBuilder converts a plan tree into a RowIter tree. All relational nodes have a build statement. Custom source nodes that provide rows that implement sql.ExecSourceRel are also built into the tree.

func (*BaseBuilder) Build

func (b *BaseBuilder) Build(ctx *sql.Context, n sql.Node, r sql.Row) (sql.RowIter, error)

type EvalPartitionKeyValueIter

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

func NewEvalPartitionKeyValueIter

func NewEvalPartitionKeyValueIter(iter sql.PartitionIndexKeyValueIter, columns []string, exprs []sql.Expression) *EvalPartitionKeyValueIter

func (*EvalPartitionKeyValueIter) Close

func (i *EvalPartitionKeyValueIter) Close(ctx *sql.Context) error

func (*EvalPartitionKeyValueIter) Next

func (i *EvalPartitionKeyValueIter) Next(ctx *sql.Context) (sql.Partition, sql.IndexKeyValueIter, error)

type ExecBuilderFunc

type ExecBuilderFunc func(ctx *sql.Context, n sql.Node, r sql.Row) (sql.RowIter, error)

type ExprCloserIter

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

ExprCloserIter ensures that all expressions that implement sql.Closer are closed. This is implemented as a capturing iterator, as our workflow only supports closing nodes, not expressions.

func (*ExprCloserIter) Close

func (eci *ExprCloserIter) Close(ctx *sql.Context) error

Close implements the interface sql.RowIter.

func (*ExprCloserIter) GetIter

func (eci *ExprCloserIter) GetIter() sql.RowIter

func (*ExprCloserIter) Next

func (eci *ExprCloserIter) Next(ctx *sql.Context) (sql.Row, error)

Next implements the interface sql.RowIter.

func (*ExprCloserIter) WithChildIter

func (eci *ExprCloserIter) WithChildIter(childIter sql.RowIter) sql.RowIter

type FulltextFilterTable

type FulltextFilterTable struct {
	MatchAgainst *expression.MatchAgainst
	Table        sql.TableNode
}

FulltextFilterTable handles row iteration for filters involving Full-Text indexes, as they behave differently than other indexes. This acts as a sort of wrapper, so that integrators do not need to implement special logic on their side.

This takes a MatchAgainst expression, as it will have already resolved the index and necessary tables, therefore we do not need to replicate the work here. Although they may seem similar in functionality, they are performing two different functions. This filter table determines if we need to calculate the relevancy of a word, by only returning rows that exist within our index tables. If a word does not exist within the tables, then we can assume that it has a relevancy of zero (for the default search mode). Therefore, we can skip processing that row altogether. The existence of a row does not imply that the relevancy value will be non-zero though, as the relevancy calculation can return a zero due to rounding (as is the case with the MyISAM backend, which we currently do not support).

func (*FulltextFilterTable) Collation

func (f *FulltextFilterTable) Collation() sql.CollationID

Collation implements the interface sql.IndexedTable.

func (*FulltextFilterTable) LookupPartitions

func (f *FulltextFilterTable) LookupPartitions(ctx *sql.Context, lookup sql.IndexLookup) (sql.PartitionIter, error)

LookupPartitions implements the interface sql.IndexedTable.

func (*FulltextFilterTable) Name

func (f *FulltextFilterTable) Name() string

Name implements the interface sql.IndexedTable.

func (*FulltextFilterTable) PartitionRows

func (f *FulltextFilterTable) PartitionRows(ctx *sql.Context, partition sql.Partition) (sql.RowIter, error)

PartitionRows implements the interface sql.IndexedTable.

func (*FulltextFilterTable) Partitions

func (f *FulltextFilterTable) Partitions(ctx *sql.Context) (sql.PartitionIter, error)

Partitions implements the interface sql.IndexedTable.

func (*FulltextFilterTable) Schema

func (f *FulltextFilterTable) Schema() sql.Schema

Schema implements the interface sql.IndexedTable.

func (*FulltextFilterTable) String

func (f *FulltextFilterTable) String() string

String implements the interface sql.IndexedTable.

type NameAndSchema

type NameAndSchema interface {
	sql.Nameable
	Schema() sql.Schema
}

type ProjectIter

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

func (*ProjectIter) CanDefer

func (i *ProjectIter) CanDefer() bool

func (*ProjectIter) Close

func (i *ProjectIter) Close(ctx *sql.Context) error

func (*ProjectIter) GetChildIter

func (i *ProjectIter) GetChildIter() sql.RowIter

func (*ProjectIter) GetProjections

func (i *ProjectIter) GetProjections() []sql.Expression

func (*ProjectIter) Next

func (i *ProjectIter) Next(ctx *sql.Context) (sql.Row, error)

type TransactionCommittingIter

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

TransactionCommittingIter is a simple RowIter wrapper to allow the engine to conditionally commit a transaction during the Close() operation

func (*TransactionCommittingIter) Close

func (t *TransactionCommittingIter) Close(ctx *sql.Context) error

func (*TransactionCommittingIter) GetIter

func (t *TransactionCommittingIter) GetIter() sql.RowIter

func (*TransactionCommittingIter) Next

func (t *TransactionCommittingIter) Next(ctx *sql.Context) (sql.Row, error)

func (*TransactionCommittingIter) WithChildIter

func (t *TransactionCommittingIter) WithChildIter(childIter sql.RowIter) sql.RowIter