Multi session support for Snowflake.

Author: Roelant Vos

Virtual_EDW/Templates/templatePresentationGenerateTables.Handlebars

@@ -7,14 +7,16 @@ IF OBJECT_ID('[{{targetDataObject.name}}]', 'U') IS NOT NULL
   DROP TABLE [{{targetDataObject.name}}];
 
 CREATE TABLE [{{targetDataObject.name}}]
-(
+({{/if}}{{/each}}
+{{#each dataObjectMappings}}
     {{#each dataItemMappings}}
     [{{targetDataItem.name}}] [{{targetDataItem.dataType}}]{{#stringcompare targetDataItem.dataType "int"}}{{else}}{{#stringcompare targetDataItem.dataType "nvarchar"}}(1000){{else}}{{#stringcompare targetDataItem.dataType "datetime2"}}(7){{else}}{{#stringcompare targetDataItem.dataType "decimal"}}{{else}}{{#stringcompare targetDataItem.dataType "binary"}}(16){{else}}({{characterLength}}{{#stringcompare targetDataItem.dataType "numeric"}}{numericPrecision}},{{/stringcompare}}{{numericScale}}){{/stringcompare}}{{/stringcompare}}{{/stringcompare}}{{/stringcompare}}{{/stringcompare}},
          {{/each}}
-   [SNAPSHOT_DATE] [datetime2](7) NOT NULL,
-   [{{../metadataConfiguration.etlProcessAttribute}}] [int] NOT NULL,
-   [{{../metadataConfiguration.loadDateTimeAttribute}}] [datetime2](7) NOT NULL,
-   [{{../metadataConfiguration.changeDataCaptureAttribute}}] [nvarchar](100) NOT NULL,
-   [{{../metadataConfiguration.eventDateTimeAttribute}}] [datetime2](7) NOT NULL,
-   [{{../metadataConfiguration.recordChecksumAttribute}}] [binary](16) NOT NULL,
-){{/if}}{{/each}}
+{{/each}}
+    [SNAPSHOT_DATE] [datetime2](7) NOT NULL,
+    [{{metadataConfiguration.etlProcessAttribute}}] [int] NOT NULL,
+    [{{metadataConfiguration.loadDateTimeAttribute}}] [datetime2](7) NOT NULL,
+    [{{metadataConfiguration.changeDataCaptureAttribute}}] [nvarchar](100) NOT NULL,
+    [{{metadataConfiguration.eventDateTimeAttribute}}] [datetime2](7) NOT NULL,
+    [{{metadataConfiguration.recordChecksumAttribute}}] [binary](16) NOT NULL
+)

Virtual_EDW/VdwUtility.cs

@@ -234,6 +234,7 @@ public static void CreateVdwSchema(Microsoft.Data.SqlClient.SqlConnection connec
 
         public static void ExecuteInDatabase(TeamConnection teamConnection, string query)
         {
+            // SQL Server
             if (teamConnection.TechnologyConnectionType == TechnologyConnectionType.SqlServer)
             {
                 var connectionString = teamConnection.CreateSqlServerConnectionString(false);
@@ -260,6 +261,7 @@ public static void ExecuteInDatabase(TeamConnection teamConnection, string query
                     sqlConnection.Dispose();
                 }
             }
+            // Snowflake
             else if (teamConnection.TechnologyConnectionType == TechnologyConnectionType.Snowflake)
             {
                 IDbConnection conn = new SnowflakeDbConnection();
@@ -269,8 +271,13 @@ public static void ExecuteInDatabase(TeamConnection teamConnection, string query
                 {
                     conn.Open();
                     IDbCommand cmd = conn.CreateCommand();
+                    // Select the Snowflake warehouse.
                     cmd.CommandText = $"USE WAREHOUSE {teamConnection.DatabaseServer.Warehouse}";
                     cmd.ExecuteNonQuery();
+                    // Support multiple statements for this session.
+                    cmd.CommandText = "ALTER SESSION SET MULTI_STATEMENT_COUNT = 0;";
+                    cmd.ExecuteNonQuery();
+                    // Run the query generated from the template.
                     cmd.CommandText = query;
                     cmd.ExecuteNonQuery();
                 }