Documentation
¶
Index ¶
- func GetAliasFromStatement(node sqlparser.SQLNode) string
- func GetHIDs(handlerCtx handler.HandlerContext, node sqlparser.SQLNode, ...) (internaldto.HeirarchyIdentifiers, error)
- 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
- func GetUpdateTargetTableName(node *sqlparser.Update) (string, error)
- type AnnotatedTabulationMap
- type AnnotationCtx
- type AnnotationCtxMap
- type AnnotationCtxSplitMap
- type TblMap
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetAliasFromStatement ¶
func GetHIDs ¶ added in v0.5.692
func GetHIDs( handlerCtx handler.HandlerContext, node sqlparser.SQLNode, params parserutil.ColumnKeyedDatastore, viewPermissive bool) (internaldto.HeirarchyIdentifiers, error)
func GetHeirarchyFromStatement ¶
func GetHeirarchyFromStatement( handlerCtx handler.HandlerContext, node sqlparser.SQLNode, parameters parserutil.ColumnKeyedDatastore, viewPermissive bool, isAwait bool, ) (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()
IsAwait() bool
Equals(AnnotationCtx) bool
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{}, isAwait bool, ) 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 AnnotationCtxSplitMap ¶ added in v0.5.686
type AnnotationCtxSplitMap interface {
Put(AnnotationCtx, AnnotationCtx)
Get(AnnotationCtx) ([]AnnotationCtx, bool)
Len() int
}
func NewAnnotationCtxSplitMap ¶ added in v0.5.686
func NewAnnotationCtxSplitMap() AnnotationCtxSplitMap
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)
Source Files
Click to show internal directories.
Click to hide internal directories.