branchig adaptation

eclipse-dirigible · Apr 3, 2024 · 67c2611 · 67c2611
1 parent b1527c8
commit 67c2611
Show file tree

Hide file tree

Showing 3 changed files with 73 additions and 3 deletions.
diff --git a/...rg/eclipse/dirigible/database/sql/dialects/snowflake/SnowflakeCreateBranchingBuilder.java b/...rg/eclipse/dirigible/database/sql/dialects/snowflake/SnowflakeCreateBranchingBuilder.java
@@ -38,4 +38,54 @@ public SnowflakeCreateTableBuilder table(String table) {
         return new SnowflakeCreateTableBuilder(this.getDialect(), table, ISqlDialect.KEYWORD_HYBRID);
     }
 
+    /**
+     * Hybrid table.
+     *
+     * @param table the table
+     * @return the creates the table builder
+     */
+    public SnowflakeCreateTableBuilder hybridTable(String table) {
+        return new SnowflakeCreateTableBuilder(this.getDialect(), table, ISqlDialect.KEYWORD_HYBRID);
+    }
+
+    /**
+     * Dynamic table.
+     *
+     * @param table the table
+     * @return the creates the table builder
+     */
+    public SnowflakeCreateTableBuilder dynamicTable(String table) {
+        return new SnowflakeCreateTableBuilder(this.getDialect(), table, ISqlDialect.KEYWORD_DYNAMIC);
+    }
+
+    /**
+     * Event table.
+     *
+     * @param table the table
+     * @return the creates the table builder
+     */
+    public SnowflakeCreateTableBuilder eventTable(String table) {
+        return new SnowflakeCreateTableBuilder(this.getDialect(), table, ISqlDialect.KEYWORD_EVENT);
+    }
+
+    /**
+     * External table.
+     *
+     * @param table the table
+     * @return the creates the table builder
+     */
+    public SnowflakeCreateTableBuilder externalTable(String table) {
+        return new SnowflakeCreateTableBuilder(this.getDialect(), table, ISqlDialect.KEYWORD_EXTERNAL);
+    }
+
+    /**
+     * Iceberg table.
+     *
+     * @param table the table
+     * @return the creates the table builder
+     */
+    public SnowflakeCreateTableBuilder icebergTable(String table) {
+        return new SnowflakeCreateTableBuilder(this.getDialect(), table, ISqlDialect.KEYWORD_ICEBERG);
+    }
+
 }
diff --git a/.../main/java/org/eclipse/dirigible/database/sql/dialects/snowflake/SnowflakeSqlDialect.java b/.../main/java/org/eclipse/dirigible/database/sql/dialects/snowflake/SnowflakeSqlDialect.java
@@ -32,7 +32,7 @@
  * The Snowflake SQL Dialect.
  */
 public class SnowflakeSqlDialect extends
-        DefaultSqlDialect<SelectBuilder, InsertBuilder, UpdateBuilder, DeleteBuilder, CreateBranchingBuilder, AlterBranchingBuilder, DropBranchingBuilder, SnowflakeNextValueSequenceBuilder, SnowflakeLastValueIdentityBuilder> {
+        DefaultSqlDialect<SelectBuilder, InsertBuilder, UpdateBuilder, DeleteBuilder, SnowflakeCreateBranchingBuilder, AlterBranchingBuilder, DropBranchingBuilder, SnowflakeNextValueSequenceBuilder, SnowflakeLastValueIdentityBuilder> {
 
     /** The Constant FUNCTIONS. */
     public static final Set<String> FUNCTIONS = Collections.synchronizedSet(new HashSet<String>(Arrays.asList(new String[] {"ABS", "ACOS",

diff --git a/.../src/test/java/org/eclipse/dirigible/database/sql/dialects/snowflake/CreateTableTest.java b/.../src/test/java/org/eclipse/dirigible/database/sql/dialects/snowflake/CreateTableTest.java
@@ -37,7 +37,7 @@ public void createTableGeneric() {
 
         assertNotNull(sql);
         assertEquals(
-                "CREATE TABLE CUSTOMERS ( ID INTEGER NOT NULL PRIMARY KEY , FIRST_NAME VARCHAR (20) NOT NULL UNIQUE , LAST_NAME VARCHAR (30) )",
+                "CREATE HYBRID TABLE CUSTOMERS ( ID INTEGER NOT NULL PRIMARY KEY , FIRST_NAME VARCHAR (20) NOT NULL UNIQUE , LAST_NAME VARCHAR (30) )",
                 sql);
     }
 
@@ -55,7 +55,27 @@ public void createTableTypeSafe() {
                                .build();
 
         assertNotNull(sql);
-        assertEquals("CREATE TABLE CUSTOMERS ( ID INTEGER NOT NULL PRIMARY KEY , FIRST_NAME VARCHAR (20) UNIQUE , LAST_NAME VARCHAR (30) )",
+        assertEquals(
+                "CREATE HYBRID TABLE CUSTOMERS ( ID INTEGER NOT NULL PRIMARY KEY , FIRST_NAME VARCHAR (20) UNIQUE , LAST_NAME VARCHAR (30) )",
+                sql);
+    }
+
+    /**
+     * Creates the table type safe.
+     */
+    @Test
+    public void createTableTypeIceberg() {
+        String sql = SqlFactory.getNative(new SnowflakeSqlDialect())
+                               .create()
+                               .icebergTable("CUSTOMERS")
+                               .columnInteger("ID", true, false, false)
+                               .columnVarchar("FIRST_NAME", 20, false, true, true)
+                               .columnVarchar("LAST_NAME", 30, false, true, false)
+                               .build();
+
+        assertNotNull(sql);
+        assertEquals(
+                "CREATE ICEBERG TABLE CUSTOMERS ( ID INTEGER NOT NULL PRIMARY KEY , FIRST_NAME VARCHAR (20) UNIQUE , LAST_NAME VARCHAR (30) )",
                 sql);
     }