biquery: CREATE VIEW OPTIONS (#35)

Author: lustefaniak

src/ast/mod.rs

@@ -1573,6 +1573,7 @@ pub enum Statement {
         late_binding: bool,
         auto_refresh: Option<bool>,
         comment: Option<String>,
+        view_options: Vec<SqlOption>,
     },
     /// CREATE TABLE
     CreateTable {
@@ -2535,6 +2536,7 @@ impl fmt::Display for Statement {
                 late_binding,
                 auto_refresh,
                 comment,
+                view_options,
             } => {
                 write!(
                     f,
@@ -2590,6 +2592,14 @@ impl fmt::Display for Statement {
                     write!(f, " COMMENT='{comment}'")?;
                 }
 
+                if !view_options.is_empty() {
+                    write!(
+                        f,
+                        " OPTIONS({view_options})",
+                        view_options = display_comma_separated(view_options)
+                    )?;
+                }
+
                 write!(f, " AS {query}")?;
 
                 if *late_binding {

src/parser/mod.rs

@@ -3347,6 +3347,8 @@ impl<'a> Parser<'a> {
             None
         };
 
+        let view_options = self.parse_options(Keyword::OPTIONS)?;
+
         self.expect_keyword(Keyword::AS)?;
         let query = Box::new(self.parse_query()?);
         // Optional `WITH [ CASCADED | LOCAL ] CHECK OPTION` is widely supported here.
@@ -3377,6 +3379,7 @@ impl<'a> Parser<'a> {
             late_binding,
             auto_refresh,
             comment,
+            view_options,
         })
     }
 

tests/sqlparser_bigquery.rs

@@ -1285,3 +1285,10 @@ fn test_create_table_field_options() {
         "CREATE TABLE `pr`.`ts`.`salesforce_accounts` (account_name STRING OPTIONS(description = \"Account name\", label = \"dev\"))",
     );
 }
+
+#[test]
+fn test_create_view_options() {
+    bigquery().verified_stmt(
+        "CREATE VIEW `myproject`.`mydataset`.`newview` OPTIONS(friendly_name = \"newview\", description = \"a view that expires in 2 days\") AS SELECT col_1 FROM `myproject`.`mydataset`.`mytable`",
+    );
+}

tests/sqlparser_common.rs

@@ -5703,6 +5703,7 @@ fn parse_create_view() {
             late_binding,
             auto_refresh,
             comment,
+            view_options,
         } => {
             assert_eq!("myschema.myview", name.to_string());
             assert_eq!(Vec::<WithSpan<Ident>>::new(), columns);
@@ -5721,6 +5722,7 @@ fn parse_create_view() {
             assert_eq!(late_binding, false);
             assert_eq!(auto_refresh, None);
             assert_eq!(comment, None);
+            assert_eq!(view_options, vec![]);
         }
         _ => unreachable!(),
     }
@@ -5771,6 +5773,7 @@ fn parse_create_view_with_columns() {
             late_binding,
             auto_refresh,
             comment,
+            view_options,
         } => {
             assert_eq!("v", name.to_string());
             assert_eq!(
@@ -5795,6 +5798,7 @@ fn parse_create_view_with_columns() {
             assert_eq!(late_binding, false);
             assert_eq!(auto_refresh, None);
             assert_eq!(comment, None);
+            assert_eq!(view_options, vec![]);
         }
         _ => unreachable!(),
     }
@@ -5822,6 +5826,7 @@ fn parse_create_or_replace_view() {
             late_binding,
             auto_refresh,
             comment,
+            view_options,
         } => {
             assert_eq!("v", name.to_string());
             assert_eq!(columns, vec![]);
@@ -5840,6 +5845,7 @@ fn parse_create_or_replace_view() {
             assert_eq!(late_binding, false);
             assert_eq!(auto_refresh, None);
             assert_eq!(comment, None);
+            assert_eq!(view_options, vec![]);
         }
         _ => unreachable!(),
     }
@@ -5871,6 +5877,7 @@ fn parse_create_or_replace_materialized_view() {
             late_binding,
             auto_refresh,
             comment,
+            view_options,
         } => {
             assert_eq!("v", name.to_string());
             assert_eq!(columns, vec![]);
@@ -5889,6 +5896,7 @@ fn parse_create_or_replace_materialized_view() {
             assert_eq!(late_binding, false);
             assert_eq!(auto_refresh, None);
             assert_eq!(comment, None);
+            assert_eq!(view_options, vec![]);
         }
         _ => unreachable!(),
     }
@@ -5916,6 +5924,7 @@ fn parse_create_materialized_view() {
             late_binding,
             auto_refresh,
             comment,
+            view_options,
         } => {
             assert_eq!("myschema.myview", name.to_string());
             assert_eq!(Vec::<WithSpan<Ident>>::new(), columns);
@@ -5934,6 +5943,7 @@ fn parse_create_materialized_view() {
             assert_eq!(late_binding, false);
             assert_eq!(auto_refresh, None);
             assert_eq!(comment, None);
+            assert_eq!(view_options, vec![]);
         }
         _ => unreachable!(),
     }
@@ -5961,6 +5971,7 @@ fn parse_create_materialized_view_with_cluster_by() {
             late_binding,
             auto_refresh,
             comment,
+            view_options,
         } => {
             assert_eq!("myschema.myview", name.to_string());
             assert_eq!(Vec::<WithSpan<Ident>>::new(), columns);
@@ -5979,6 +5990,7 @@ fn parse_create_materialized_view_with_cluster_by() {
             assert_eq!(late_binding, false);
             assert_eq!(auto_refresh, None);
             assert_eq!(comment, None);
+            assert_eq!(view_options, vec![]);
         }
         _ => unreachable!(),
     }