Method parse_create_webhook_source

src/sql-parser/src/parser.rs:3334–3419

(
        &mut self,
        name: UnresolvedItemName,
        if_not_exists: bool,
        in_cluster: Option<RawClusterName>,
        is_table: bool,
    )

    }

    fn parse_create_webhook_source(
        &mut self,
        name: UnresolvedItemName,
        if_not_exists: bool,
        in_cluster: Option<RawClusterName>,
        is_table: bool,
    ) -> Result<Statement<Raw>, ParserError> {
        self.expect_keywords(&[BODY, FORMAT])?;

        // Note: we don't use `parse_format()` here because we support fewer formats than other
        // sources, and the user gets better errors if we reject the formats here.
        let body_format = match self.expect_one_of_keywords(&[JSON, TEXT, BYTES])? {
            JSON => {
                let array = self.parse_keyword(ARRAY);
                Format::Json { array }
            }
            TEXT => Format::Text,
            BYTES => Format::Bytes,
            _ => unreachable!(),
        };

        let mut include_headers = CreateWebhookSourceIncludeHeaders::default();
        while self.parse_keyword(INCLUDE) {
            match self.expect_one_of_keywords(&[HEADER, HEADERS])? {
                HEADER => {
                    let header_name = self.parse_literal_string()?;
                    self.expect_keyword(AS)?;
                    let column_name = self.parse_identifier()?;
                    let use_bytes = self.parse_keyword(BYTES);

                    include_headers.mappings.push(CreateWebhookSourceMapHeader {
                        header_name,
                        column_name,
                        use_bytes,
                    });
                }
                HEADERS => {
                    let header_filters = include_headers.column.get_or_insert_with(Vec::default);
                    if self.consume_token(&Token::LParen) {
                        let filters = self.parse_comma_separated(|f| {
                            let block = f.parse_keyword(NOT);
                            let header_name = f.parse_literal_string()?;
                            Ok(CreateWebhookSourceFilterHeader { block, header_name })
                        })?;
                        header_filters.extend(filters);

                        self.expect_token(&Token::RParen)?;
                    }
                }
                k => unreachable!("programming error, didn't expect {k}"),
            }
        }

        let validate_using = if self.parse_keyword(CHECK) {
            self.expect_token(&Token::LParen)?;

            let options = if self.parse_keyword(WITH) {
                self.expect_token(&Token::LParen)?;