Rozwijanie składnik transformacja niestandardowe z synchroniczne wyjścia

Dane wejściowe, wyjściowe i właściwości niestandardowe składnika są zwykle tworzone podczas ProvideComponentProperties() Metoda. Istnieją dwa sposoby, można dodawać dane wejściowe i wyjściowe składnika transformacja z synchronicznej wyjść.Można użyć klasy podstawowej stosowania metoda i następnie zmodyfikować domyślne dane wejściowe i wyjściowe, tworzy lub jawnie dodać dane wejściowe i wyjściowe samodzielnie.

Poniższy przykład kodu pokazuje implementację ProvideComponentProperties() które jawnie dodaje obiekty wejściowe i wyjściowe. Wywołanie klasy podstawowej, które mogłyby wykonać samo dołączono komentarz.

using Microsoft.SqlServer.Dts.Pipeline;
using Microsoft.SqlServer.Dts.Pipeline.Wrapper;
using Microsoft.SqlServer.Dts.Runtime;

namespace Microsoft.Samples.SqlServer.Dts
{
    [DtsPipelineComponent(DisplayName = "SynchronousComponent", ComponentType = ComponentType.Transform)]
    public class SyncComponent : PipelineComponent
    {

        public override void ProvideComponentProperties()
        {
            // Add the input.
            IDTSInput100 input = ComponentMetaData.InputCollection.New();
            input.Name = "Input";

            // Add the output.
            IDTSOutput100 output = ComponentMetaData.OutputCollection.New();
            output.Name = "Output";
            output.SynchronousInputID = input.ID;

            // Alternatively, you can let the base class add the input and output
            // and set the SynchronousInputID of the output to the ID of the input.
            // base.ProvideComponentProperties();
        }
    }
}

Imports Microsoft.SqlServer.Dts.Pipeline
Imports Microsoft.SqlServer.Dts.Pipeline.Wrapper
Imports Microsoft.SqlServer.Dts.Runtime

<DtsPipelineComponent(DisplayName:="SynchronousComponent", ComponentType:=ComponentType.Transform)> _
Public Class SyncComponent
    Inherits PipelineComponent

    Public Overrides Sub ProvideComponentProperties()

        ' Add the input.
        Dim input As IDTSInput100 = ComponentMetaData.InputCollection.New()
        input.Name = "Input"

        ' Add the output.
        Dim output As IDTSOutput100 = ComponentMetaData.OutputCollection.New()
        output.Name = "Output"
        output.SynchronousInputID = Input.ID

        ' Alternatively, you can let the base class add the input and output
        ' and set the SynchronousInputID of the output to the ID of the input.
        ' base.ProvideComponentProperties();

    End Sub

End Class

Mimo, że składniki transformacja z wyjść synchronicznego nie należy dodawać wiersze do buforów, może dodać dodatkowe wyjściowy kolumn do swoich danych wyjściowych.Zazwyczaj gdy składnik dodaje kolumna wyprowadzenia, wartości dla nowej kolumna wyjściowe są obliczane w czasie wykonywania na podstawie danych zawartych w jednej lub więcej kolumn do składnika przez składnik poprzednie.

Po utworzeniu kolumna wyprowadzenia, należy ustawić jego właściwości typów danych.Ustawianie danych właściwości typu kolumna wyprowadzenia wymaga specjalnej obsługi i wykonywane jest przez wywołanie SetDataTypeProperties(DataType, Int32, Int32, Int32, Int32) Metoda. Ta metoda jest wymagane, ponieważ DataType(), Length(), Precision(), a CodePage() właściwości są pojedynczo tylko do odczytu, ponieważ każdy zależy od ustawień z drugiej strony. Ta metoda gwarantuje, że wartości właściwości są ustawiane w sposób ciągły, a także zadanie przepływ danych sprawdza, czy są one poprawnie ustawione.

The DataType() of the kolumna determines the values that are zestaw for the other properties. W poniższej tabela przedstawiono wymagania dotyczące zależne od właściwości dla każdego DataType(). Typy danych niewymienionych są zależne od właściwości zestaw na zero.

Ponieważ ograniczeń na właściwości typów danych zależą od typu danych kolumna danych wyjściowych, należy wybrać odpowiedniego Integration Services Typ danych podczas pracy z typami zarządzanych. Klasa podstawowa oferuje trzy metody pomocnika, ConvertBufferDataTypeToFitManaged(DataType, Boolean%), BufferTypeToDataRecordType(DataType), a DataRecordTypeToBufferType(Type) Deweloperzy składników zarządzanych, pomóc przy wyborze SSIS biorąc pod uwagę typu zarządzanego typu danych. Te metody konwersji typów danych zarządzanych SSIS typy danych i na odwrót.

Liczba kolumn w bufory, dostarczane ze składnikiem podczas wykonywania prawdopodobnie przekroczy liczbę kolumn w kolekcjach wejściowego lub wyjściowego składnika.Dzieje się tak, ponieważ każdy bufor zawiera kolumny wyjściowe określonych składników w przepływie danych.W celu zapewnienia, że kolumny buforu poprawnie dopasowane do kolumny danych wejściowych lub wyjściowych, należy użyć składnika deweloperzy FindColumnByLineageID(Int32, Int32) Metoda BufferManager(). Ta metoda lokalizuje kolumna w określonym buforze według jego identyfikatora rodowodu.Zazwyczaj kolumnach znajdują się w okresie PreExecute() ponieważ jest to pierwsza metoda run-czas gdzie BufferManager() Właściwość stają się dostępne.

Poniższy przykład kodu pokazuje składnik, który lokalizuje indeksów kolumna s w jego dane wejściowe i wyjściowe kolumna kolekcja podczas PreExecute(). Indeksy kolumnie są przechowywane w tablicy liczb całkowitych i można uzyskać dostęp za pośrednictwem składnika podczas ProcessInput(Int32, PipelineBuffer).

int []inputColumns;
int []outputColumns;

public override void PreExecute()
{
    IDTSInput100 input = ComponentMetaData.InputCollection[0];
    IDTSOutput100 output = ComponentMetaData.OutputCollection[0];

    inputColumns = new int[input.InputColumnCollection.Count];
    outputColumns = new int[output.OutputColumnCollection.Count];

    for(int col=0; col < input.InputColumnCollection.Count; col++)
    {
        IDTSInputColumn100 inputColumn = input.InputColumnCollection[col];
        inputColumns[col] = BufferManager.FindColumnByLineageID(input.Buffer, inputColumn.LineageID);
    }

    for(int col=0; col < output.OutputColumnCollection.Count; col++)
    {
        IDTSOutputColumn100 outputColumn = output.OutputColumnCollection[col];
        outputColumns[col] = BufferManager.FindColumnByLineageID(input.Buffer, outputColumn.LineageID);
    }

}

Public Overrides Sub PreExecute()

    Dim input As IDTSInput100 = ComponentMetaData.InputCollection(0)
    Dim output As IDTSOutput100 = ComponentMetaData.OutputCollection(0)


    ReDim inputColumns(input.InputColumnCollection.Count)
    ReDim outputColumns(output.OutputColumnCollection.Count)

    For col As Integer = 0 To input.InputColumnCollection.Count

        Dim inputColumn As IDTSInputColumn100 = input.InputColumnCollection(col)
        inputColumns(col) = BufferManager.FindColumnByLineageID(input.Buffer, inputColumn.LineageID)
    Next

    For col As Integer = 0 To output.OutputColumnCollection.Count

        Dim outputColumn As IDTSOutputColumn100 = output.OutputColumnCollection(col)
        outputColumns(col) = BufferManager.FindColumnByLineageID(input.Buffer, outputColumn.LineageID)
    Next

End Sub

Odbieranie składników PipelineBuffer obiekty, które zawierają wiersze i kolumny w ProcessInput(Int32, PipelineBuffer) Metoda. Podczas tej metoda są iterated wierszy w buforze, a w kolumnach rozpoznane w PreExecute() odczytywać i modyfikować. W wywoływana jest metoda wielokrotnie przez zadanie przepływ danych, dopóki nie ma więcej wierszy znajdują się od składnika nadrzędnego.

Pojedynczej kolumna w buforze jest odczytu lub zapisu przy użyciu metoda dostępu indeksowania tablicy lub przy użyciu jednej z Get lub Set metoda. The Get and Set methods are more efficient and should be used when the data type of the kolumna in the buffer is known.

Poniższy przykład kodu pokazuje implementację ProcessInput(Int32, PipelineBuffer) Metoda przetwarzania przychodzących wierszy.

public override void ProcessInput( int InputID, PipelineBuffer buffer)
{
       while( buffer.NextRow())
       {
            for(int x=0; x < inputColumns.Length;x++)
            {
                if(!buffer.IsNull(inputColumns[x]))
                {
                    object columnData = buffer[inputColumns[x]];
                    // TODO: Modify the column data.
                    buffer[inputColumns[x]] = columnData;
                }
            }
        
      }
}

Public Overrides Sub ProcessInput(ByVal InputID As Integer, ByVal buffer As PipelineBuffer)

        While (buffer.NextRow())

            For x As Integer = 0 To inputColumns.Length

                if buffer.IsNull(inputColumns(x)) = false then

                    Dim columnData As Object = buffer(inputColumns(x))
                    ' TODO: Modify the column data.
                    buffer(inputColumns(x)) = columnData

                End If
            Next

        End While
End Sub