Damit ist die Quarant\u00e4ne noch nicht ganz fertig. Das UNION ALL f\u00fchrt dann zu einem SQL-Server-Ziel. Dort werden die Spalten aus der Union All in die Datenbank geschrieben. Diesen Teil habe ich, da er nur einmal (je Data Flow) zu erstellen ist, aber manuell gel\u00f6st. Hier ist der Aufwand geringer als eine automatisierte L\u00f6sung zu implementieren.<\/p>\n
Fehlerbehandlung auf Redirect Row umstellen<\/h1>\n
Interessanter Weise gibt es unterschiedliche Arten von Fehlerbehandlungen in SSIS. Bei manchen Komponenten wird die Fehlerbehandlung einzeln f\u00fcr jede Spalte (z.B. derived column) definiert, in anderen nur global f\u00fcr die gesamte Komponente, in manchen auch f\u00fcr beides.<\/p>\n
Der Lookup hat beide Fehlerbehandlungen:<\/p>\n
Hier ein Beispiel f\u00fcr die Fehlerbehandlung einer Derived Column:<\/p>\n Im Advanced Editor sieht das dann so aus:<\/p>\n Und die globale Komponenten-Fehlerbehandlung wird nicht verwendet:<\/p>\n Wichtig ist zu bemerken, dass diese Einstellungen nat\u00fcrlich nicht in dem Error Output, sondern in dem normalen (bzw. allen normalen) Output(s) und Input(s) gemacht werden m\u00fcssen.<\/p>\n Deswegen durchl\u00e4uft der Code alle Inputs und alle Spalten aller Inputs und das gleiche f\u00fcr die Outputs:<\/p>\n For Each outp As IDTSOutput100 In comp.OutputCollection Und das gleiche f\u00fcr die Inputs:<\/p>\n For Each inp As IDTSInput100 In comp.InputCollection . . .<\/span><\/p><\/blockquote>\n Am besten merkt man sich noch in einer boolschen Variablen, ob ein Redirect Row eingestellt wurde. Nur dann darf man n\u00e4mlich den n\u00e4chsten Schritt machen.<\/p>\n Dies ist wichtig, da die Fehlermeldungen bei der SSIS-API-Entwicklung meist kryptisch sind, da .NET-Wrapper von der API verwendet werden. \u00a0<\/span><\/p>\n Wir erstellen sie so:<\/p>\n ’neue Derived Column Man beachte das Initiate()<\/em>. Dadurch wird die derived Column wie im Visual Studio auch instantiiert. Das hei\u00dft, man kann auf alle Voreinstellungen zugreifen.<\/p>\n Hierzu legt man einen neuen Pfad an, der den Error Output (den wir im letzten Blog gefunden und gemerkt hatten) mit der Derived Column verbindet:<\/p>\n Dim path As IDTSPath100 = pipe.PathCollection.New() Da man das immer wieder braucht, habe ich dazu eine Methode erstellt.<\/p>\n Diese erh\u00e4lt als Parameter:<\/p>\n Hier der Code:<\/p>\n Private Sub addNewColumn2DerivedComponent(derivedColumnComponent As IDTSComponentMetaData100, name As String, dataType As Wrapper.DataType, dataTypeLaenge As Integer, expression As String, Optional lineageIDKeyColumn As Integer = 0) Dim neueSpalteProp As IDTSCustomProperty100 = neueSpalte.CustomPropertyCollection.New() End Sub<\/p><\/blockquote>\n Hier einige Erkl\u00e4rungen dazu:<\/p>\n Und jetzt die Geschichte mit der lineage-ID, wie versprochen:<\/p>\n Man kann auch in den Formeln (expression) auf bestehende Spalten zugreifen. Das funktioniert \u00fcber die lineage-Id der Spalte, also beispielsweise so \u201c(DT_WSTR,50)#17\u201d. Die \u201cfriendly expression\u201d muss nicht unbedingt angegeben werden.<\/p>\n Die lineage-ID kann man sich ermitteln, indem man alle Spalten des Inputs durchl\u00e4uft und den Namen der Spalte kennt. Allerdings kommt dabei der Wrapper f\u00fcr managed code zum Einsatz, den ich vorher bereits angedeutet habe. Wir ben\u00f6tigen n\u00e4mlich hier Designer-Funktionalit\u00e4t, wie sie im Visual Studio auch vorhanden ist. Deswegen sieht der Code etwas h\u00e4sslich aus:<\/p>\n Private Function findeSpalte(comp As IDTSComponentMetaData100, nameSpalte As String, ByRef nameSpalteGefunden As String) As Integer nameSpalteGefunden = „“<\/p>\n For Each virtualCol As IDTSVirtualInputColumn100 In virtualInpCols Return 0 Diese Funktion stellt auch den UsageType der Spalte auf Readonly. Dies erscheint zun\u00e4chst unn\u00f6tig, ohne dies funktioniert es\u00a0 aber nicht. Dies spiegelt wider, was der Advanced Editor f\u00fcr die Spalten anzeigt, die in den Formeln verwendet werden:<\/p>\n In diesem Beispiel wurde die EinrichtungID-Spalte in einer Formel verwendet.<\/p>\n So habe ich die Prim\u00e4rschl\u00fcssel, die ich in der Quarant\u00e4ne-Tabelle mit protokollieren wollte, gefunden.<\/p>\n Das funktioniert genauso wie der Pfad zur derived column, muss also nicht im Detail beschrieben werden.<\/p>\n Damit sind wir nun fast fertig. Es sind lediglich ein paar Besonderheiten zu beachten \u2013 s. n\u00e4chster Blog-Eintrag.<\/p>\n","protected":false},"excerpt":{"rendered":" Nachdem wir im letzten Blog-Kapitel alle Komponenten eines Data Flows durchlaufen konnten und dazu erkennen konnten, ob eine Fehlerbehandlung m\u00f6glich und noch nicht vorhanden ist, m\u00fcssen wir nun die Fehlerbehandlung in diesen F\u00e4llen einbauen. Die Fehlerbehandlung soll wie folgt funktionieren: Fehlerbehandlung auf Redirect Row einstellen Den Error Output in eine neu zu erstellende Derived Column … Quarantäne-Teil 3: Anlegen der zusätzlichen Komponenten<\/span> weiterlesen ![\"image\"](\"https:\/\/www.csopro.de\/biblog\/wp-content\/uploads\/2015\/06\/image1.png\" "\\"image\\"")
<\/a><\/p>\n<\/a><\/p>\n<\/a><\/p>\n<\/a><\/p>\n
\n‚ globale Fehlerhandlung
\nIf outp.ErrorRowDisposition = DTSRowDisposition.RD_FailComponent Then
\noutp.ErrorRowDisposition = DTSRowDisposition.RD_RedirectRow
\nEnd If
\nIf outp.TruncationRowDisposition = DTSRowDisposition.RD_FailComponent Then
\noutp.TruncationRowDisposition = DTSRowDisposition.RD_RedirectRow
\nEnd If
\n‚Fehlerbehandlung je Spalte
\nFor Each col As IDTSOutputColumn100 In outp.OutputColumnCollection
\nIf col.ErrorRowDisposition = DTSRowDisposition.RD_FailComponent Then
\ncol.ErrorRowDisposition = DTSRowDisposition.RD_RedirectRow
\nEnd If
\nIf col.TruncationRowDisposition = DTSRowDisposition.RD_FailComponent Then
\ncol.TruncationRowDisposition = DTSRowDisposition.RD_RedirectRow
\nEnd If
\nNext col
\nNext outp<\/p><\/blockquote>\nEine Derived Column-Komponente erstellen<\/h1>\n
\nDim compDerivedCol As IDTSComponentMetaData100 = pipe.ComponentMetaDataCollection.New()
\ncompDerivedCol.ComponentClassID = „DTSTransform.DerivedColumn“
\nDim DesignDerivedTransformColumns As CManagedComponentWrapper = compDerivedCol.Instantiate()
\nDesignDerivedTransformColumns.ProvideComponentProperties()
\ncompDerivedCol.Name = „Fehler_“ & comp.Name
\ncompDerivedCol.InputCollection(0).ExternalMetadataColumnCollection.IsUsed = False
\ncompDerivedCol.InputCollection(0).HasSideEffects = False<\/p><\/blockquote>\nDen Fehler-Output und die Derived Column verbinden<\/h1>\n
\npath.AttachPathAndPropagateNotifications(comp.OutputCollection(nrOfErrorOutput), compDerivedCol.InputCollection(0))<\/p><\/blockquote>\nZus\u00e4tzliche Spalten in der Derived Column anlegen<\/h1>\n
\n
\nHier kann man wunderbar den vorhandenen enum verwenden.<\/li>\n
\nDim neueSpalte As IDTSOutputColumn100 = derivedColumnComponent.OutputCollection(0).OutputColumnCollection.New()
\nneueSpalte.Name = name
\nneueSpalte.SetDataTypeProperties(dataType, dataTypeLaenge, 0, 0, 0)
\nneueSpalte.ExternalMetadataColumnID = 0
\nneueSpalte.ErrorRowDisposition = DTSRowDisposition.RD_IgnoreFailure
\nneueSpalte.TruncationRowDisposition = DTSRowDisposition.RD_IgnoreFailure<\/p>\n
\nneueSpalteProp.Name = „Expression“
\nIf lineageIDKeyColumn = 0 Then
\nneueSpalteProp.Value = expression
\nElse
\nneueSpalteProp.Value = „(DT_WSTR,“ & dataTypeLaenge & „)#“ + lineageIDKeyColumn.ToString()
\nEnd If
\nneueSpalteProp = neueSpalte.CustomPropertyCollection.New()
\nneueSpalteProp.Name = „FriendlyExpression“
\nneueSpalteProp.Value = expression<\/p>\n\n
\nDim inp As IDTSInput100 = comp.InputCollection(0)
\nDim virtualInp As IDTSVirtualInput100 = inp.GetVirtualInput()
\nDim virtualInpCols As IDTSVirtualInputColumnCollection100 = virtualInp.VirtualInputColumnCollection
\nDim designer As CManagedComponentWrapper = comp.Instantiate()<\/p>\n
\nIf virtualCol.Name = nameSpalte Then
\ndesigner.SetUsageType(inp.ID, virtualInp, virtualCol.LineageID, DTSUsageType.UT_READONLY)
\nnameSpalteGefunden = nameSpalte
\nReturn virtualCol.LineageID
\nEnd If
\nNext<\/p>\n
\nEnd Function<\/p><\/blockquote>\n<\/a><\/p>\nDie Derived Column mit der UNION ALL verbinden<\/h1>\n