Method parse_csr_connection_reference

src/sql-parser/src/parser.rs:2310–2326

(&mut self)

    }

    fn parse_csr_connection_reference(&mut self) -> Result<CsrConnection<Raw>, ParserError> {
        self.expect_keyword(CONNECTION)?;
        let connection = self.parse_raw_name()?;

        let options = if self.consume_token(&Token::LParen) {
            let options = self.parse_comma_separated(Parser::parse_csr_config_option)?;
            self.expect_token(&Token::RParen)?;
            options
        } else {
            vec![]
        };

        Ok(CsrConnection {
            connection,
            options,
        })
    }

    fn parse_csr_config_option(&mut self) -> Result<CsrConfigOption<Raw>, ParserError> {
        let name = match self.expect_one_of_keywords(&[AVRO, NULL, KEY, VALUE, DOC])? {