|
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