parser

type AST struct {
	Select           string            // Unaltered SELECT statement, if any.
	Use              string            `(  "USE" @Ident`
	Drop             *Drop             ` | "DROP" @@ `
	Create           *Create           ` | "CREATE" @@ `
	Show             *Show             ` | "SHOW" @@ `
	Describe         string            ` | "DESCRIBE" @Ident `
	SourceSetMaxRate *SourceSetMaxRate ` | "SOURCE" "SET" "MAX" "RATE" @@ `
	ResetDdl         string            ` | "RESET" "DDL" @Ident ) ';'?`
}

type Boolean bool

type ColSelector struct {
	Selector string `@String`
}

type ColumnDef struct {
	Pos lexer.Position

	Name string `@Ident`

	Type       common.Type `@(("VARCHAR"|"TINYINT"|"INT"|"BIGINT"|"TIMESTAMP"|"DOUBLE"|"DECIMAL"))` // Conversion done by common.Type.Capture()
	Parameters []int       `("(" @Number ("," @Number)* ")")?`                                      // Optional parameters to the type(x [, x, ...])
}

type ColumnName struct {
	Name string `@Ident`
}

type Create struct {
	MaterializedView *CreateMaterializedView `  "MATERIALIZED" "VIEW" @@`
	Source           *CreateSource           `| "SOURCE" @@`
	Index            *CreateIndex            `| "INDEX" @@`
}

type CreateIndex struct {
	Name        string        `@Ident "ON"`
	TableName   string        `@Ident`
	ColumnNames []*ColumnName `"(" @@ ("," @@)* ")"`
}

type CreateMaterializedView struct {
	Name              *Ref                                 `@@`
	OriginInformation []*MaterializedViewOriginInformation `("WITH" "(" @@ ("," @@)* ")")?`
	Query             *RawQuery                            `"AS" @@`
}

type CreateSource struct {
	Name              string                     `@Ident`
	Options           []*TableOption             `"(" @@ ("," @@)* ")"` // Table options.
	OriginInformation []*SourceOriginInformation `"WITH" "(" @@ ("," @@)* ")"`
}

type Drop struct {
	MaterializedView bool   `(   @"MATERIALIZED" "VIEW"`
	Source           bool   `  | @"SOURCE"`
	Index            bool   `  | @"INDEX" )`
	Name             string `@Ident `
	TableName        string `("ON" @Ident)?`
}

type MaterializedViewOriginInformation struct {
	InitialState string `"InitialState" "=" @String`
}

type RawQuery struct {
	Tokens []lexer.Token
	Query  []string `(!";")+`
}

type Ref struct {
	Path []string `@Ident ("." @Ident)*`
}

type Show struct {
	Tables    bool   `(  @"TABLES"`
	Schemas   bool   `| @"SCHEMAS"`
	Indexes   bool   `| @"INDEXES" )`
	TableName string `("ON" @Ident)?`
}

type SourceOriginInformation struct {
	BrokerName     string                        `"BrokerName" "=" @String`
	TopicName      string                        `|"TopicName" "=" @String`
	HeaderEncoding string                        `|"HeaderEncoding" "=" @String`
	KeyEncoding    string                        `|"KeyEncoding" "=" @String`
	ValueEncoding  string                        `|"ValueEncoding" "=" @String`
	IngestFilter   string                        `|"IngestFilter" "=" @String`
	InitialState   string                        `|"InitialState" "=" @String`
	Transient      *Boolean                      `|"Transient" "=" @Ident`
	ColSelectors   []*selector.ColumnSelectorAST `|"ColumnSelectors" "=" "(" (@@ ("," @@)*)? ")"`
	Properties     []*TopicInfoProperty          `|"Properties" "=" "(" (@@ ("," @@)*)? ")"`
}

type SourceSetMaxRate struct {
	SourceName string `@Ident`
	Rate       int64  `@Number`
}

type TableOption struct {
	PrimaryKey []string   `  "PRIMARY" "KEY" "(" @Ident ( "," @Ident )* ")"`
	Column     *ColumnDef `| @@`
}

type TopicInfoProperty struct {
	Key   string `@String "="`
	Value string `@String`
}