query

type FileQuerySplitterExtractor ¶

type FileQuerySplitterExtractor struct {
	Fs       afero.Fs
	Renderer renderer
}

FileQuerySplitterExtractor is a regular file extractor, but it splits the queries in the given file into multiple instances. For usecases that require EXPLAIN statements, such as validating Snowflake queries, it is not possible to EXPLAIN a multi-query string directly, therefore we have to split them.

func (f FileQuerySplitterExtractor) ExtractQueriesFromString(content string) ([]*Query, error)

type Query ¶

type Query struct {
	VariableDefinitions []string
	Query               string
}

func (q Query) String() string

func (q Query) ToDryRunQuery() string

func (q Query) ToExplainQuery() string

type QueryExtractor ¶ added in v0.11.182

type QueryExtractor interface {
	ExtractQueriesFromString(filepath string) ([]*Query, error)
	CloneForAsset(ctx context.Context, asset *pipeline.Asset) QueryExtractor
	ReextractQueriesFromSlice(content []string) ([]string, error)
}

type QueryResult ¶ added in v0.11.53

type QueryResult struct {
	Columns     []string
	Rows        [][]interface{}
	ColumnTypes []string
}

type Renderer ¶

type Renderer struct {
	Args map[string]string
}

func (r Renderer) Render(query string) string

type WholeFileExtractor ¶

type WholeFileExtractor struct {
	Fs       afero.Fs
	Renderer renderer
}

WholeFileExtractor is a regular file extractor that returns the whole file content as the query string. It is useful for cases where the whole file content can be treated as a single query, such as validating GoogleCloudPlatform queries via dry-run.

func (f *WholeFileExtractor) CloneForAsset(ctx context.Context, t *pipeline.Asset) QueryExtractor

func (f *WholeFileExtractor) ExtractQueriesFromString(content string) ([]*Query, error)

func (f *WholeFileExtractor) ReextractQueriesFromSlice(content []string) ([]string, error)