Skip to content

Commit 18e9246

Browse files
author
Roelant Vos
committed
Fixed issues related to establishment of SQL connection.
1 parent d77c94e commit 18e9246

6 files changed

Lines changed: 217 additions & 51 deletions

‎Virtual_EDW/CustomTabPage.cs‎

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -627,26 +627,24 @@ private void GenerateFromPattern()
627627

628628
if (localConnection != null)
629629
{
630-
var conn = new SqlConnection {ConnectionString = localConnection.CreateSqlServerConnectionString(false)};
631-
632630
try
633631
{
634-
VdwUtility.CreateVdwSchema(conn);
632+
VdwUtility.CreateVdwSchema(new SqlConnection { ConnectionString = localConnection.CreateSqlServerConnectionString(false) });
635633
}
636634
catch
637635
{
638-
var errorMessage = $"There was an issue creating the schema '{FormBase.VdwConfigurationSettings.VdwSchema}' in database '{conn.Database}'.";
636+
var errorMessage = $"There was an issue creating the schema '{FormBase.VdwConfigurationSettings.VdwSchema}' against connection '{localConnection.ConnectionKey}'.";
639637
RaiseOnChangeMainText(errorMessage);
640638
FormBase.VdwConfigurationSettings.VdwEventLog.Add(Event.CreateNewEvent(EventTypes.Error, errorMessage));
641639
}
642640

643641
try
644642
{
645-
VdwUtility.ExecuteOutputInDatabase(conn, result);
643+
VdwUtility.ExecuteInDatabase(new SqlConnection { ConnectionString = localConnection.CreateSqlServerConnectionString(false) }, result);
646644
}
647645
catch
648646
{
649-
var errorMessage = $"There was an issue executing the query '{result}' in database '{conn.Database}'.";
647+
var errorMessage = $"There was an issue executing the query '{result}' against connection '{localConnection.ConnectionKey}'.";
650648
RaiseOnChangeMainText(errorMessage);
651649
FormBase.VdwConfigurationSettings.VdwEventLog.Add(Event.CreateNewEvent(EventTypes.Error, errorMessage));
652650
}

‎Virtual_EDW/LoadPatterns/loadPatternHubView.Handlebars‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
11
--
2-
-- Hub View definition for {{generationSpecificMetadata.selectedDataObject}}
2+
-- Hub View definition for {{generationSpecificMetadata.selectedDataObjec.namet}}
33
-- Generated at {{generationSpecificMetadata.generationDateTime}}
44
--
55

6-
IF EXISTS (SELECT * FROM sys.objects WHERE object_id = OBJECT_ID(N'[{{metadataConfiguration.vdwSchemaName}}].[{{generationSpecificMetadata.selectedDataObject}}]') AND type in (N'V'))
7-
DROP VIEW [{{metadataConfiguration.vdwSchemaName}}].[{{generationSpecificMetadata.selectedDataObject}}]
6+
IF EXISTS (SELECT * FROM sys.objects WHERE object_id = OBJECT_ID(N'[{{metadataConfiguration.vdwSchemaName}}].[{{generationSpecificMetadata.selectedDataObject.name}}]') AND type in (N'V'))
7+
DROP VIEW [{{metadataConfiguration.vdwSchemaName}}].[{{generationSpecificMetadata.selectedDataObject.name}}]
88
GO
99

10-
CREATE VIEW [{{metadataConfiguration.vdwSchemaName}}].[{{generationSpecificMetadata.selectedDataObject}}] AS
10+
CREATE VIEW [{{metadataConfiguration.vdwSchemaName}}].[{{generationSpecificMetadata.selectedDataObject.name}}] AS
1111
SELECT hub.*
1212
FROM (
1313
{{#each dataObjectMappings}}{{#if @first}}

‎Virtual_EDW/LoadPatterns/loadPatternHubView.handlebarsBackup_20221213105949‎

Lines changed: 60 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,60 @@
1+
--
2+
-- Hub View definition for {{generationSpecificMetadata.selectedDataObject}}
3+
-- Generated at {{generationSpecificMetadata.generationDateTime}}
4+
--
5+
6+
IF EXISTS (SELECT * FROM sys.objects WHERE object_id = OBJECT_ID(N'[{{metadataConfiguration.vdwSchemaName}}].[{{generationSpecificMetadata.selectedDataObject}}]') AND type in (N'V'))
7+
DROP VIEW [{{metadataConfiguration.vdwSchemaName}}].[{{generationSpecificMetadata.selectedDataObject}}]
8+
GO
9+
10+
CREATE VIEW [{{metadataConfiguration.vdwSchemaName}}].[{{generationSpecificMetadata.selectedDataObject}}] AS
11+
SELECT hub.*
12+
FROM (
13+
{{#each dataObjectMappings}}{{#if @first}}
14+
SELECT
15+
HASHBYTES('MD5', {{#each businessKeys}} {{#if @first}} {{!-- Create the Surrogate Key using the Business Key and components --}}
16+
{{#each businessKeyComponentMapping}}
17+
ISNULL(RTRIM(CONVERT(NVARCHAR(100), {{targetDataItem.name}})), 'N/A') + '#~!'{{#unless @last}} +{{/unless}}
18+
{{/each}}
19+
) AS {{surrogateKey}},{{/if}}{{/each}}
20+
-1 AS {{../metadataConfiguration.etlProcessAttribute}}, {{!-- List out the ETL Framework attributes --}}
21+
MIN({{../metadataConfiguration.loadDateTimeAttribute}}) AS {{../metadataConfiguration.loadDateTimeAttribute}},
22+
{{../metadataConfiguration.recordSourceAttribute}},{{#each businessKeys}} {{!-- The Hub business key --}}
23+
{{#each businessKeyComponentMapping}}
24+
{{targetDataItem.name}},{{/each}}{{/each}}
25+
ROW_NUMBER() OVER (PARTITION BY {{#each businessKeys}}{{#each businessKeyComponentMapping}} {{!-- Create a row number to enable selection only the earliest row, ordered by date/time --}}
26+
{{targetDataItem.name}}{{#unless @last}},{{/unless}}{{/each}}
27+
{{/each}}
28+
ORDER BY
29+
MIN({{../metadataConfiguration.loadDateTimeAttribute}})
30+
) AS ROW_NR
31+
FROM
32+
( {{/if}}{{/each}}
33+
{{#each dataObjectMappings }}
34+
SELECT {{#each businessKeys}}{{#each businessKeyComponentMapping}}
35+
CAST({{sourceDataItems.0.name}} AS NVARCHAR(100)) AS {{targetDataItem.name}},{{/each}}{{/each}}
36+
{{../metadataConfiguration.recordSourceAttribute}},
37+
MIN({{../metadataConfiguration.loadDateTimeAttribute}}) AS {{../metadataConfiguration.loadDateTimeAttribute}}
38+
FROM [{{sourceDataObjects.0.dataObjectConnection.extensions.1.value}}].[{{sourceDataObjects.0.name}}]
39+
WHERE {{#each businessKeys}}{{#each businessKeyComponentMapping}}
40+
{{sourceDataItems.0.name}} IS NOT NULL{{#unless @last}} AND{{/unless}}{{/each}}{{/each}}
41+
{{#if filterCriterion}}AND {{filterCriterion}}{{/if}}
42+
GROUP BY
43+
{{#each businessKeys}}{{#each businessKeyComponentMapping}}{{#each sourceDataItems}}{{#stringcompare isHardCodedValue "True"}}{{else}}{{name}},{{/stringcompare}}{{/each}}{{/each}}{{/each}}
44+
{{../metadataConfiguration.recordSourceAttribute}}
45+
{{#unless @last}}UNION{{/unless}}
46+
{{/each}}
47+
) HUB_selection {{#each dataObjectMappings}}{{#if @first}}
48+
GROUP BY {{#each businessKeys}}{{#each businessKeyComponentMapping}}
49+
{{targetDataItem.name}},{{/each}}{{/each}}
50+
{{../metadataConfiguration.recordSourceAttribute}} {{/if}}{{/each}}
51+
) hub
52+
WHERE ROW_NR = 1
53+
UNION
54+
SELECT
55+
0x00000000000000000000000000000000,
56+
- 1,
57+
'1900-01-01',
58+
'Data Warehouse',{{#each dataObjectMappings}}{{#if @first}}{{#each businessKeys}}{{#each businessKeyComponentMapping}}
59+
'Unknown',{{/each}}{{/each}}{{/if}}{{/each}}
60+
1 AS ROW_NR

‎Virtual_EDW/LoadPatterns/loadPatternHubView.handlebarsBackup_20221213110002‎

Lines changed: 60 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,60 @@
1+
--
2+
-- Hub View definition for {{generationSpecificMetadata.selectedDataObjec.namet}}
3+
-- Generated at {{generationSpecificMetadata.generationDateTime}}
4+
--
5+
6+
IF EXISTS (SELECT * FROM sys.objects WHERE object_id = OBJECT_ID(N'[{{metadataConfiguration.vdwSchemaName}}].[{{generationSpecificMetadata.selectedDataObject.name}}]') AND type in (N'V'))
7+
DROP VIEW [{{metadataConfiguration.vdwSchemaName}}].[{{generationSpecificMetadata.selectedDataObject.name}}]
8+
GO
9+
10+
CREATE VIEW [{{metadataConfiguration.vdwSchemaName}}].[{{generationSpecificMetadata.selectedDataObjec.namet}}] AS
11+
SELECT hub.*
12+
FROM (
13+
{{#each dataObjectMappings}}{{#if @first}}
14+
SELECT
15+
HASHBYTES('MD5', {{#each businessKeys}} {{#if @first}} {{!-- Create the Surrogate Key using the Business Key and components --}}
16+
{{#each businessKeyComponentMapping}}
17+
ISNULL(RTRIM(CONVERT(NVARCHAR(100), {{targetDataItem.name}})), 'N/A') + '#~!'{{#unless @last}} +{{/unless}}
18+
{{/each}}
19+
) AS {{surrogateKey}},{{/if}}{{/each}}
20+
-1 AS {{../metadataConfiguration.etlProcessAttribute}}, {{!-- List out the ETL Framework attributes --}}
21+
MIN({{../metadataConfiguration.loadDateTimeAttribute}}) AS {{../metadataConfiguration.loadDateTimeAttribute}},
22+
{{../metadataConfiguration.recordSourceAttribute}},{{#each businessKeys}} {{!-- The Hub business key --}}
23+
{{#each businessKeyComponentMapping}}
24+
{{targetDataItem.name}},{{/each}}{{/each}}
25+
ROW_NUMBER() OVER (PARTITION BY {{#each businessKeys}}{{#each businessKeyComponentMapping}} {{!-- Create a row number to enable selection only the earliest row, ordered by date/time --}}
26+
{{targetDataItem.name}}{{#unless @last}},{{/unless}}{{/each}}
27+
{{/each}}
28+
ORDER BY
29+
MIN({{../metadataConfiguration.loadDateTimeAttribute}})
30+
) AS ROW_NR
31+
FROM
32+
( {{/if}}{{/each}}
33+
{{#each dataObjectMappings }}
34+
SELECT {{#each businessKeys}}{{#each businessKeyComponentMapping}}
35+
CAST({{sourceDataItems.0.name}} AS NVARCHAR(100)) AS {{targetDataItem.name}},{{/each}}{{/each}}
36+
{{../metadataConfiguration.recordSourceAttribute}},
37+
MIN({{../metadataConfiguration.loadDateTimeAttribute}}) AS {{../metadataConfiguration.loadDateTimeAttribute}}
38+
FROM [{{sourceDataObjects.0.dataObjectConnection.extensions.1.value}}].[{{sourceDataObjects.0.name}}]
39+
WHERE {{#each businessKeys}}{{#each businessKeyComponentMapping}}
40+
{{sourceDataItems.0.name}} IS NOT NULL{{#unless @last}} AND{{/unless}}{{/each}}{{/each}}
41+
{{#if filterCriterion}}AND {{filterCriterion}}{{/if}}
42+
GROUP BY
43+
{{#each businessKeys}}{{#each businessKeyComponentMapping}}{{#each sourceDataItems}}{{#stringcompare isHardCodedValue "True"}}{{else}}{{name}},{{/stringcompare}}{{/each}}{{/each}}{{/each}}
44+
{{../metadataConfiguration.recordSourceAttribute}}
45+
{{#unless @last}}UNION{{/unless}}
46+
{{/each}}
47+
) HUB_selection {{#each dataObjectMappings}}{{#if @first}}
48+
GROUP BY {{#each businessKeys}}{{#each businessKeyComponentMapping}}
49+
{{targetDataItem.name}},{{/each}}{{/each}}
50+
{{../metadataConfiguration.recordSourceAttribute}} {{/if}}{{/each}}
51+
) hub
52+
WHERE ROW_NR = 1
53+
UNION
54+
SELECT
55+
0x00000000000000000000000000000000,
56+
- 1,
57+
'1900-01-01',
58+
'Data Warehouse',{{#each dataObjectMappings}}{{#if @first}}{{#each businessKeys}}{{#each businessKeyComponentMapping}}
59+
'Unknown',{{/each}}{{/each}}{{/if}}{{/each}}
60+
1 AS ROW_NR

‎Virtual_EDW/LoadPatterns/loadPatternHubView.handlebarsBackup_20221213110017‎

Lines changed: 60 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,60 @@
1+
--
2+
-- Hub View definition for {{generationSpecificMetadata.selectedDataObjec.namet}}
3+
-- Generated at {{generationSpecificMetadata.generationDateTime}}
4+
--
5+
6+
IF EXISTS (SELECT * FROM sys.objects WHERE object_id = OBJECT_ID(N'[{{metadataConfiguration.vdwSchemaName}}].[{{generationSpecificMetadata.selectedDataObject.name}}]') AND type in (N'V'))
7+
DROP VIEW [{{metadataConfiguration.vdwSchemaName}}].[{{generationSpecificMetadata.selectedDataObject.name}}]
8+
GO
9+
10+
CREATE VIEW [{{metadataConfiguration.vdwSchemaName}}].[{{generationSpecificMetadata.selectedDataObjec.name}}] AS
11+
SELECT hub.*
12+
FROM (
13+
{{#each dataObjectMappings}}{{#if @first}}
14+
SELECT
15+
HASHBYTES('MD5', {{#each businessKeys}} {{#if @first}} {{!-- Create the Surrogate Key using the Business Key and components --}}
16+
{{#each businessKeyComponentMapping}}
17+
ISNULL(RTRIM(CONVERT(NVARCHAR(100), {{targetDataItem.name}})), 'N/A') + '#~!'{{#unless @last}} +{{/unless}}
18+
{{/each}}
19+
) AS {{surrogateKey}},{{/if}}{{/each}}
20+
-1 AS {{../metadataConfiguration.etlProcessAttribute}}, {{!-- List out the ETL Framework attributes --}}
21+
MIN({{../metadataConfiguration.loadDateTimeAttribute}}) AS {{../metadataConfiguration.loadDateTimeAttribute}},
22+
{{../metadataConfiguration.recordSourceAttribute}},{{#each businessKeys}} {{!-- The Hub business key --}}
23+
{{#each businessKeyComponentMapping}}
24+
{{targetDataItem.name}},{{/each}}{{/each}}
25+
ROW_NUMBER() OVER (PARTITION BY {{#each businessKeys}}{{#each businessKeyComponentMapping}} {{!-- Create a row number to enable selection only the earliest row, ordered by date/time --}}
26+
{{targetDataItem.name}}{{#unless @last}},{{/unless}}{{/each}}
27+
{{/each}}
28+
ORDER BY
29+
MIN({{../metadataConfiguration.loadDateTimeAttribute}})
30+
) AS ROW_NR
31+
FROM
32+
( {{/if}}{{/each}}
33+
{{#each dataObjectMappings }}
34+
SELECT {{#each businessKeys}}{{#each businessKeyComponentMapping}}
35+
CAST({{sourceDataItems.0.name}} AS NVARCHAR(100)) AS {{targetDataItem.name}},{{/each}}{{/each}}
36+
{{../metadataConfiguration.recordSourceAttribute}},
37+
MIN({{../metadataConfiguration.loadDateTimeAttribute}}) AS {{../metadataConfiguration.loadDateTimeAttribute}}
38+
FROM [{{sourceDataObjects.0.dataObjectConnection.extensions.1.value}}].[{{sourceDataObjects.0.name}}]
39+
WHERE {{#each businessKeys}}{{#each businessKeyComponentMapping}}
40+
{{sourceDataItems.0.name}} IS NOT NULL{{#unless @last}} AND{{/unless}}{{/each}}{{/each}}
41+
{{#if filterCriterion}}AND {{filterCriterion}}{{/if}}
42+
GROUP BY
43+
{{#each businessKeys}}{{#each businessKeyComponentMapping}}{{#each sourceDataItems}}{{#stringcompare isHardCodedValue "True"}}{{else}}{{name}},{{/stringcompare}}{{/each}}{{/each}}{{/each}}
44+
{{../metadataConfiguration.recordSourceAttribute}}
45+
{{#unless @last}}UNION{{/unless}}
46+
{{/each}}
47+
) HUB_selection {{#each dataObjectMappings}}{{#if @first}}
48+
GROUP BY {{#each businessKeys}}{{#each businessKeyComponentMapping}}
49+
{{targetDataItem.name}},{{/each}}{{/each}}
50+
{{../metadataConfiguration.recordSourceAttribute}} {{/if}}{{/each}}
51+
) hub
52+
WHERE ROW_NR = 1
53+
UNION
54+
SELECT
55+
0x00000000000000000000000000000000,
56+
- 1,
57+
'1900-01-01',
58+
'Data Warehouse',{{#each dataObjectMappings}}{{#if @first}}{{#each businessKeys}}{{#each businessKeyComponentMapping}}
59+
'Unknown',{{/each}}{{/each}}{{/if}}{{/each}}
60+
1 AS ROW_NR

0 commit comments

Comments
 (0)