sqlparser

Documentation

Index

• func AssetTypeToDialect(assetType pipeline.AssetType) (string, error)
• type ColumnLineage
• type Lineage
• type QueryConfig
• type SQLParser
  • func NewSQLParser(randomize bool) (*SQLParser, error)
  • func NewSQLParserWithConfig(randomize bool, maxQueryLength int) (*SQLParser, error)
  • func (s *SQLParser) AddLimit(sql string, limit int, dialect string) (string, error)
  • func (s *SQLParser) Close() error
  • func (s *SQLParser) ColumnLineage(sql, dialect string, schema Schema) (*Lineage, error)
  • func (s *SQLParser) GetMissingDependenciesForAsset(asset *pipeline.Asset, pipeline *pipeline.Pipeline, ...) ([]string, error)
  • func (s *SQLParser) IsSingleSelectQuery(sql string, dialect string) (bool, error)
  • func (s *SQLParser) RenameTables(sql string, dialect string, tableMapping map[string]string) (string, error)
  • func (s *SQLParser) Start() error
  • func (s *SQLParser) UsedTables(sql, dialect string) ([]string, error)
• type Schema
• type UpstreamColumn

Functions

func AssetTypeToDialect

func AssetTypeToDialect(assetType pipeline.AssetType) (string, error)

Types

type ColumnLineage

type ColumnLineage struct {
	Name     string           `json:"name"`
	Upstream []UpstreamColumn `json:"upstream"`
	Type     string           `json:"type"`
}

type Lineage

type Lineage struct {
	Columns            []ColumnLineage `json:"columns"`
	NonSelectedColumns []ColumnLineage `json:"non_selected_columns"`
	Errors             []string        `json:"errors"`
}

type QueryConfig

type QueryConfig struct {
	Name   string `json:"name"`
	Query  string `json:"query"`
	Schema Schema `json:"schema"`
}

type SQLParser

type SQLParser struct {
	MaxQueryLength int
	// contains filtered or unexported fields
}

func NewSQLParser

func NewSQLParser(randomize bool) (*SQLParser, error)

func NewSQLParserWithConfig

func NewSQLParserWithConfig(randomize bool, maxQueryLength int) (*SQLParser, error)

func (*SQLParser) AddLimit

func (s *SQLParser) AddLimit(sql string, limit int, dialect string) (string, error)

func (*SQLParser) Close

func (s *SQLParser) Close() error

func (*SQLParser) ColumnLineage

func (s *SQLParser) ColumnLineage(sql, dialect string, schema Schema) (*Lineage, error)

func (*SQLParser) GetMissingDependenciesForAsset

func (s *SQLParser) GetMissingDependenciesForAsset(asset *pipeline.Asset, pipeline *pipeline.Pipeline, renderer jinja.RendererInterface) ([]string, error)

func (*SQLParser) IsSingleSelectQuery

func (s *SQLParser) IsSingleSelectQuery(sql string, dialect string) (bool, error)

func (*SQLParser) RenameTables

func (s *SQLParser) RenameTables(sql string, dialect string, tableMapping map[string]string) (string, error)

func (*SQLParser) Start

func (s *SQLParser) Start() error

func (*SQLParser) UsedTables

func (s *SQLParser) UsedTables(sql, dialect string) ([]string, error)

type Schema

type Schema map[string]map[string]string

type UpstreamColumn

type UpstreamColumn struct {
	Column string `json:"column"`
	Table  string `json:"table"`
}