iffyio commented on code in PR #1960:
URL:
https://github.com/apache/datafusion-sqlparser-rs/pull/1960#discussion_r2229202341
##########
tests/sqlparser_snowflake.rs:
##########
@@ -1104,6 +1066,59 @@ fn
parse_sf_create_table_or_view_with_dollar_quoted_comment() {
);
}
+#[test]
+fn parse_create_dynamic_table() {
+ snowflake().verified_stmt(r#"CREATE OR REPLACE DYNAMIC TABLE
my_dynamic_table TARGET_LAG='20 minutes' WAREHOUSE=mywh AS SELECT product_id,
product_name FROM staging_table"#);
+ snowflake().verified_stmt(concat!(
+ "CREATE DYNAMIC ICEBERG TABLE my_dynamic_table (date TIMESTAMP_NTZ, id
NUMBER, content STRING)",
+ " EXTERNAL_VOLUME='my_external_volume'",
+ " CATALOG='SNOWFLAKE'",
+ " BASE_LOCATION='my_iceberg_table'",
+ " TARGET_LAG='20 minutes'",
+ " WAREHOUSE=mywh",
+ " AS SELECT product_id, product_name FROM staging_table"
+ ));
+
+ snowflake().verified_stmt(concat!(
+ "CREATE DYNAMIC TABLE my_dynamic_table (date TIMESTAMP_NTZ, id NUMBER,
content VARIANT)",
+ " CLUSTER BY (date, id)",
+ " TARGET_LAG='20 minutes'",
+ " WAREHOUSE=mywh",
+ " AS SELECT product_id, product_name FROM staging_table"
+ ));
+
+ snowflake().verified_stmt(concat!(
+ "CREATE DYNAMIC TABLE my_cloned_dynamic_table",
+ " CLONE my_dynamic_table",
+ " AT(TIMESTAMP => TO_TIMESTAMP_TZ('04/05/2013 01:02:03', 'mm/dd/yyyy
hh24:mi:ss'))"
+ ));
+
+ snowflake().verified_stmt(concat!(
+ "CREATE DYNAMIC TABLE my_cloned_dynamic_table",
+ " CLONE my_dynamic_table",
+ " BEFORE(OFFSET => TO_TIMESTAMP_TZ('04/05/2013 01:02:03', 'mm/dd/yyyy
hh24:mi:ss'))"
+ ));
+
+ snowflake().verified_stmt(concat!(
+ "CREATE DYNAMIC TABLE my_dynamic_table",
+ " TARGET_LAG='DOWNSTREAM'",
+ " WAREHOUSE=mywh",
+ " INITIALIZE=ON_SCHEDULE",
+ " REQUIRE USER",
+ " AS SELECT product_id, product_name FROM staging_table"
+ ));
+
+ snowflake().verified_stmt(concat!(
+ "CREATE DYNAMIC TABLE my_dynamic_table",
+ " TARGET_LAG='DOWNSTREAM'",
+ " WAREHOUSE=mywh",
+ " REFRESH_MODE=AUTO",
Review Comment:
Can we add similar coverage for `REFRESH_MODE=FULL` and
`REFRESH_MODE=INCREMENTAL`?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscr...@datafusion.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: github-unsubscr...@datafusion.apache.org
For additional commands, e-mail: github-h...@datafusion.apache.org
