sqlparser

Documentation

Index

• type ColumnLineage
• type Lineage
• type QueryConfig
• type SQLParser
  • func NewSQLParser(randomize bool) (*SQLParser, error)
  • func (s *SQLParser) Close() error
  • func (s *SQLParser) ColumnLineage(sql, dialect string, schema Schema) (*Lineage, error)
  • func (s *SQLParser) Start() error
  • func (s *SQLParser) UsedTables(sql, dialect string) ([]string, error)
• type Schema
• type UpstreamColumn

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"`
}

type QueryConfig

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

type SQLParser

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

func NewSQLParser

func NewSQLParser(randomize bool) (*SQLParser, 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) 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"`
}