Skip to content

Commit c8eb328

Browse files
RoelantVosRoelantVos
committed
Added Frequency Code
1 parent 4b7b825 commit c8eb328

File tree

2 files changed

+15
-17
lines changed

2 files changed

+15
-17
lines changed

‎DIRECT_Management/DIRECT_Management.csproj‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -137,8 +137,6 @@
137137
<DesignTime>True</DesignTime>
138138
<DependentUpon>Resources.resx</DependentUpon>
139139
</Compile>
140-
<None Include="DIRECT_Management_1_TemporaryKey.pfx" />
141-
<None Include="DIRECT_Management_TemporaryKey.pfx" />
142140
<None Include="packages.config" />
143141
</ItemGroup>
144142
<ItemGroup>

‎DIRECT_Management/Form_Main.cs‎

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ private void ButtonGenerateOmdMetadata(object sender, EventArgs e)
6868
var metadataDatabaseName = textBoxGenerationMetadataDatabaseName;
6969

7070
insertIntoStatement.AppendLine("/* Run the following in ETL control framework database */");
71-
insertIntoStatement.AppendLine("USE ["+metadataDatabaseName+"];");
71+
insertIntoStatement.AppendLine("USE ["+textBoxDirectDatabase.Text+"];");
7272
insertIntoStatement.AppendLine();
7373

7474
// Add the initial delete statements
@@ -187,10 +187,10 @@ private void AddModuleContent(StringBuilder insertIntoStatement)
187187
{
188188
insertIntoStatement.AppendLine("IF NOT EXISTS (SELECT MODULE_CODE FROM OMD_MODULE WHERE MODULE_CODE='m_100_" + stagingTableName + "')");
189189
}
190-
insertIntoStatement.AppendLine("INSERT INTO [OMD_MODULE] ([AREA_CODE],[MODULE_CODE],[MODULE_DESCRIPTION],[MODULE_TYPE_CODE])");
190+
insertIntoStatement.AppendLine("INSERT INTO [OMD_MODULE] ([AREA_CODE], [MODULE_CODE], [MODULE_DESCRIPTION], [MODULE_TYPE_CODE], [FREQUENCY_CODE])");
191191
insertIntoStatement.AppendLine("VALUES ('STG','m_100_" + stagingTableName +
192192
"','Source to Staging ETL for " +
193-
stagingTableName + "', 'SSIS')");
193+
stagingTableName + "', 'SSIS', 'Queue')");
194194
}
195195
}
196196
else
@@ -230,10 +230,10 @@ private void AddModuleContent(StringBuilder insertIntoStatement)
230230
insertIntoStatement.AppendLine("IF NOT EXISTS (SELECT MODULE_CODE FROM OMD_MODULE WHERE MODULE_CODE='m_150_H" + stagingTableName + "')");
231231
}
232232
insertIntoStatement.AppendLine(
233-
"INSERT INTO [OMD_MODULE] ([AREA_CODE],[MODULE_CODE],[MODULE_DESCRIPTION],[MODULE_TYPE_CODE])");
233+
"INSERT INTO [OMD_MODULE] ([AREA_CODE],[MODULE_CODE],[MODULE_DESCRIPTION],[MODULE_TYPE_CODE],[FREQUENCY_CODE])");
234234
insertIntoStatement.AppendLine("VALUES ('HSTG','m_150_H" + stagingTableName +
235235
"','Staging to History Staging ETL for H" + stagingTableName +
236-
"', 'SSIS')");
236+
"', 'SSIS', 'Queue')");
237237
}
238238
}
239239
else
@@ -352,10 +352,10 @@ private void AddModuleContent(StringBuilder insertIntoStatement)
352352
insertIntoStatement.AppendLine("IF NOT EXISTS (SELECT MODULE_CODE FROM OMD_MODULE WHERE MODULE_CODE = 'm_200_" + intTable + "_With_Driving_Key')");
353353
}
354354
insertIntoStatement.AppendLine(
355-
"INSERT INTO [OMD_MODULE] ([AREA_CODE],[MODULE_CODE],[MODULE_DESCRIPTION],[MODULE_TYPE_CODE])");
355+
"INSERT INTO [OMD_MODULE] ([AREA_CODE],[MODULE_CODE],[MODULE_DESCRIPTION],[MODULE_TYPE_CODE],[FREQUENCY_CODE])");
356356
insertIntoStatement.AppendLine("VALUES ('INT','m_200_" + intTable +
357357
"_With_Driving_Key','Driving-key based Link Satellite table sourced from " +
358-
targetTableName + "', 'SSIS')");
358+
targetTableName + "', 'SSIS', 'Queue')");
359359
}
360360
else //Normal LSATs
361361
{
@@ -366,10 +366,10 @@ private void AddModuleContent(StringBuilder insertIntoStatement)
366366
"')");
367367
}
368368
insertIntoStatement.AppendLine(
369-
"INSERT INTO [OMD_MODULE] ([AREA_CODE],[MODULE_CODE],[MODULE_DESCRIPTION],[MODULE_TYPE_CODE])");
369+
"INSERT INTO [OMD_MODULE] ([AREA_CODE],[MODULE_CODE],[MODULE_DESCRIPTION],[MODULE_TYPE_CODE],[FREQUENCY_CODE])");
370370
insertIntoStatement.AppendLine("VALUES ('INT','m_200_" + intTable + "_" + targetTableName +
371371
"','Driving-key based Link Satellite table sourced from " +
372-
targetTableName + "', 'SSIS')");
372+
targetTableName + "', 'SSIS', 'Queue')");
373373
}
374374
}
375375
else
@@ -379,9 +379,9 @@ private void AddModuleContent(StringBuilder insertIntoStatement)
379379
insertIntoStatement.AppendLine("IF NOT EXISTS (SELECT MODULE_CODE FROM OMD_MODULE WHERE MODULE_CODE='m_200_" + intTable + "_" +
380380
targetTableName + "')");
381381
}
382-
insertIntoStatement.AppendLine("INSERT INTO [OMD_MODULE] ([AREA_CODE],[MODULE_CODE],[MODULE_DESCRIPTION],[MODULE_TYPE_CODE])");
382+
insertIntoStatement.AppendLine("INSERT INTO [OMD_MODULE] ([AREA_CODE],[MODULE_CODE],[MODULE_DESCRIPTION],[MODULE_TYPE_CODE],[FREQUENCY_CODE])");
383383
insertIntoStatement.AppendLine("VALUES ('INT','m_200_" + intTable + "_" + targetTableName +
384-
"','Integration Layer ETL sourced from " + targetTableName + "', 'SSIS')");
384+
"','Integration Layer ETL sourced from " + targetTableName + "', 'SSIS','Queue')");
385385
}
386386
insertIntoStatement.AppendLine();
387387
}
@@ -444,8 +444,8 @@ private void AddModuleContent(StringBuilder insertIntoStatement)
444444
insertIntoStatement.AppendLine("IF NOT EXISTS (SELECT MODULE_CODE FROM OMD_MODULE WHERE MODULE_CODE='m_200_" + intTableName + "_END_DATES')");
445445
}
446446

447-
insertIntoStatement.AppendLine("INSERT INTO [OMD_MODULE] ([AREA_CODE],[MODULE_CODE],[MODULE_DESCRIPTION],[MODULE_TYPE_CODE])");
448-
insertIntoStatement.AppendLine("VALUES ('INT','m_200_" + intTableName + "_END_DATES','End-dating logic for the table " + intTableName + "', 'SSIS')");
447+
insertIntoStatement.AppendLine("INSERT INTO [OMD_MODULE] ([AREA_CODE],[MODULE_CODE],[MODULE_DESCRIPTION],[MODULE_TYPE_CODE],[FREQUENCY_CODE])");
448+
insertIntoStatement.AppendLine("VALUES ('INT','m_200_" + intTableName + "_END_DATES','End-dating logic for the table " + intTableName + "', 'SSIS', 'Queue')");
449449
insertIntoStatement.AppendLine();
450450
}
451451
}
@@ -522,7 +522,7 @@ private void AddBatchContent(StringBuilder insertIntoStatement)
522522
}
523523

524524
insertIntoStatement.AppendLine("INSERT INTO [OMD_BATCH] ([FREQUENCY_CODE],[BATCH_CODE],[BATCH_DESCRIPTION])");
525-
insertIntoStatement.AppendLine("VALUES ('Continuous','b_EDW_STG_INT_" + stagingBatchName + "','Source to Integration Area processing for " + stagingBatchName + "')");
525+
insertIntoStatement.AppendLine("VALUES ('Queue','b_EDW_STG_INT_" + stagingBatchName + "','Source to Integration Area processing for " + stagingBatchName + "')");
526526
insertIntoStatement.AppendLine();
527527
}
528528
}
@@ -1399,7 +1399,7 @@ private void InitializePath()
13991399
initialConfigurationFile.AppendLine(@"connectionStringGenerationMetadata|Provider=SQLNCLI11;Server=.;Initial Catalog=EDW_900_Metadata;User ID=sa; Password=K3kobus2");
14001400
initialConfigurationFile.AppendLine(@"GenerationMetaDataDatabaseName|EDW_900_Metadata");
14011401
initialConfigurationFile.AppendLine(@"connectionStringDirect|Provider=SQLNCLI11;Server=.;Initial Catalog=EDW_900_Metadata; User ID=sa; Password=K3kobus2");
1402-
initialConfigurationFile.AppendLine(@"DirectDatabaseName|EDW_900_Metadata");
1402+
initialConfigurationFile.AppendLine(@"DirectDatabaseName|EDW_900_OMD_Framework");
14031403
initialConfigurationFile.AppendLine(@"connectionStringSTG|Provider=SQLNCLI11;Server=.;Initial Catalog=EDW_100_Staging_Area;User ID=sa; Password=K3kobus2");
14041404
initialConfigurationFile.AppendLine(@"STGDatabaseName|EDW_100_Staging_Area");
14051405
initialConfigurationFile.AppendLine(@"connectionStringPSA|Provider=SQLNCLI11;Server=.;Initial Catalog=EDW_150_Persistent_Staging_Area;User ID=sa; Password=K3kobus2");

0 commit comments

Comments
 (0)