Method parseCreateNamedCollection

parser/parser_table.go:189–253

(pos Pos)

}

func (p *Parser) parseCreateNamedCollection(pos Pos) (*CreateNamedCollection, error) {
	if err := p.expectKeyword(KeywordNamed); err != nil {
		return nil, err
	}

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

	createCollection := &CreateNamedCollection{
		CreatePos: pos,
	}

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

	// parse collection name
	name, err := p.parseIdent()
	if err != nil {
		return nil, err
	}
	createCollection.Name = name

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

	// parse AS keyword
	if err := p.expectKeyword(KeywordAs); err != nil {
		return nil, err
	}

	// parse parameters
	params := make([]*NamedCollectionParam, 0)
	for !p.lexer.isEOF() {
		param, err := p.parseNamedCollectionParam(p.Pos())
		if err != nil {
			return nil, err
		}
		params = append(params, param)

		// Check if there's another parameter
		if p.tryConsumeTokenKind(TokenKindComma) == nil {
			break
		}
	}
	createCollection.Params = params

	if len(params) > 0 {
		createCollection.StatementEnd = params[len(params)-1].End()
	} else if onCluster != nil {