Method parse_connection_option_unified

src/sql-parser/src/parser.rs:3060–3074

(&mut self)

    }

    fn parse_connection_option_unified(&mut self) -> Result<ConnectionOption<Raw>, ParserError> {
        let name = self.parse_connection_option_name()?;
        let value = match name {
            ConnectionOptionName::AwsConnection => Some(self.parse_object_option_value()?),
            ConnectionOptionName::AwsPrivatelink => Some(self.parse_default_aws_privatelink()?),
            ConnectionOptionName::Broker => Some(self.parse_kafka_broker()?),
            ConnectionOptionName::Brokers => Some(WithOptionValue::Sequence(
                self.parse_list_value(Parser::parse_kafka_broker_or_matching_rule)?,
            )),
            ConnectionOptionName::GcpConnection => Some(self.parse_object_option_value()?),
            ConnectionOptionName::SshTunnel => Some(self.parse_object_option_value()?),
            _ => self.parse_optional_option_value()?,
        };
        Ok(ConnectionOption { name, value })
    }

    fn parse_create_subsource(&mut self) -> Result<Statement<Raw>, ParserError> {
        self.expect_keyword(SUBSOURCE)?;