Database Reference
In-Depth Information
<Dataflow Name="Load <#=table.Name#>">
<Transformations>
<OleDbSource Name="<#=table.Name#> Source"
ConnectionName="SSISIncrementalLoad_Source">
<DirectInput>SELECT <#=table.GetColumnList()#> FROM
<#=table.SchemaQualifiedName#></DirectInput>
</OleDbSource>
<Lookup Name="Correlate"
OleDbConnectionName="SSISIncrementalLoad_Stage"
NoMatchBehavior="RedirectRowsToNoMatchOutput">
<DirectInput>SELECT <#=table.GetColumnList()#> FROM
dbo.<#=table.Name#></DirectInput>
<Inputs>
<# foreach (var keyColumn in
table.Keys[0].Columns) { #>
<Column SourceColumn="<#=keyColumn.Column#>"
TargetColumn="<#=keyColumn.Column#>" />
<# } #>
</Inputs>
<Outputs>
<# foreach (var col in table.Columns) { #>
<Column SourceColumn="<#=col#>"
TargetColumn="Dest_<#=col#>" />
<# } #>
</Outputs>
</Lookup>
<ConditionalSplit Name="Filter">
<OutputPaths>
<OutputPath Name="Changed Rows">
<# string exp ="";
foreach (var colex in table.Columns) { exp
+= "(" + colex + " != Dest_"
+ colex + ") || "; } #>
<Expression><#=exp.Substring(0, exp.Length
- 4)#></Expression>
</OutputPath>
</OutputPaths>
</ConditionalSplit>
Search WWH ::




Custom Search