Saving WIP

Author: RoelantVos

Virtual_EDW/Templates/loadPatternHubInsertIntofromSTG.Handlebars

@@ -0,0 +1,43 @@
+{{#each dataObjectMappings}}
+--
+-- Hub Insert Into statement for {{targetDataObject.name}}
+--
+IF  EXISTS (SELECT * FROM sys.objects WHERE object_id = OBJECT_ID(N'INT.SP_{{targetDataObject.name}}_{{sourceDataObjects.0.name}}') AND type in (N'P'))
+DROP PROCEDURE [INT].[SP_{{targetDataObject.name}}_{{sourceDataObjects.0.name}}];
+GO
+
+CREATE PROCEDURE [INT].[SP_{{targetDataObject.name}}_{{sourceDataObjects.0.name}}] @OMD_INSERT_MODULE_INSTANCE_ID int
+AS
+
+--
+-- Hub Insert Into statement for [{{targetDataObject.name}}]
+--
+
+INSERT INTO [INT].[{{targetDataObject.name}}]
+(
+  [{{targetDataObject.name}}_SK],
+  OMD_INSERT_DATETIME,
+  OMD_INSERT_MODULE_INSTANCE_ID,
+  OMD_RECORD_SOURCE_ID,
+  {{#each businessKeys}}{{#if @first}}{{#each businessKeyComponentMapping}}
+   [{{targetDataItem.name}}]{{#unless @last}},{{/unless}}{{/each}}{{/if}}{{/each}}
+)
+          SELECT 
+               CONVERT(CHAR,HASHBYTES('SHA1',UPPER({{#each businessKeys}}{{#each businessKeyComponentMapping}} RTRIM(ISNULL({{stringcompare sourceDataItems.0.isHardCodedValue 'True'}} [{{/stringcompare }}{{sourceDataItems.0.name}}{{stringcompare sourceDataItems.0.isHardCodedValue 'True'}}] {{/stringcompare }},'NA')){{#unless @last}}+'|'+{{/unless}}{{/each}} {{/each}} )),2) as  [{{targetDataObject.name}}_SK],
+   min(OMD_INSERT_DATETIME),
+  @OMD_INSERT_MODULE_INSTANCE_ID,
+  min(OMD_RECORD_SOURCE_ID),
+               {{#each businessKeys}}{{#each businessKeyComponentMapping}}
+            ISNULL({{stringcompare sourceDataItems.0.isHardCodedValue 'True'}} [{{/stringcompare }}{{sourceDataItems.0.name}}{{stringcompare sourceDataItems.0.isHardCodedValue 'True'}}] {{/stringcompare }},'NA') AS [{{targetDataItem.name}}]{{#unless @last}},{{/unless}}{{/each}}{{/each}}
+
+          FROM [{{sourceDataObjects.0.dataObjectConnection.extensions.1.value}}].[{{sourceDataObjects.0.name}}] stg
+          WHERE  CONVERT(CHAR,HASHBYTES('SHA1',UPPER({{#each businessKeys}}{{#each businessKeyComponentMapping}} RTRIM(ISNULL({{stringcompare sourceDataItems.0.isHardCodedValue 'True'}} [{{/stringcompare }}{{sourceDataItems.0.name}}{{stringcompare sourceDataItems.0.isHardCodedValue 'True'}}] {{/stringcompare }},'NA')){{#unless @last}}+'|'+{{/unless}}{{/each}} {{/each}} )),2) NOT IN
+          (
+             SELECT [{{targetDataObject.name}}_SK]
+             FROM [INT].[{{targetDataObject.name}}] INT
+             )
+             GROUP BY  {{#each businessKeys}}{{#each businessKeyComponentMapping}}{{stringcompare sourceDataItems.0.isHardCodedValue 'True'}}{{#unless @first}},{{/unless}} [{{sourceDataItems.0.name}}]{{/stringcompare}}{{/each}}{{/each}} ;
+
+SELECT @@ROWCOUNT AS ROWS_INSERTED
+GO
+{{/each}}

Virtual_EDW/Templates/loadPatternHubView.handlebarsBackup_20221213105949

@@ -0,0 +1,60 @@
+{{#each dataObjectMappings}}
+--
+-- Link Insert Into statement for {{targetDataObject.name}}
+--
+
+IF  EXISTS (SELECT * FROM sys.objects WHERE object_id = OBJECT_ID(N'INT.SP_{{targetDataObject.name}}_{{sourceDataObjects.0.name}}') AND type in (N'P'))
+DROP PROCEDURE [INT].[SP_{{targetDataObject.name}}_{{sourceDataObjects.0.name}}];
+GO
+
+CREATE PROCEDURE [INT].[SP_{{targetDataObject.name}}_{{sourceDataObjects.0.name}}] @OMD_INSERT_MODULE_INSTANCE_ID int
+AS
+
+--
+-- LNK Insert Into statement for [{{targetDataObject.name}}]
+-- Includes the GROUP BY clause
+
+INSERT INTO [INT].[{{targetDataObject.name}}]
+(  {{#each businessKeys}} {{#if @first}} [{{surrogateKey}}], {{/if}}{{/each}}
+   {{#each businessKeys}}{{#unless @first}} 
+   [{{surrogateKey}}],{{/unless}} {{/each}}
+   OMD_INSERT_DATETIME,
+   OMD_RECORD_SOURCE_ID,
+   OMD_INSERT_MODULE_INSTANCE_ID
+)
+
+SELECT
+   CONVERT(CHAR,HASHBYTES('SHA1',UPPER( {{#each businessKeys}} {{#unless @first}}{{!-- Create the Surrogate Key using the combined Business Keys --}}
+{{#each dataItemMappings}} RTRIM(ISNULL([{{targetDataItem.name}}], 'NA')) + '|'+{{/each}}
+{{#each businessKeyComponentMapping}}  RTRIM(ISNULL([{{targetDataItem.name}}{{@../index }}], 'NA')) {{#unless @last}} + '|' +{{/unless}}{{/each}}{{#unless @last}} +'|'+{{/unless}}{{/unless}}{{/each}}
+{{#each dataItemMappings}} +  RTRIM(ISNULL([{{targetDataItem.name}}], 'NA')) + '|'+{{/each}}{{#each businessKeys}} {{#if @first}})),2) AS [{{surrogateKey}}],{{/if}}{{/each}}
+   {{#each businessKeys}}{{#unless @first}} {{!-- List out the separate (Hub) business keys, by skipping the first generic relationship key. --}}
+    {{#unless businessKeyClassification}}
+   CONVERT(CHAR,HASHBYTES('SHA1',UPPER( {{#each businessKeyComponentMapping}} RTRIM(ISNULL([{{targetDataItem.name}}{{@../index }}],'NA')) {{#unless @last}} +'|'+{{/unless}}{{/each}})),2) AS [{{surrogateKey}}],
+    {{/unless}}{{#if businessKeyClassification}}{{#each businessKeyComponentMapping}}[{{targetDataItem.name}}{{@../index }}]{{/each}} AS [{{surrogateKey}}],
+    {{/if}} {{/unless}} {{/each}}{{#each dataItemMappings}}
+    [{{targetDataItem.name}}],{{/each}}
+     OMD_INSERT_DATETIME,
+     OMD_RECORD_SOURCE_ID,
+  @OMD_INSERT_MODULE_INSTANCE_ID
+FROM 
+(
+    SELECT {{#each businessKeys}} {{#unless @first}} {{#each businessKeyComponentMapping}}
+           CAST({{stringcompare sourceDataItems.0.isHardCodedValue 'True'}}[{{/stringcompare}}{{sourceDataItems.0.name}}{{stringcompare sourceDataItems.0.isHardCodedValue 'True'}}]{{/stringcompare}} AS NVARCHAR(100)) AS [{{targetDataItem.name}}{{@../index }}],{{/each}}{{/unless}}{{/each}}{{#each dataItemMappings}}
+                    [{{sourceDataItems.0.name}}] AS [{{targetDataItem.name}}],{{/each}}
+                    min(OMD_INSERT_DATETIME) AS OMD_INSERT_DATETIME,
+                    min(OMD_RECORD_SOURCE_ID) AS  OMD_RECORD_SOURCE_ID
+          FROM STG.[{{sourceDataObjects.0.name}}]
+          GROUP BY   {{#each businessKeys}}{{#if @first}}{{#each businessKeyComponentMapping}}{{stringcompare sourceDataItems.0.isHardCodedValue 'True'}}{{#unless @first}},{{/unless}} [{{sourceDataItems.0.name}}]{{/stringcompare}}{{/each}}{{/if}}{{/each}}
+ ) LINK_selection
+WHERE   CONVERT(CHAR,HASHBYTES('SHA1',UPPER( {{#each businessKeys}} {{#unless @first}}{{!-- Create the Surrogate Key using the combined Business Keys --}}
+{{#each dataItemMappings}} RTRIM(ISNULL([{{targetDataItem.name}}], 'NA')) + '|'+{{/each}}
+{{#each businessKeyComponentMapping}}  RTRIM(ISNULL([{{targetDataItem.name}}{{@../index }}], 'NA')) {{#unless @last}} + '|' +{{/unless}}{{/each}}{{#unless @last}} +'|'+{{/unless}}{{/unless}}{{/each}}
+{{#each dataItemMappings}} +  RTRIM(ISNULL([{{targetDataItem.name}}], 'NA')) + '|'+{{/each}}{{#each businessKeys}} {{#if @first}})),2) {{/if}}{{/each}} NOT IN 
+  (
+SELECT  [{{targetDataObject.name}}_SK] 
+FROM [INT].[{{targetDataObject.name}}]
+);
+SELECT @@ROWCOUNT AS ROWS_INSERTED
+GO
+ {{/each}}