Method parse_alter_source

src/sql-parser/src/parser.rs:5840–5984

(&mut self)

    }

    fn parse_alter_source(&mut self) -> Result<Statement<Raw>, ParserStatementError> {
        let if_exists = self.parse_if_exists().map_no_statement_parser_err()?;
        let source_name = self.parse_item_name().map_no_statement_parser_err()?;

        Ok(
            match self
                .expect_one_of_keywords(&[ADD, DROP, RESET, SET, RENAME, OWNER, REFRESH])
                .map_no_statement_parser_err()?
            {
                ADD => {
                    self.expect_one_of_keywords(&[SUBSOURCE, TABLE])
                        .map_parser_err(StatementKind::AlterSource)?;

                    // TODO: Add IF NOT EXISTS?
                    let subsources = self
                        .parse_comma_separated(Parser::parse_subsource_references)
                        .map_parser_err(StatementKind::AlterSource)?;

                    let options = if self.parse_keyword(WITH) {
                        self.expect_token(&Token::LParen)
                            .map_parser_err(StatementKind::AlterSource)?;
                        let options = self
                            .parse_comma_separated(Parser::parse_alter_source_add_subsource_option)
                            .map_parser_err(StatementKind::AlterSource)?;
                        self.expect_token(&Token::RParen)
                            .map_parser_err(StatementKind::AlterSource)?;
                        options
                    } else {
                        vec![]
                    };

                    Statement::AlterSource(AlterSourceStatement {
                        source_name,
                        if_exists,
                        action: AlterSourceAction::AddSubsources {
                            external_references: subsources,
                            options,
                        },
                    })
                }
                DROP => {
                    self.expect_one_of_keywords(&[SUBSOURCE, TABLE])
                        .map_parser_err(StatementKind::AlterSource)?;

                    let if_exists_inner = self
                        .parse_if_exists()
                        .map_parser_err(StatementKind::AlterSource)?;

                    let names = self
                        .parse_comma_separated(Parser::parse_item_name)
                        .map_parser_err(StatementKind::AlterSource)?;

                    let cascade = matches!(
                        self.parse_at_most_one_keyword(&[CASCADE, RESTRICT], "ALTER SOURCE...DROP")
                            .map_parser_err(StatementKind::AlterSource)?,
                        Some(CASCADE),
                    );