Method parseCreateMaterializedView

parser/parser_view.go:19–171

parseCreateMaterializedView parses a CREATE MATERIALIZED VIEW statement. The syntax is as follows: CREATE MATERIALIZED VIEW [IF NOT EXISTS] [db.]table_name [ON CLUSTER cluster] REFRESH EVERY|AFTER interval [OFFSET interval] [RANDOMIZE FOR interval] [DEPENDS ON [db.]name [, [db.]name [, ...]]] [SETT

(pos Pos)

// AS SELECT ...
// [COMMENT 'comment']
func (p *Parser) parseCreateMaterializedView(pos Pos) (*CreateMaterializedView, error) {
	if err := p.expectKeyword(KeywordMaterialized); err != nil {
		return nil, err
	}
	if err := p.expectKeyword(KeywordView); err != nil {
		return nil, err
	}

	createMaterializedView := &CreateMaterializedView{CreatePos: pos}

	// parse IF NOT EXISTS clause if exists
	var err error
	createMaterializedView.IfNotExists, err = p.tryParseIfNotExists()
	if err != nil {
		return nil, err
	}

	tableIdentifier, err := p.parseTableIdentifier(p.Pos())
	if err != nil {
		return nil, err
	}
	createMaterializedView.Name = tableIdentifier

	onCluster, err := p.tryParseClusterClause(p.Pos())
	if err != nil {
		return nil, err
	}
	createMaterializedView.OnCluster = onCluster

	refreshExpr, err := p.tryParseRefreshExpr(p.Pos())
	if err != nil {
		return nil, err
	}
	createMaterializedView.Refresh = refreshExpr

	if p.tryConsumeKeywords(KeywordRandomize, KeywordFor) {
		randomizeFor, err := p.parseInterval(false)
		if err != nil {
			return nil, err
		}
		createMaterializedView.RandomizeFor = randomizeFor
	}
	if p.tryConsumeKeywords(KeywordDepends, KeywordOn) {
		dependsOnTables := make([]*TableIdentifier, 0)
		table, err := p.parseTableIdentifier(p.Pos())
		if err != nil {
			return nil, err
		}
		dependsOnTables = append(dependsOnTables, table)
		for p.matchTokenKind(TokenKindComma) {
			table, err := p.parseTableIdentifier(p.Pos())
			if err != nil {
				return nil, err
			}
			dependsOnTables = append(dependsOnTables, table)
		}
		createMaterializedView.DependsOn = dependsOnTables
	}