Merge pull request #451 from kitta65/feature/issue-430

Feature/issue 430

src/parser.rs

@@ -2025,6 +2025,10 @@ impl Parser {
     // ----- DDL -----
     fn parse_create_schema_statement(&mut self, semicolon: bool) -> BQ2CSTResult<Node> {
         let mut create = self.construct_node(NodeType::CreateSchemaStatement)?;
+        if self.get_token(1)?.is("EXTERNAL") {
+            self.next_token()?; // -> EXTERNAL
+            create.push_node("external", self.construct_node(NodeType::Keyword)?);
+        }
         self.next_token()?; // -> SCHEMA
         create.push_node("what", self.construct_node(NodeType::Keyword)?);
         if self.get_token(1)?.is("IF") {
@@ -2047,6 +2051,10 @@ impl Parser {
             default.push_node("next_keyword", collate);
             create.push_node("default_collate", default);
         }
+        if self.get_token(1)?.is("WITH") && self.get_token(2)?.is("CONNECTION") {
+            self.next_token()?; // -> WITH
+            create.push_node("with_connection", self.parse_with_connection_clause()?);
+        }
         if self.get_token(1)?.is("OPTIONS") {
             self.next_token()?; // OPTIONS
             create.push_node("options", self.parse_keyword_with_grouped_exprs(false)?);

src/parser/tests/tests_ddl.rs

@@ -71,6 +71,28 @@ ident:
   self: dataset_name (Identifier)
 what:
   self: SCHEMA (Keyword)
+",
+            0,
+        )),
+        Box::new(SuccessTestCase::new(
+            "\
+CREATE EXTERNAL SCHEMA dataset_name
+WITH CONNECTION connection_name
+",
+            "\
+self: CREATE (CreateSchemaStatement)
+external:
+  self: EXTERNAL (Keyword)
+ident:
+  self: dataset_name (Identifier)
+what:
+  self: SCHEMA (Keyword)
+with_connection:
+  self: WITH (KeywordSequence)
+  next_keyword:
+    self: CONNECTION (KeywordWithExpr)
+    expr:
+      self: connection_name (Identifier)
 ",
             0,
         )),

src/types.rs

@@ -649,10 +649,12 @@ export type CreateRowAccessPolicyStatement = XXXStatement & {
 export type CreateSchemaStatement = XXXStatement & {
   node_type: "CreateSchemaStatement";
   children: {
+    external?: NodeChild;
     what: NodeChild;
     if_not_exists?: NodeVecChild;
     ident: NodeChild;
     default_collate: NodeChild;
+    with_connection?: NodeChild;
     options?: NodeChild;
   };
 };