Method parse_subscribe

src/sql-parser/src/parser.rs:8876–8912

(&mut self)

    }

    fn parse_subscribe(&mut self) -> Result<Statement<Raw>, ParserError> {
        let _ = self.parse_keyword(TO);
        let relation = if self.consume_token(&Token::LParen) {
            let query = self.parse_query()?;
            self.expect_token(&Token::RParen)?;
            SubscribeRelation::Query(query)
        } else {
            SubscribeRelation::Name(self.parse_raw_name()?)
        };
        let mut output = self.parse_subscribe_output()?;
        let options = if self.parse_keyword(WITH) {
            self.expect_token(&Token::LParen)?;
            let options = self.parse_comma_separated(Self::parse_subscribe_option)?;
            self.expect_token(&Token::RParen)?;
            options
        } else {
            vec![]
        };
        let as_of = self.parse_optional_as_of()?;
        let up_to = self.parse_optional_up_to()?;
        // For backwards compatibility, we allow parsing output options
        // (`ENVELOPE`, `WITHIN TIMESTAMP ORDER BY`) at the end of the
        // statement, if they haven't already been specified where we prefer
        // them, before the `WITH` options and before the `AS OF`/`UP TO`
        // options. Our preferred syntax better aligns with the option ordering
        // for `CREATE SINK` and `SELECT`.
        if output == SubscribeOutput::Diffs {
            output = self.parse_subscribe_output()?;
        }
        Ok(Statement::Subscribe(SubscribeStatement {
            relation,
            options,
            as_of,
            up_to,
            output,
        }))
    }

    fn parse_subscribe_option(&mut self) -> Result<SubscribeOption<Raw>, ParserError> {
        let name = match self.expect_one_of_keywords(&[PROGRESS, SNAPSHOT])? {