Added dynamic keyword parsing for snowflake

Author: romanoff

src/ast/ddl.rs

@@ -365,6 +365,10 @@ pub enum AlterTableOperation {
     DropClusteringKey,
     SuspendRecluster,
     ResumeRecluster,
+    /// `REFRESH`
+    ///
+    /// Note: this is Snowflake specific for dynamic tables <https://docs.snowflake.com/en/sql-reference/sql/alter-table>
+    Refresh,
     /// `ALGORITHM [=] { DEFAULT | INSTANT | INPLACE | COPY }`
     ///
     /// [MySQL]-specific table alter algorithm.
@@ -845,6 +849,9 @@ impl fmt::Display for AlterTableOperation {
                 write!(f, "RESUME RECLUSTER")?;
                 Ok(())
             }
+            AlterTableOperation::Refresh => {
+                write!(f, "REFRESH")
+            }
             AlterTableOperation::AutoIncrement { equals, value } => {
                 write!(
                     f,

src/ast/spans.rs

@@ -1107,6 +1107,7 @@ impl Spanned for AlterTableOperation {
             AlterTableOperation::DropClusteringKey => Span::empty(),
             AlterTableOperation::SuspendRecluster => Span::empty(),
             AlterTableOperation::ResumeRecluster => Span::empty(),
+            AlterTableOperation::Refresh => Span::empty(),
             AlterTableOperation::Algorithm { .. } => Span::empty(),
             AlterTableOperation::AutoIncrement { value, .. } => value.span(),
             AlterTableOperation::Lock { .. } => Span::empty(),

src/dialect/snowflake.rs

@@ -26,7 +26,7 @@ use crate::ast::helpers::stmt_data_loading::{
     FileStagingCommand, StageLoadSelectItem, StageLoadSelectItemKind, StageParamsObject,
 };
 use crate::ast::{
-    CatalogSyncNamespaceMode, ColumnOption, ColumnPolicy, ColumnPolicyProperty, ContactEntry,
+    AlterTableOperation, CatalogSyncNamespaceMode, ColumnOption, ColumnPolicy, ColumnPolicyProperty, ContactEntry,
     CopyIntoSnowflakeKind, CreateTableLikeKind, DollarQuotedString, Ident, IdentityParameters,
     IdentityProperty, IdentityPropertyFormatKind, IdentityPropertyKind, IdentityPropertyOrder,
     InitializeKind, ObjectName, ObjectNamePart, RefreshModeKind, RowAccessPolicy, ShowObjects,
@@ -214,6 +214,11 @@ impl Dialect for SnowflakeDialect {
             return Some(parser.parse_begin_exception_end());
         }
 
+	if parser.parse_keywords(&[Keyword::ALTER, Keyword::DYNAMIC, Keyword::TABLE]) {
+            // ALTER DYNAMIC TABLE
+            return Some(parse_alter_dynamic_table(parser));
+	}
+
         if parser.parse_keywords(&[Keyword::ALTER, Keyword::SESSION]) {
             // ALTER SESSION
             let set = match parser.parse_one_of_keywords(&[Keyword::SET, Keyword::UNSET]) {
@@ -604,6 +609,27 @@ fn parse_file_staging_command(kw: Keyword, parser: &mut Parser) -> Result<Statem
     }
 }
 
+/// Parse snowflake alter dynamic table.
+/// <https://docs.snowflake.com/en/sql-reference/sql/alter-table>
+fn parse_alter_dynamic_table(parser: &mut Parser) -> Result<Statement, ParserError> {
+    let table_name = parser.parse_object_name(false)?;
+
+    // Parse the operation (currently only REFRESH is supported)
+    if parser.parse_keyword(Keyword::REFRESH) {
+        Ok(Statement::AlterTable {
+            name: table_name,
+            if_exists: false,
+            only: false,
+            operations: vec![AlterTableOperation::Refresh],
+            location: None,
+            on_cluster: None,
+            iceberg: false,
+        })
+    } else {
+        parser.expected("REFRESH after ALTER DYNAMIC TABLE", parser.peek_token())
+    }
+}
+
 /// Parse snowflake alter session.
 /// <https://docs.snowflake.com/en/sql-reference/sql/alter-session>
 fn parse_alter_session(parser: &mut Parser, set: bool) -> Result<Statement, ParserError> {

src/keywords.rs

@@ -784,6 +784,7 @@ define_keywords!(
     REFERENCES,
     REFERENCING,
     REFRESH_MODE,
+    REFRESH,
     REGCLASS,
     REGEXP,
     REGION,

tests/sqlparser_snowflake.rs

@@ -4662,3 +4662,56 @@ fn test_drop_constraints() {
     snowflake().verified_stmt("ALTER TABLE tbl DROP FOREIGN KEY k1 RESTRICT");
     snowflake().verified_stmt("ALTER TABLE tbl DROP CONSTRAINT c1 CASCADE");
 }
+
+#[test]
+fn test_snowflake_alter_dynamic_table_refresh() {
+    // Test with simple table name
+    let sql = "ALTER DYNAMIC TABLE MY_DYNAMIC_TABLE REFRESH";
+    let result = snowflake().parse_sql_statements(sql);
+
+    assert!(
+        result.is_ok(),
+        "Expected ALTER DYNAMIC TABLE to parse successfully"
+    );
+
+    match result.unwrap().first().unwrap() {
+        Statement::AlterTable {
+            name, operations, ..
+        } => {
+            assert_eq!(name.to_string(), "MY_DYNAMIC_TABLE");
+            assert_eq!(operations.len(), 1);
+            match &operations[0] {
+                AlterTableOperation::Refresh => {
+                    // Success!
+                }
+                _ => panic!("Expected Refresh operation"),
+            }
+        }
+        _ => panic!("Expected AlterTable statement"),
+    }
+
+    // Test with qualified table name
+    let sql3 = "ALTER DYNAMIC TABLE my_database.my_schema.my_dynamic_table REFRESH";
+    let result3 = snowflake().parse_sql_statements(sql3);
+
+    assert!(
+        result3.is_ok(),
+        "Expected ALTER DYNAMIC TABLE to parse successfully"
+    );
+
+    match result3.unwrap().first().unwrap() {
+        Statement::AlterTable {
+            name, operations, ..
+        } => {
+            assert_eq!(name.to_string(), "my_database.my_schema.my_dynamic_table");
+            assert_eq!(operations.len(), 1);
+            match &operations[0] {
+                AlterTableOperation::Refresh => {
+                    // Success!
+                }
+                _ => panic!("Expected Refresh operation"),
+            }
+        }
+        _ => panic!("Expected AlterTable statement"),
+    }
+}