Grundlegendes zum Skript-Komponentenobjektmodell

Wie in Codieren und Debuggen der Skriptkomponente erläutert, enthält das Skriptkomponentenprojekt drei Projektelemente:

1. Das ScriptMain-Element, das die ScriptMain-Klasse enthält, in die Sie den Code schreiben. Die ScriptMain-Klasse erbt von der UserComponent-Klasse.

2. Das ComponentWrapper-Element, das die UserComponent-Klasse enthält, eine Instanz von ScriptComponent, die die Methoden und Eigenschaften enthält, die Sie verwenden, um Daten zu verarbeiten und mit dem Paket zu interagieren. Das ComponentWrapper-Element enthält auch Connections- und Variables-Auflistungsklassen.

3. Das BufferWrapper-Element, das Klassen enthält, das von ScriptBuffer für jede Eingabe und Ausgabe und typisierte Eigenschaften für jede Spalte erbt.

Beim Schreiben des Codes in das ScriptMain-Element verwenden Sie die in diesem Thema besprochenen Objekte, Methoden und Eigenschaften. Es werden nicht von jeder Komponente alle hier aufgeführten Methoden verwendet. Wenn sie jedoch verwendet werden, geschieht dies in der gezeigten Reihenfolge.

Die ScriptComponent-Basisklasse enthält keinen Implementierungscode für die in diesem Thema erläuterten Methoden. Es ist daher unnötig, aber ungefährlich, Ihrer eigenen Implementierung der Methode einen Aufruf der Basisklassenimplementierung hinzuzufügen.

Informationen darüber, wie die Methoden und Eigenschaften dieser Klassen in einem bestimmten Skriptkomponententyp zu verwenden sind, finden Sie im Abschnitt Zusätzliche Skriptkomponentenbeispiele. Die Beispielthemen enthalten auch vollständige Codebeispiele.

‚AcquireConnections’-Methode

Quellen und Ziele müssen im Allgemeinen eine Verbindung mit einer externen Datenquelle herstellen. Überschreiben Sie die AcquireConnections-Methode der ScriptComponent-Basisklasse, um die Verbindung oder die Verbindungsinformationen von dem entsprechenden Verbindungs-Manager abzurufen.

Im folgenden Beispiel wird System.Data.SqlClient.SqlConnection von einem ADO.NET-Verbindungs-Manager zurückgegeben.

    Dim connMgr As IDTSConnectionManager100
    Dim sqlConn As SqlConnection

    Public Overrides Sub AcquireConnections(ByVal Transaction As Object)

        connMgr = Me.Connections.MyADONETConnection
        sqlConn = CType(connMgr.AcquireConnection(Nothing), SqlConnection)

    End Sub

Das folgende Beispiel gibt einen vollständigen Pfad- und Dateinamen von einem Verbindungs-Manager für Flatfiles zurück und öffnet anschließend die Datei mithilfe von System.IO.StreamReader.

    Private textReader As StreamReader
    Public Overrides Sub AcquireConnections(ByVal Transaction As Object)

        Dim connMgr As IDTSConnectionManager100 = _
            Me.Connections.MyFlatFileSrcConnectionManager
        Dim exportedAddressFile As String = _
            CType(connMgr.AcquireConnection(Nothing), String)
        textReader = New StreamReader(exportedAddressFile)

    End Sub

‚PreExecute’-Methode

Überschreiben Sie die PreExecute-Methode der ScriptComponent-Basisklasse immer dann, wenn Sie eine Verarbeitung nur einmal durchführen müssen, bevor Sie die Verarbeitung einer Datenzeile starten. In einem Ziel können Sie beispielsweise den parametrisierten Befehl, den das Ziel verwendet, so konfigurieren, dass jede Datenzeile in die Datenquelle eingefügt wird.

    Dim sqlConn As SqlConnection
    Dim sqlCmd As SqlCommand
    Dim sqlParam As SqlParameter
...
    Public Overrides Sub PreExecute()

        sqlCmd = New SqlCommand("INSERT INTO Person.Address2(AddressID, City) " & _
            "VALUES(@addressid, @city)", sqlConn)
        sqlParam = New SqlParameter("@addressid", SqlDbType.Int)
        sqlCmd.Parameters.Add(sqlParam)
        sqlParam = New SqlParameter("@city", SqlDbType.NVarChar, 30)
        sqlCmd.Parameters.Add(sqlParam)

    End Sub

    SqlConnection sqlConn; 
    SqlCommand sqlCmd; 
    SqlParameter sqlParam; 
    
    public override void PreExecute() 
    { 
        
        sqlCmd = new SqlCommand("INSERT INTO Person.Address2(AddressID, City) " + "VALUES(@addressid, @city)", sqlConn); 
        sqlParam = new SqlParameter("@addressid", SqlDbType.Int); 
        sqlCmd.Parameters.Add(sqlParam); 
        sqlParam = new SqlParameter("@city", SqlDbType.NVarChar, 30); 
        sqlCmd.Parameters.Add(sqlParam); 
       
    }

Verarbeiten von Eingaben und Ausgaben

Verarbeiten von Eingaben

Skriptkomponenten, die als Transformationen oder Ziele konfiguriert sind, weisen eine Eingabe auf.

Bereitstellungen durch das ‚BufferWrapper’-Projektelement

Für jede von Ihnen konfigurierte Eingabe enthält das BufferWrapper-Projektelement eine Klasse, die von ScriptBuffer abgeleitet ist und denselben Namen hat wie die Eingabe. Jede Eingabepufferklasse enthält die folgenden Eigenschaften, Funktionen und Methoden:

• Benannte, typisierte Accessoreigenschaften für jede ausgewählte Eingabespalte. Diese Eigenschaften sind schreibgeschützt oder weisen Lese-/Schreibzugriff auf, abhängig von dem für die Spalte auf der Seite Eingabespalten des Dialogfelds Transformations-Editor für Skripterstellung angegebenen Verwendungstyp.

• Eine <column>_IsNull-Eigenschaft für jede ausgewählte Eingabespalte. Diese Eigenschaft ist ebenfalls schreibgeschützt oder weist Lese-/Schreibzugriff auf, abhängig von dem für die Spalte angegebenen Verwendungstyp.

• Eine DirectRowTo<outputbuffer>-Methode für jede konfigurierte Ausgabe. Sie verwenden diese Methoden beim Filtern von Zeilen in eine von mehreren Ausgaben in derselben ExclusionGroup.

• Eine NextRow-Funktion, um die nächste Eingabezeile abzurufen, und eine EndOfRowset-Funktion, um zu bestimmen, ob der letzte Datenpuffer verarbeitet wurde. Normalerweise benötigen Sie diese Funktionen nicht, wenn Sie die in der UserComponent-Basisklasse implementierten Eingabeverarbeitungsmethoden verwenden. Im nächsten Abschnitt finden Sie weitere Informationen über die UserComponent-Basisklasse.

Bereitstellungen durch das ‚ComponentWrapper’-Projektelement

Das ComponentWrapper-Projektelement enthält eine Klasse mit dem Namen UserComponent, die von ScriptComponent abgeleitet wird. Die ScriptMain-Klasse, in die Sie Ihren benutzerdefinierten Code schreiben, wird wiederum von UserComponent abgeleitet. Die UserComponent-Klasse enthält die folgenden Methoden:

• Eine überschriebene Implementierung der ProcessInput-Methode. Diese Methode wird vom Datenflussmodul zur Laufzeit direkt im Anschluss an die PreExecute-Methode (und u. U. mehrfach) aufgerufen. ProcessInput übergibt die Verarbeitung an die <inputbuffer>_ProcessInput-Methode. Anschließend sucht die ProcessInput-Methode nach dem Ende des Eingabepuffers. Wenn das Ende des Puffers erreicht wurde, ruft sie die überschreibbare FinishOutputs-Methode und die private MarkOutputsAsFinished-Methode auf. Die MarkOutputsAsFinished-Methode ruft dann beim letzten Ausgabepuffer SetEndOfRowset auf.

• Eine überschreibbare Implementierung der <inputbuffer>_ProcessInput-Methode. Diese Standardimplementierung durchläuft einfach jede Eingabezeile und ruft <inputbuffer>_ProcessInputRow auf.

• Eine überschreibbare Implementierung der <inputbuffer>_ProcessInputRow-Methode. Der Standardimplementierung ist leer. Dies ist die Methode, die Sie normalerweise überschreiben, um den benutzerdefinierten Datenverarbeitungscode zu schreiben.

Schritte, die der benutzerdefinierte Code ausführen soll

Sie können mithilfe der folgenden Methoden Eingaben in die ScriptMain-Klasse verarbeiten:

• Überschreiben Sie <inputbuffer>_ProcessInputRow, um die Daten in jeder Eingabezeile beim Durchlaufen zu verarbeiten.

• Überschreiben Sie <inputbuffer>_ProcessInput nur dann, wenn Sie beim Durchlaufen der Eingabezeilen noch etwas anderes zu tun haben. (Sie müssen beispielsweise EndOfRowset testen, um andere Maßnahmen zu ergreifen, nachdem alle Zeilen verarbeitet wurden.) Rufen Sie <inputbuffer>_ProcessInputRow auf, um die Zeilenverarbeitung auszuführen.

• Überschreiben Sie FinishOutputs, wenn Sie etwas mit den Ausgaben durchführen müssen, bevor sie geschlossen werden.

Die ProcessInput-Methode stellt sicher, dass diese Methoden zum jeweils richtigen Zeitpunkt aufgerufen werden.

Verarbeiten von Ausgaben

Skriptkomponenten, die als Quellen oder Transformationen konfiguriert sind, weisen mindestens eine Eingabe auf.

Bereitstellungen durch das ‚BufferWrapper’-Projektelement

Für jede von Ihnen konfigurierte Ausgabe enthält das BufferWrapper-Projektelement eine Klasse, die von ScriptBuffer abgeleitet ist und denselben Namen hat wie die Ausgabe. Jede Eingabepufferklasse enthält die folgenden Eigenschaften und Methoden:

• Benannte, typisierte, lesegeschützte Accessoreigenschaften für jede ausgewählte Ausgabespalte.

• Eine lesegeschützte <column>_IsNull-Eigenschaft für jede ausgewählte Ausgabespalte, die Sie zum Festlegen des Spaltenwerts auf null verwenden können.

• Eine AddRow-Methode, um dem Ausgabepuffer eine leere neue Zeile hinzuzufügen.

• Eine SetEndOfRowset-Methode, um dem Datenflussmodul mitzuteilen, dass keine weiteren Datenpuffer erwartet werden. Außerdem gibt es eine EndOfRowset-Funktion, um zu bestimmen, ob der aktuelle Puffer der letzte Datenpuffer ist. Normalerweise benötigen Sie diese Funktionen nicht, wenn Sie die in der UserComponent-Basisklasse implementierten Eingabeverarbeitungsmethoden verwenden.

Bereitstellungen durch das ‚ComponentWrapper’-Projektelement

Das ComponentWrapper-Projektelement enthält eine Klasse mit dem Namen UserComponent, die von ScriptComponent abgeleitet wird. Die ScriptMain-Klasse, in die Sie Ihren benutzerdefinierten Code schreiben, wird wiederum von UserComponent abgeleitet. Die UserComponent-Klasse enthält die folgenden Methoden:

• Eine überschriebene Implementierung der PrimeOutput-Methode. Diese Methode wird vom Datenflussmodul zur Laufzeit vor ProcessInput (und nur einmal) aufgerufen. PrimeOutput übergibt die Verarbeitung an die CreateNewOutputRows-Methode. Wenn die Komponente eine Quelle ist (d. h. die Komponente weist keine Eingaben auf), ruft PrimeOutput anschließend die überschreibbare FinishOutputs-Methode und die private MarkOutputsAsFinished-Methode auf. Die MarkOutputsAsFinished-Methode ruft beim letzten Ausgabepuffer SetEndOfRowset auf.

• Eine überschreibbare Implementierung der CreateNewOutputRows-Methode. Der Standardimplementierung ist leer. Dies ist die Methode, die Sie normalerweise überschreiben, um den benutzerdefinierten Datenverarbeitungscode zu schreiben.

Schritte, die der benutzerdefinierte Code ausführen sollte

Sie können mithilfe der folgenden Methoden Ausgaben in der ScriptMain-Klasse verarbeiten:

• Überschreiben Sie CreateNewOutputRows nur, wenn Sie Ausgabezeilen vor der Verarbeitung der Eingabezeilen hinzufügen und füllen können. Sie können beispielsweise CreateNewOutputRows in einer Quelle verwenden. In einer Transformation mit asynchronen Ausgaben sollten Sie jedoch AddRow während oder nach der Verarbeitung der Eingabedaten aufrufen.

• überschreiben Sie FinishOutputs, wenn Sie etwas mit den Ausgaben durchführen müssen, bevor sie geschlossen werden.

Die PrimeOutput-Methode stellt sicher, dass diese Methoden zum jeweils richtigen Zeitpunkt aufgerufen werden.

‚PostExecute’-Methode

Überschreiben Sie die PostExecute-Methode der ScriptComponent-Basisklasse immer dann, wenn Sie eine Verarbeitung nur einmal durchführen müssen, nachdem Sie die Datenzeilen verarbeitet haben. In einer Quelle können Sie beispielsweise den von Ihnen zum Laden von Daten in den Datenfluss verwendeten System.Data.SqlClient.SqlDataReader schließen.

Wichtig

Die Auflistung von ReadWriteVariables ist nur in der PostExecute-Methode verfügbar. Sie können daher den Wert einer Paketvariablen nicht direkt inkrementieren, während Sie jede Datenzeile verarbeiten. Inkrementieren Sie stattdessen den Wert einer lokalen Variablen, und legen Sie den Wert der Paketvariablen auf den Wert der lokalen Variablen in der PostExecute-Methode fest, nachdem alle Daten verarbeitet wurden.

‚ReleaseConnections’-Methode

Quellen und Ziele müssen im Allgemeinen eine Verbindung mit einer externen Datenquelle herstellen. Überschreiben Sie die ReleaseConnections-Methode der ScriptComponent-Basisklasse, um die vorher in der AcquireConnections-Methode geöffnete Verbindung zu schließen und freizugeben.

    Dim connMgr As IDTSConnectionManager100
...
    Public Overrides Sub ReleaseConnections()

        connMgr.ReleaseConnection(sqlConn)

    End Sub

    IDTSConnectionManager100 connMgr;

    public override void ReleaseConnections()
    {

        connMgr.ReleaseConnection(sqlConn);

    }

Bleiben Sie mit Integration Services auf dem neuesten Stand Die neuesten Downloads, Artikel, Beispiele und Videos von Microsoft sowie ausgewählte Lösungen aus der Community finden Sie auf MSDN auf der Integration Services-Seite: Besuchen Sie die Integration Services-Seite auf MSDN Abonnieren Sie die auf der Seite verfügbaren RSS-Feeds, um automatische Benachrichtigungen zu diesen Updates zu erhalten.

Siehe auch

Konzepte

Konfigurieren der Skriptkomponente im Skriptkomponenten-Editor

Codieren und Debuggen der Skriptkomponente