Method parseCreateLiveView

parser/parser_view.go:265–333

# CreateLiveViewStmt (ATTACH | CREATE) LIVE VIEW (IF NOT EXISTS)? tableIdentifier uuidClause? clusterClause? (WITH TIMEOUT DECIMAL_LITERAL?)? destinationClause? tableSchemaClause? subqueryClause

(pos Pos)

// (ATTACH | CREATE) LIVE VIEW (IF NOT EXISTS)? tableIdentifier uuidClause?
// clusterClause? (WITH TIMEOUT DECIMAL_LITERAL?)? destinationClause? tableSchemaClause? subqueryClause
func (p *Parser) parseCreateLiveView(pos Pos) (*CreateLiveView, error) {
	if err := p.expectKeyword(KeywordLive); err != nil {
		return nil, err
	}

	if err := p.expectKeyword(KeywordView); err != nil {
		return nil, err
	}

	createLiveView := &CreateLiveView{CreatePos: pos}
	// parse IF NOT EXISTS clause if exists
	var err error
	createLiveView.IfNotExists, err = p.tryParseIfNotExists()
	if err != nil {
		return nil, err
	}

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

	// try parse UUID clause if exists
	uuid, err := p.tryParseUUID()
	if err != nil {
		return nil, err
	}
	createLiveView.UUID = uuid
	// parse ON CLUSTER clause if exists
	onCluster, err := p.tryParseClusterClause(p.Pos())
	if err != nil {
		return nil, err
	}
	createLiveView.OnCluster = onCluster

	withTimeout, err := p.tryParseWithTimeout(p.Pos())
	if err != nil {
		return nil, err
	}
	createLiveView.WithTimeout = withTimeout

	if p.matchKeyword(KeywordTo) {
		destination, err := p.parseDestinationClause(p.Pos())
		if err != nil {
			return nil, err
		}
		createLiveView.Destination = destination
	}

	if p.matchTokenKind(TokenKindLParen) {
		tableSchema, err := p.parseTableSchemaClause(p.Pos())
		if err != nil {
			return nil, err
		}
		createLiveView.TableSchema = tableSchema
	}