|
13 | 13 | ( {{#each dataObjectMappings}}{{#if @first}}
|
14 | 14 | SELECT
|
15 | 15 | HASHBYTES('MD5', {{#each businessKeys}} {{#unless @first}}{{!-- Create the Surrogate Key using the combined Business Keys --}}{{#each dataItemMappings}}ISNULL(RTRIM(CONVERT(NVARCHAR(100), [{{targetDataItem.name}}], 'N/A') + '#~!'{{/each}}
|
16 |
| -{{#each businessKeyComponentMapping}} ISNULL(RTRIM(CONVERT(NVARCHAR(100), {{targetDataItem.name}}{{../../@index}})), 'N/A') + '#~!'{{#unless @last}} +{{/unless}}{{/each}}{{#unless @last}} +{{/unless}}{{/unless}}{{/each}} |
| 16 | +{{#each businessKeyComponentMapping}} ISNULL(RTRIM(CONVERT(NVARCHAR(100), {{targetDataItem.name}}{{@../index }})), 'N/A') + '#~!'{{#unless @last}} +{{/unless}}{{/each}}{{#unless @last}} +{{/unless}}{{/unless}}{{/each}} |
17 | 17 | {{#each dataItemMappings}} + ISNULL(RTRIM(CONVERT(NVARCHAR(100), [{{targetDataItem.name}}])), 'N/A') + '#~!'{{/each}}{{#each businessKeys}} {{#if @first}} ) AS {{surrogateKey}},{{/if}}{{/each}}
|
18 | 18 | -1 AS {{../metadataConfiguration.etlProcessAttribute}}, {{!-- List out the ETL Framework attributes --}}
|
19 | 19 | MIN({{../metadataConfiguration.loadDateTimeAttribute}}) AS {{../metadataConfiguration.loadDateTimeAttribute}},
|
20 | 20 | {{../metadataConfiguration.recordSourceAttribute}},{{#each businessKeys}}{{#unless @first}} {{!-- List out the separate (Hub) business keys, by skipping the first generic relationship key. --}}
|
21 | 21 | {{#unless businessKeyClassification}}HASHBYTES('MD5',
|
22 | 22 | {{#each businessKeyComponentMapping}}
|
23 |
| - ISNULL(RTRIM(CONVERT(NVARCHAR(100), {{targetDataItem.name}}{{../../@index}})), 'N/A') + '#~!'{{#unless @last}} +{{/unless}}{{/each}} |
| 23 | + ISNULL(RTRIM(CONVERT(NVARCHAR(100), {{targetDataItem.name}}{{@../index }})), 'N/A') + '#~!'{{#unless @last}} +{{/unless}}{{/each}} |
24 | 24 | ) AS {{surrogateKey}},
|
25 |
| - {{/unless}}{{#if businessKeyClassification}}{{#each businessKeyComponentMapping}}{{targetDataItem.name}}{{../../@index}}{{/each}} AS {{surrogateKey}}, |
| 25 | + {{/unless}}{{#if businessKeyClassification}}{{#each businessKeyComponentMapping}}{{targetDataItem.name}}{{@../index }}{{/each}} AS {{surrogateKey}}, |
26 | 26 | {{/if}} {{/unless}} {{/each}}{{#each dataItemMappings}}
|
27 | 27 | [{{targetDataItem.name}}],{{/each}}
|
28 | 28 | ROW_NUMBER() OVER (PARTITION BY {{#each businessKeys}} {{#unless @first}} {{#each businessKeyComponentMapping}} {{!-- Create a row number to enable selection only the earliest row, ordered by date/time --}}
|
29 |
| - {{targetDataItem.name}}{{../../@index}}{{#unless @last}},{{/unless}}{{/each}}{{#unless @last}},{{/unless}}{{/unless}} {{/each}} |
| 29 | + {{targetDataItem.name}}{{@../index }}{{#unless @last}},{{/unless}}{{/each}}{{#unless @last}},{{/unless}}{{/unless}} {{/each}} |
30 | 30 | {{#each dataItemMappings}},[{{targetDataItem.name}}]{{/each}}
|
31 | 31 | ORDER BY
|
32 | 32 | MIN({{../metadataConfiguration.loadDateTimeAttribute}})
|
|
35 | 35 | ({{/if}}{{/each}}
|
36 | 36 | {{#each dataObjectMappings }}
|
37 | 37 | SELECT {{#each businessKeys}} {{#unless @first}} {{#each businessKeyComponentMapping}}
|
38 |
| - CAST({{sourceDataItems.0.name}} AS NVARCHAR(100)) AS {{targetDataItem.name}}{{../../@index}},{{/each}}{{/unless}}{{/each}}{{#each dataItemMappings}} |
| 38 | + CAST({{sourceDataItems.0.name}} AS NVARCHAR(100)) AS {{targetDataItem.name}}{{@../index }},{{/each}}{{/unless}}{{/each}}{{#each dataItemMappings}} |
39 | 39 | [{{sourceDataItems.0.name}}] AS [{{targetDataItem.name}}],{{/each}}
|
40 | 40 | {{../metadataConfiguration.recordSourceAttribute}},
|
41 | 41 | MIN({{../metadataConfiguration.loadDateTimeAttribute}}) AS {{../metadataConfiguration.loadDateTimeAttribute}}
|
42 |
| - FROM [{{sourceDataObjects.0.name}}] |
| 42 | + FROM [{{sourceDataObjects.0.dataObjectConnection.extensions.1.value}}].[{{sourceDataObjects.0.name}}] |
43 | 43 | WHERE {{#each businessKeys}} {{#unless @first}} {{#each businessKeyComponentMapping}}
|
44 | 44 | {{sourceDataItems.0.name}} IS NOT NULL{{#unless @last}} AND{{/unless}}{{/each}}{{#unless @last}} AND{{/unless}}{{/unless}} {{/each}}
|
45 | 45 | {{#each dataItemMappings}}
|
|
51 | 51 | {{../metadataConfiguration.recordSourceAttribute}}{{#unless @last}}UNION{{/unless}}
|
52 | 52 | ) LINK_selection
|
53 | 53 | GROUP BY {{#each businessKeys}} {{#unless @first}} {{#each businessKeyComponentMapping}}
|
54 |
| - {{targetDataItem.name}}{{../../@index}}{{#unless @last}},{{/unless}}{{/each}},{{/unless}}{{/each}} |
| 54 | + {{targetDataItem.name}}{{@../index }}{{#unless @last}},{{/unless}}{{/each}},{{/unless}}{{/each}} |
55 | 55 | {{#each dataItemMappings}}
|
56 | 56 | [{{targetDataItem.name}}],{{/each}}
|
57 | 57 | {{../metadataConfiguration.recordSourceAttribute}} {{/each}}
|
|
0 commit comments