primitivebuilder

package
v0.5.643 Latest Latest
Warning

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

 Go to latest Published: May 15, 2024 License: MIT Imports: 42 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDescribeTableInstructionExecutor 

func NewDescribeTableInstructionExecutor(
	handlerCtx handler.HandlerContext,
	tbl tablemetadata.ExtendedTableMetadata,
	extended bool,
	full bool,
) internaldto.ExecutorOutput

func NewDescribeViewInstructionExecutor 

func NewDescribeViewInstructionExecutor(
	handlerCtx handler.HandlerContext,
	tbl tablemetadata.ExtendedTableMetadata,
	nonControlColumns []typing.ColumnMetadata,
	extended bool,
	full bool,
) internaldto.ExecutorOutput

func NewInsertableValsPrimitive 

func NewInsertableValsPrimitive(
	handlerCtx handler.HandlerContext,
	vals map[int]map[int]interface{},
) (primitive.IPrimitive, error)

func NewLocalSelectExecutor 

func NewLocalSelectExecutor(
	handlerCtx handler.HandlerContext,
	node *sqlparser.Select,
	rowSort func(map[string]map[string]interface{}) []string,
	colz []map[string]interface{},
) (primitive.IPrimitive, error)

func NewShowInstructionExecutor 

func NewShowInstructionExecutor(
	node *sqlparser.Show,
	prov provider.IProvider,
	tbl tablemetadata.ExtendedTableMetadata,
	handlerCtx handler.HandlerContext,
	commentDirectives sqlparser.CommentDirectives,
	tableFilter func(anysdk.ITable,
	) (anysdk.ITable, error),
) internaldto.ExecutorOutput

func NewUpdateableValsPrimitive 

func NewUpdateableValsPrimitive(
	handlerCtx handler.HandlerContext,
	vals map[*sqlparser.ColName]interface{},
) (primitive.IPrimitive, error)

Types

type Builder 

type Builder interface {
	Build() error

	GetRoot() primitivegraph.PrimitiveNode

	GetTail() primitivegraph.PrimitiveNode
}

func NewDDL 

func NewDDL(
	bldrInput builder_input.BuilderInput,
) (Builder, error)

func NewDataflowGraphBuilder 

func NewDataflowGraphBuilder(
	graph primitivegraph.PrimitiveGraphHolder,
	dataflowGraph dataflow.WeaklyConnectedComponent,
	txnControlCounters *internaldto.TxnControlCounters,
	handlerCtx handler.HandlerContext,
	sqlEngine sqlengine.SQLEngine,
) Builder

func NewDelete 

func NewDelete(
	graph primitivegraph.PrimitiveGraphHolder,
	handlerCtx handler.HandlerContext,
	node sqlparser.SQLNode,
	tbl tablemetadata.ExtendedTableMetadata,
	commentDirectives sqlparser.CommentDirectives,
	isAwait bool,
) Builder

func NewDependencySubDAGBuilder 

func NewDependencySubDAGBuilder(
	graph primitivegraph.PrimitiveGraphHolder,
	dependencyBuilders []Builder,
	dependentBuilder Builder,
) Builder

func NewDependentMultipleAcquireAndSelect 

func NewDependentMultipleAcquireAndSelect(
	graph primitivegraph.PrimitiveGraphHolder,
	acquireBuilders []Builder,
	selectBuilder Builder,
	dataflowToEdges map[int][]int,
) Builder

func NewDiamondBuilder 

func NewDiamondBuilder(
	parent Builder,
	children []Builder,
	graphHolder primitivegraph.PrimitiveGraphHolder,
	sqlSystem sql_system.SQLSystem,
	shouldCollectGarbage bool,
) Builder

func NewExec 

func NewExec(
	graph primitivegraph.PrimitiveGraphHolder,
	handlerCtx handler.HandlerContext,
	node sqlparser.SQLNode,
	tbl tablemetadata.ExtendedTableMetadata,
	isAwait bool,
	isShowResults bool,
) Builder

func NewInsertOrUpdate added in v0.5.375 

func NewInsertOrUpdate(
	bldrInput builder_input.BuilderInput,
) Builder

func NewNativeSelect 

func NewNativeSelect(
	graph primitivegraph.PrimitiveGraphHolder,
	handlerCtx handler.HandlerContext,
	selectQuery nativedb.Select,
) Builder

func NewNopBuilder 

func NewNopBuilder(
	graph primitivegraph.PrimitiveGraphHolder,
	txnControlCounters internaldto.TxnControlCounters,
	handlerCtx handler.HandlerContext,
	sqlEngine sqlengine.SQLEngine,
	messages []string,
) Builder

func NewRawNativeExec 

func NewRawNativeExec(
	graph primitivegraph.PrimitiveGraphHolder,
	handlerCtx handler.HandlerContext,
	txnCtrlCtr internaldto.TxnControlCounters,
	nativeQuery string,
	bldrInput builder_input.BuilderInput,
) Builder

func NewRawNativeSelect 

func NewRawNativeSelect(
	graph primitivegraph.PrimitiveGraphHolder,
	handlerCtx handler.HandlerContext,
	txnCtrlCtr internaldto.TxnControlCounters,
	nativeQuery string,
) Builder

func NewRefreshMaterializedView added in v0.5.451 

func NewRefreshMaterializedView(
	bldrInput builder_input.BuilderInput,
) (Builder, error)

func NewSQLDataSourceSingleSelectAcquire 

func NewSQLDataSourceSingleSelectAcquire(
	graph primitivegraph.PrimitiveGraphHolder,
	handlerCtx handler.HandlerContext,
	insertionContainer tableinsertioncontainer.TableInsertionContainer,
	query string,
	queryArgs []interface{},
	insertCtx drm.PreparedStatementCtx,
	rowSort func(map[string]map[string]interface{}) []string,
	stream streaming.MapStream,
) Builder

func NewSingleAcquireAndSelect 

func NewSingleAcquireAndSelect(
	graph primitivegraph.PrimitiveGraphHolder,
	txnControlCounters internaldto.TxnControlCounters,
	handlerCtx handler.HandlerContext,
	insertContainer tableinsertioncontainer.TableInsertionContainer,
	insertCtx drm.PreparedStatementCtx,
	selectCtx drm.PreparedStatementCtx,
	rowSort func(map[string]map[string]interface{}) []string,
) Builder

func NewSingleSelect 

func NewSingleSelect(
	graph primitivegraph.PrimitiveGraphHolder,
	handlerCtx handler.HandlerContext,
	selectCtx drm.PreparedStatementCtx,
	insertionContainers []tableinsertioncontainer.TableInsertionContainer,
	rowSort func(map[string]map[string]interface{}) []string,
	stream streaming.MapStream,
) Builder

func NewSingleSelectAcquire 

func NewSingleSelectAcquire(
	graphHolder primitivegraph.PrimitiveGraphHolder,
	handlerCtx handler.HandlerContext,
	insertionContainer tableinsertioncontainer.TableInsertionContainer,
	insertCtx drm.PreparedStatementCtx,
	rowSort func(map[string]map[string]interface{}) []string,
	stream streaming.MapStream,
) Builder

func NewSubTreeBuilder 

func NewSubTreeBuilder(children []Builder) Builder

func NewUnion 

func NewUnion(
	graph primitivegraph.PrimitiveGraphHolder,
	handlerCtx handler.HandlerContext,
	unionCtx drm.PreparedStatementCtx,
) Builder

type DataflowGraphBuilder 

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

func (*DataflowGraphBuilder) Build 

func (nb *DataflowGraphBuilder) Build() error

func (*DataflowGraphBuilder) GetRoot 

func (nb *DataflowGraphBuilder) GetRoot() primitivegraph.PrimitiveNode

func (*DataflowGraphBuilder) GetTail 

func (nb *DataflowGraphBuilder) GetTail() primitivegraph.PrimitiveNode

type Delete 

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

func (*Delete) Build 

func (ss *Delete) Build() error

func (*Delete) GetRoot 

func (ss *Delete) GetRoot() primitivegraph.PrimitiveNode

func (*Delete) GetTail 

func (ss *Delete) GetTail() primitivegraph.PrimitiveNode

type DependencySubDAGBuilder 

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

func (*DependencySubDAGBuilder) Build 

func (ss *DependencySubDAGBuilder) Build() error

func (*DependencySubDAGBuilder) GetRoot 

func (ss *DependencySubDAGBuilder) GetRoot() primitivegraph.PrimitiveNode

func (*DependencySubDAGBuilder) GetTail 

func (ss *DependencySubDAGBuilder) GetTail() primitivegraph.PrimitiveNode

type DependentMultipleAcquireAndSelect 

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

func (*DependentMultipleAcquireAndSelect) Build 

func (ss *DependentMultipleAcquireAndSelect) Build() error

func (*DependentMultipleAcquireAndSelect) GetRoot 

func (ss *DependentMultipleAcquireAndSelect) GetRoot() primitivegraph.PrimitiveNode

Cache queries may not have acquire builders.

func (*DependentMultipleAcquireAndSelect) GetTail 

func (ss *DependentMultipleAcquireAndSelect) GetTail() primitivegraph.PrimitiveNode

type DiamondBuilder 

type DiamondBuilder struct {
	SubTreeBuilder
	// contains filtered or unexported fields
}

func (*DiamondBuilder) Build 

func (db *DiamondBuilder) Build() error

func (*DiamondBuilder) GetRoot 

func (db *DiamondBuilder) GetRoot() primitivegraph.PrimitiveNode

func (*DiamondBuilder) GetTail 

func (db *DiamondBuilder) GetTail() primitivegraph.PrimitiveNode

type Exec 

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

func (*Exec) Build 

func (ss *Exec) Build() error

func (*Exec) GetRoot 

func (ss *Exec) GetRoot() primitivegraph.PrimitiveNode

func (*Exec) GetTail 

func (ss *Exec) GetTail() primitivegraph.PrimitiveNode

type GraphQLSingleSelectAcquire 

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

GraphQLSingleSelectAcquire implements the Builder interface and represents the action of acquiring data from an endpoint and then persisting that data into a table. This data would then subsequently be queried by later execution phases.

func (*GraphQLSingleSelectAcquire) Build 

func (ss *GraphQLSingleSelectAcquire) Build() error

func (*GraphQLSingleSelectAcquire) GetRoot 

func (ss *GraphQLSingleSelectAcquire) GetRoot() primitivegraph.PrimitiveNode

func (*GraphQLSingleSelectAcquire) GetTail 

func (ss *GraphQLSingleSelectAcquire) GetTail() primitivegraph.PrimitiveNode

type InsertOrUpdate added in v0.5.375 

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

func (*InsertOrUpdate) Build added in v0.5.375 

func (ss *InsertOrUpdate) Build() error

func (*InsertOrUpdate) GetRoot added in v0.5.375 

func (ss *InsertOrUpdate) GetRoot() primitivegraph.PrimitiveNode

func (*InsertOrUpdate) GetTail added in v0.5.375 

func (ss *InsertOrUpdate) GetTail() primitivegraph.PrimitiveNode

type NativeSelect 

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

func (*NativeSelect) Build 

func (ss *NativeSelect) Build() error

func (*NativeSelect) GetRoot 

func (ss *NativeSelect) GetRoot() primitivegraph.PrimitiveNode

func (*NativeSelect) GetTail 

func (ss *NativeSelect) GetTail() primitivegraph.PrimitiveNode

type NopBuilder 

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

func (*NopBuilder) Build 

func (nb *NopBuilder) Build() error

func (*NopBuilder) GetRoot 

func (nb *NopBuilder) GetRoot() primitivegraph.PrimitiveNode

func (*NopBuilder) GetTail 

func (nb *NopBuilder) GetTail() primitivegraph.PrimitiveNode

type RawNativeExec 

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

func (*RawNativeExec) Build 

func (ss *RawNativeExec) Build() error

func (*RawNativeExec) GetRoot 

func (ss *RawNativeExec) GetRoot() primitivegraph.PrimitiveNode

func (*RawNativeExec) GetTail 

func (ss *RawNativeExec) GetTail() primitivegraph.PrimitiveNode

type RawNativeSelect 

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

func (*RawNativeSelect) Build 

func (ss *RawNativeSelect) Build() error

func (*RawNativeSelect) GetRoot 

func (ss *RawNativeSelect) GetRoot() primitivegraph.PrimitiveNode

func (*RawNativeSelect) GetTail 

func (ss *RawNativeSelect) GetTail() primitivegraph.PrimitiveNode

type SingleAcquireAndSelect 

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

func (*SingleAcquireAndSelect) Build 

func (ss *SingleAcquireAndSelect) Build() error

func (*SingleAcquireAndSelect) GetRoot 

func (ss *SingleAcquireAndSelect) GetRoot() primitivegraph.PrimitiveNode

func (*SingleAcquireAndSelect) GetTail 

func (ss *SingleAcquireAndSelect) GetTail() primitivegraph.PrimitiveNode

type SingleSelect 

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

func (*SingleSelect) Build 

func (ss *SingleSelect) Build() error

func (*SingleSelect) GetRoot 

func (ss *SingleSelect) GetRoot() primitivegraph.PrimitiveNode

func (*SingleSelect) GetTail 

func (ss *SingleSelect) GetTail() primitivegraph.PrimitiveNode

type SingleSelectAcquire 

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

SingleSelectAcquire implements the Builder interface and represents the action of acquiring data from an endpoint and then persisting that data into a table. This data would then subsequently be queried by later execution phases.

func (*SingleSelectAcquire) Build 

func (ss *SingleSelectAcquire) Build() error

func (*SingleSelectAcquire) GetRoot 

func (ss *SingleSelectAcquire) GetRoot() primitivegraph.PrimitiveNode

func (*SingleSelectAcquire) GetTail 

func (ss *SingleSelectAcquire) GetTail() primitivegraph.PrimitiveNode

type SubTreeBuilder 

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

func (*SubTreeBuilder) Build 

func (st *SubTreeBuilder) Build() error

func (*SubTreeBuilder) GetRoot 

func (st *SubTreeBuilder) GetRoot() primitivegraph.PrimitiveNode

func (*SubTreeBuilder) GetTail 

func (st *SubTreeBuilder) GetTail() primitivegraph.PrimitiveNode

type Union 

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

func (*Union) Build 

func (un *Union) Build() error

func (*Union) GetRoot 

func (un *Union) GetRoot() primitivegraph.PrimitiveNode

func (*Union) GetTail 

func (un *Union) GetTail() primitivegraph.PrimitiveNode

Source Files

View all Source files

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.