taxonomy

Documentation

Index

• func GetAliasFromStatement(node sqlparser.SQLNode) string
• func GetHeirarchyFromStatement(handlerCtx handler.HandlerContext, node sqlparser.SQLNode, ...) (tablemetadata.HeirarchyObjects, error)
• func GetHeirarchyIDsFromParserNode(handlerCtx handler.HandlerContext, node sqlparser.SQLNode) (internaldto.HeirarchyIdentifiers, error)
• func GetTableNameFromStatement(node sqlparser.SQLNode, formatter sqlparser.NodeFormatter) string
• type AnnotatedTabulationMap
• type AnnotationCtx
  • func NewStaticStandardAnnotationCtx(schema anysdk.Schema, hIds internaldto.HeirarchyIdentifiers, ...) AnnotationCtx
• type AnnotationCtxMap
  • func (am AnnotationCtxMap) AssignParams() error
  • func (am AnnotationCtxMap) GetStringParams() map[string]interface{}
• type TblMap
  • func (tm TblMap) GetTable(node sqlparser.SQLNode) (tablemetadata.ExtendedTableMetadata, error)
  • func (tm TblMap) GetTableLoose(node sqlparser.SQLNode) (tablemetadata.ExtendedTableMetadata, error)
  • func (tm TblMap) SetTable(node sqlparser.SQLNode, table tablemetadata.ExtendedTableMetadata)

Functions

func GetAliasFromStatement

func GetAliasFromStatement(node sqlparser.SQLNode) string

func GetHeirarchyFromStatement

func GetHeirarchyFromStatement(
	handlerCtx handler.HandlerContext,
	node sqlparser.SQLNode,
	parameters parserutil.ColumnKeyedDatastore,
) (tablemetadata.HeirarchyObjects, error)

Hierarchy inference function. Returns:

• Hierarchy
• Supplied parameters that are **not** consumed in Hierarchy inference
• Error if applicable.

func GetHeirarchyIDsFromParserNode

func GetHeirarchyIDsFromParserNode(
	handlerCtx handler.HandlerContext,
	node sqlparser.SQLNode,
) (internaldto.HeirarchyIdentifiers, error)

func GetTableNameFromStatement

func GetTableNameFromStatement(node sqlparser.SQLNode, formatter sqlparser.NodeFormatter) string

Types

type AnnotatedTabulationMap

type AnnotatedTabulationMap map[sqlparser.SQLNode]util.AnnotatedTabulation

type AnnotationCtx

type AnnotationCtx interface {
	GetHIDs() internaldto.HeirarchyIdentifiers
	IsDynamic() bool
	GetView() (internaldto.RelationDTO, bool)
	GetSubquery() (internaldto.SubqueryDTO, bool)
	GetInputTableName() (string, error)
	GetParameters() map[string]interface{}
	GetSchema() anysdk.Schema
	GetTableMeta() tablemetadata.ExtendedTableMetadata
	Prepare(handlerCtx handler.HandlerContext, inStream streaming.MapStream) error
	SetDynamic()
	Clone() AnnotationCtx
}

TODO:

• For views, need API to get child.

func NewStaticStandardAnnotationCtx

func NewStaticStandardAnnotationCtx(
	schema anysdk.Schema,
	hIds internaldto.HeirarchyIdentifiers,
	tableMeta tablemetadata.ExtendedTableMetadata,
	parameters map[string]interface{},
) AnnotationCtx

type AnnotationCtxMap

type AnnotationCtxMap map[sqlparser.SQLNode]AnnotationCtx

func (AnnotationCtxMap) AssignParams

func (am AnnotationCtxMap) AssignParams() error

func (AnnotationCtxMap) GetStringParams

func (am AnnotationCtxMap) GetStringParams() map[string]interface{}

type TblMap

type TblMap map[sqlparser.SQLNode]tablemetadata.ExtendedTableMetadata

func (TblMap) GetTable

func (tm TblMap) GetTable(node sqlparser.SQLNode) (tablemetadata.ExtendedTableMetadata, error)

func (TblMap) GetTableLoose

func (tm TblMap) GetTableLoose(node sqlparser.SQLNode) (tablemetadata.ExtendedTableMetadata, error)

func (TblMap) SetTable

func (tm TblMap) SetTable(node sqlparser.SQLNode, table tablemetadata.ExtendedTableMetadata)