Method parse_create_source

src/sql-parser/src/parser.rs:3163–3245

(&mut self)

    }

    fn parse_create_source(&mut self) -> Result<Statement<Raw>, ParserError> {
        self.expect_keyword(SOURCE)?;
        let if_not_exists = self.parse_if_not_exists()?;
        let name = self.parse_item_name()?;

        let (col_names, key_constraint) = self.parse_source_columns()?;

        let in_cluster = self.parse_optional_in_cluster()?;
        self.expect_keyword(FROM)?;

        // Webhook Source, which works differently than all other sources.
        if self.parse_keyword(WEBHOOK) {
            return self.parse_create_webhook_source(name, if_not_exists, in_cluster, false);
        }

        let connection = self.parse_create_source_connection()?;
        let format = match self.parse_one_of_keywords(&[KEY, FORMAT]) {
            Some(KEY) => {
                self.expect_keyword(FORMAT)?;
                let key = self.parse_format()?;
                self.expect_keywords(&[VALUE, FORMAT])?;
                let value = self.parse_format()?;
                Some(FormatSpecifier::KeyValue { key, value })
            }
            Some(FORMAT) => Some(FormatSpecifier::Bare(self.parse_format()?)),
            Some(_) => unreachable!("parse_one_of_keywords returns None for this"),
            None => None,
        };
        let include_metadata = self.parse_source_include_metadata()?;

        let envelope = if self.parse_keyword(ENVELOPE) {
            Some(self.parse_source_envelope()?)
        } else {
            None
        };

        let referenced_subsources = if self.parse_keywords(&[FOR, TABLES]) {
            self.expect_token(&Token::LParen)?;
            let subsources = self.parse_comma_separated(Parser::parse_subsource_references)?;
            self.expect_token(&Token::RParen)?;
            Some(ExternalReferences::SubsetTables(subsources))
        } else if self.parse_keywords(&[FOR, SCHEMAS]) {
            self.expect_token(&Token::LParen)?;
            let schemas = self.parse_comma_separated(Parser::parse_identifier)?;
            self.expect_token(&Token::RParen)?;
            Some(ExternalReferences::SubsetSchemas(schemas))
        } else if self.parse_keywords(&[FOR, ALL, TABLES]) {
            Some(ExternalReferences::All)
        } else {
            None
        };

        let progress_subsource = if self.parse_keywords(&[EXPOSE, PROGRESS, AS]) {
            Some(self.parse_deferred_item_name()?)
        } else {
            None
        };