Method ParseCreateStatement

src/parser/parser.cpp:1142–1221

CREATE dispatches to TABLE or VIEW.

// CREATE dispatches to TABLE or VIEW.
ParsedStmtPtr Parser::ParseCreateStatement() {
    Expect(TokenType::KW_CREATE, "");

    // CREATE OR REPLACE VIEW
    bool or_replace = false;
    if (CheckKeyword(TokenType::KW_OR)) {
        Advance();
        if (Check(TokenType::IDENTIFIER) && StringUtil::Upper(Current().value) == "REPLACE") {
            Advance();
            or_replace = true;
        }
    }

    // CREATE [OR REPLACE] [LIVE] VIEW
    bool is_live = false;
    if (CheckKeyword(TokenType::KW_LIVE)) {
        Advance();
        is_live = true;
    }

    if (CheckKeyword(TokenType::KW_VIEW)) {
        Advance(); // consume VIEW
        auto stmt = std::make_unique<CreateViewStatement>();
        stmt->or_replace = or_replace;
        stmt->is_live = is_live;
        stmt->view_name = ExpectIdentifier("for view name").value;
        Expect(TokenType::KW_AS, "after view name");
        auto inner = ParseSelectStatement();
        stmt->query = std::unique_ptr<SelectStatement>(
            static_cast<SelectStatement *>(inner.release()));
        return stmt;
    }

    // Otherwise expect TABLE - put CREATE back (already consumed).
    // We need to parse the rest of CREATE TABLE without the CREATE keyword.
    Expect(TokenType::KW_TABLE, "after CREATE");

    auto stmt = std::make_unique<CreateTableStatement>();
    stmt->or_replace = or_replace;
    if (MatchKeyword(TokenType::KW_IF)) {
        Expect(TokenType::KW_NOT, "after IF");
        Expect(TokenType::KW_EXISTS, "after NOT");
        stmt->if_not_exists = true;
    }

    stmt->table_name = ExpectIdentifier("for table name").value;

    // CREATE [OR REPLACE] TABLE <name> AS SELECT ... - CTAS.
    // Schema is inferred at execution from the SELECT's result types, so
    // we just stash the SelectStatement; Connection materializes into a
    // real table. Mirrors the CREATE VIEW branch above.
    if (MatchKeyword(TokenType::KW_AS)) {
        auto inner = ParseSelectStatement();
        stmt->query = std::unique_ptr<SelectStatement>(
            static_cast<SelectStatement *>(inner.release()));
        return stmt;
    }