Reinit templates

Author: RoelantVos

Virtual_EDW/Templates/loadPatternLinkSatelliteReinitialisation.Handlebars

@@ -0,0 +1,49 @@
+{{#each dataObjectMappings}}
+{{#if enabled}}
+--
+-- Satellite Reinitialisation logic for [{{#each targetDataObject.dataObjectConnection.extensions}}{{#stringcompare key schema}}{{value}}{{/stringcompare}}{{/each}}].[{{targetDataObject.name}}]
+-- 
+
+-- Truncate the source for the Satellite, the Staging Area table.
+TRUNCATE TABLE [{{#each sourceDataObjects.0.dataObjectConnection.extensions}}{{#stringcompare key schema}}{{value}}{{/stringcompare}}{{/each}}].[{{sourceDataObjects.0.name}}]
+
+-- Copy the data from the Staging Area to the PSA.
+INSERT INTO STG.{{sourceDataObjects.0.name}}
+(
+   [OMD_INSERT_MODULE_INSTANCE_ID]
+  ,[OMD_FILE_LOCATION]
+  ,[OMD_EVENT_DATETIME]
+  ,[OMD_INSERT_DATETIME]
+  ,[OMD_HASH_DIFF]
+  ,[OMD_CURRENT_RECORD_INDICATOR]
+  ,[OMD_DELETED_RECORD_INDICATOR]
+  ,[OMD_EXPIRY_DATETIME]
+  ,[OMD_RECORD_SOURCE_ID]
+  ,[OMD_SOURCE_ROW_ID]
+{{#each dataItemMappings}}
+  ,[{{sourceDataItems.0.name}}]
+{{/each}}
+)
+SELECT 
+   [OMD_INSERT_MODULE_INSTANCE_ID]
+  ,[OMD_FILE_LOCATION]
+  ,[OMD_EVENT_DATETIME]
+  ,[OMD_EFFECTIVE_DATETIME]
+  ,[OMD_HASH_DIFF]
+  ,[OMD_CURRENT_RECORD_INDICATOR]
+  ,[OMD_DELETED_RECORD_INDICATOR]
+  ,[OMD_EXPIRY_DATETIME]
+  ,[OMD_RECORD_SOURCE_ID]
+  ,[OMD_SOURCE_ROW_ID]
+{{#each dataItemMappings}}
+  ,[{{sourceDataItems.0.name}}]
+{{/each}}
+FROM PSA.{{StringReplace sourceDataObjects.0.name "STG" "PSA"}}
+
+-- Truncate the Satellite table.
+TRUNCATE TABLE [{{#each targetDataObject.dataObjectConnection.extensions}}{{#stringcompare key schema}}{{value}}{{/stringcompare}}{{/each}}].[{{targetDataObject.name}}];
+
+-- Rerun the Satellite loading procedure.
+EXEC [INT].[SP_{{targetDataObject.name}}] 0;
+
+{{/if}}{{/each}}

Virtual_EDW/Templates/loadPatternSatelliteReinitialisation.Handlebars

@@ -0,0 +1,48 @@
+{{#each dataObjectMappings}}
+{{#if enabled}}
+--
+-- Satellite Reinitialisation logic for [{{#each targetDataObject.dataObjectConnection.extensions}}{{#stringcompare key schema}}{{value}}{{/stringcompare}}{{/each}}].[{{targetDataObject.name}}]
+-- 
+
+-- Truncate the source for the Satellite, the Staging Area table.
+TRUNCATE TABLE [{{#each sourceDataObjects.0.dataObjectConnection.extensions}}{{#stringcompare key schema}}{{value}}{{/stringcompare}}{{/each}}].[{{sourceDataObjects.0.name}}]
+
+-- Copy the data from the Staging Area to the PSA.
+INSERT INTO STG.{{sourceDataObjects.0.name}}
+(
+   [OMD_INSERT_MODULE_INSTANCE_ID]
+  ,[OMD_FILE_LOCATION]
+  ,[OMD_EVENT_DATETIME]
+  ,[OMD_INSERT_DATETIME]
+  ,[OMD_HASH_DIFF]
+  ,[OMD_CURRENT_RECORD_INDICATOR]
+  ,[OMD_DELETED_RECORD_INDICATOR]
+  ,[OMD_EXPIRY_DATETIME]
+  ,[OMD_RECORD_SOURCE_ID]
+  ,[OMD_SOURCE_ROW_ID]
+{{#each dataItemMappings}}
+  ,[{{sourceDataItems.0.name}}]
+{{/each}}
+)
+SELECT 
+   [OMD_INSERT_MODULE_INSTANCE_ID]
+  ,[OMD_FILE_LOCATION]
+  ,[OMD_EVENT_DATETIME]
+  ,[OMD_EFFECTIVE_DATETIME]
+  ,[OMD_HASH_DIFF]
+  ,[OMD_CURRENT_RECORD_INDICATOR]
+  ,[OMD_DELETED_RECORD_INDICATOR]
+  ,[OMD_EXPIRY_DATETIME]
+  ,[OMD_RECORD_SOURCE_ID]
+  ,[OMD_SOURCE_ROW_ID]
+{{#each dataItemMappings}}
+  ,[{{sourceDataItems.0.name}}]
+{{/each}}
+FROM PSA.{{StringReplace sourceDataObjects.0.name "STG" "PSA"}}
+
+-- Truncate the Satellite table.
+TRUNCATE TABLE [{{#each targetDataObject.dataObjectConnection.extensions}}{{#stringcompare key schema}}{{value}}{{/stringcompare}}{{/each}}].[{{targetDataObject.name}}];
+
+-- Rerun the Satellite loading procedure.
+EXEC [SP_{{targetDataObject.name}}] 0;
+{{/if}}{{/each}}

Virtual_EDW/Templates/templateCollection.json

@@ -38,7 +38,7 @@
     "TemplateOutputFileConvention": "{targetDataObject.name}.sql",
     "TemplateFilePath": "templateLinkSatelliteView.handlebars",
     "TemplateNotes": ""
-  },
+  },   
   {
     "TemplateName": "100 Data Vault Satellite View Template",
     "TemplateType": "Context",
@@ -358,7 +358,23 @@
     "TemplateOutputFileConvention": "{targetDataObject.name}_SelectView.sql",
     "TemplateFilePath": "templateLandingtoSilverFromView.handlebars",
     "TemplateNotes": "Azure Databricks insert into Staging Area. This template generates the select column list command from the view which is created from dataframe."
-  },
+  },   
+  {
+    "TemplateName": "500 Data Vault Satellite Reinitialisation Template",
+    "TemplateType": "Context",
+    "TemplateConnectionKey": "PsaConnectionInternalId",
+    "TemplateOutputFileConvention": "{targetDataObject.name}_reinitialise.sql",
+    "TemplateFilePath": "loadPatternSatelliteReinitialisation.handlebars",
+    "TemplateNotes": ""
+  },  
+  {
+    "TemplateName": "500 Data Vault Link-Satellite Reinitialisation Template",
+    "TemplateType": "NaturalBusinessRelationshipContext",
+    "TemplateConnectionKey": "PsaConnectionInternalId",
+    "TemplateOutputFileConvention": "{targetDataObject.name}_reinitialise.sql",
+    "TemplateFilePath": "loadPatternLinkSatelliteReinitialisation.handlebars",
+    "TemplateNotes": ""
+  },  
   {
     "TemplateName": "900 Unit Test - Hub Key Null Check",
     "TemplateType": "CoreBusinessConcept",