Method parse_create_sink_connection

src/sql-parser/src/parser.rs:4047–4056

(&mut self)

    }

    fn parse_create_sink_connection(&mut self) -> Result<CreateSinkConnection<Raw>, ParserError> {
        match self.expect_one_of_keywords(&[KAFKA, ICEBERG])? {
            KAFKA => self.parse_create_kafka_sink_connection(),
            ICEBERG => {
                self.expect_keyword(CATALOG)?;
                self.parse_create_iceberg_sink_connection()
            }
            _ => unreachable!(),
        }
    }

    fn parse_create_view(&mut self) -> Result<Statement<Raw>, ParserError> {
        let mut if_exists = if self.parse_keyword(OR) {