使用指令碼元件建立非同步轉換

開始使用非同步轉換元件

當您將指令碼元件加入 SSIS 設計師的 [資料流程] 索引標籤時，就會開啟 [選取指令碼元件類型] 對話方塊，提示您將此元件預先設定為來源、轉換或目的地。在這個對話方塊中，選取 [轉換]。

在中繼資料設計模式中設定非同步轉換元件

在您選取可建立轉換元件的選項之後，請藉由使用 [指令碼轉換編輯器] 來設定元件。如需詳細資訊，請參閱＜在指令碼元件編輯器中設定指令碼元件＞。

若要選取指令碼元件將要使用的指令碼語言，請在 [指令碼轉換編輯器] 對話方塊的 [指令碼] 頁面上設定 [ScriptLanguage] 屬性。

資料流程轉換元件有一個輸入，而且支援一或多個輸出。設定元件的輸入與輸出是您必須在中繼資料設計模式下完成的其中一個步驟，方法是在撰寫自訂指令碼之前先使用 [指令碼轉換編輯器]。

設定輸入資料行

設定輸入、輸出及輸出資料行

加入變數

在程式碼設計模式中編寫非同步轉換元件的指令碼

在您設定好元件的所有中繼資料之後，便可撰寫自訂指令碼。在 [指令碼轉換編輯器] 的 [指令碼] 頁面上，按一下 [編輯指令碼]，開啟 Microsoft Visual Studio Tools for Applications (VSTA) IDE 以加入自訂指令碼。所使用的指令碼語言，取決於您是選取 Microsoft Visual Basic 2008 或 Microsoft Visual C# 2008 做為 [指令碼] 頁面上 ScriptLanguage 屬性的指令碼語言而定。

如需使用指令碼元件所建立之各種元件都適用的重要資訊，請參閱＜指令碼元件的程式碼撰寫和偵錯＞。

了解自動產生的程式碼

撰寫您的自訂程式碼

範例

此範例示範在 ScriptMain 類別中所需的自訂程式碼，以建立非同步轉換元件。

此範例示範具有兩個輸出的非同步轉換元件。此轉換會通過 AddressID 和 City 資料行傳遞給一個輸出，而它會計算位於特定城市 (美國華盛頓州 Redmond 城市) 的地址數，然後將產生的值輸出給第二個輸出。

如果您要執行這個範例程式碼，必須依下列方式設定封裝與元件：

1. 將新指令碼元件加入資料流程設計師介面，並將它設定為轉換。

2. 將來源的輸出或另一個轉換的輸出連接到設計師中的新轉換元件。這個輸出應該從 AdventureWorks2008R2 範例資料庫的 Person.Address 資料表中提供資料，而這個資料庫至少包含 AddressID 與 City 資料行。

3. 開啟 [指令碼轉換編輯器]。在 [輸入資料行] 頁面上，選取 AddressID 與 City 資料行。

4. 在 [輸入及輸出] 頁面上，於第一個輸出加入及設定 AddressID 和 City 輸出資料行。加入第二個輸出，然後在第二個輸出上加入摘要值的輸出資料行。將第一個輸出的 SynchronousInputID 屬性設定為 0，因為這個範例會將每一個輸入資料列明確地複製到第一個輸出。新建立之輸出的 SynchronousInputID 屬性已經設定為 0。

5. 重新命名輸入、輸出和新的輸出資料行，為它們提供更具描述性的名稱。此範例使用 MyAddressInput 當做輸入的名稱、使用 MyAddressOutput 和 MySummaryOutput 當做輸出，並使用 MyRedmondCount 當做第二個輸出的輸出資料行。

6. 在 [指令碼] 頁面上，按一下 [編輯指令碼] 並輸入以下指令碼。然後關閉指令碼開發環境以及 [指令碼轉換編輯器]。

7. 針對第一個輸出建立及設定需要 AddressID 與 City 資料行的目的地元件，例如 SQL Server 目的地，或是在＜以指令碼元件建立目的地＞中所示範的範例目的地元件。然後將轉換的第一個輸出 MyAddressOutput 連接到目的地元件。您可以在 AdventureWorks2008R2 資料庫中執行下列 Transact-SQL 命令，以建立目的地資料表：

   CREATE TABLE [Person].[Address2](
       [AddressID] [int] NOT NULL,
       [City] [nvarchar](30) NOT NULL
   )
   

8. 為第二個輸出建立及設定另一個目的地元件。然後將轉換的第二個輸出 MySummaryOutput 連接到目的地元件。因為第二個輸出會寫入具有單一值的單一資料列，所以您可以輕鬆地使用一般檔案連接管理員來設定目的地，此管理員會連接到具有單一資料行的新檔案。在此範例中，這個目的地資料行命名為 MyRedmondCount。

9. 執行範例。

Public Class ScriptMain
    Inherits UserComponent

    Private myRedmondAddressCount As Integer

    Public Overrides Sub CreateNewOutputRows()

        MySummaryOutputBuffer.AddRow()

    End Sub

    Public Overrides Sub MyAddressInput_ProcessInput(ByVal Buffer As MyAddressInputBuffer)

        While Buffer.NextRow()
            MyAddressInput_ProcessInputRow(Buffer)
        End While

        If Buffer.EndOfRowset Then
            MyAddressOutputBuffer.SetEndOfRowset()
            MySummaryOutputBuffer.MyRedmondCount = myRedmondAddressCount
            MySummaryOutputBuffer.SetEndOfRowset()
        End If

    End Sub

    Public Overrides Sub MyAddressInput_ProcessInputRow(ByVal Row As MyAddressInputBuffer)

        With MyAddressOutputBuffer
            .AddRow()
            .AddressID = Row.AddressID
            .City = Row.City
        End With

        If Row.City.ToUpper = "REDMOND" Then
            myRedmondAddressCount += 1
        End If

    End Sub

End Class

public class ScriptMain:
    UserComponent

{
    private int myRedmondAddressCount;

    public override void CreateNewOutputRows()
    {

        MySummaryOutputBuffer.AddRow();

    }

    public override void MyAddressInput_ProcessInput(MyAddressInputBuffer Buffer)
    {

        while (Buffer.NextRow())
        {
            MyAddressInput_ProcessInputRow(Buffer);
        }

        if (Buffer.EndOfRowset())
        {
            MyAddressOutputBuffer.SetEndOfRowset();
            MySummaryOutputBuffer.MyRedmondCount = myRedmondAddressCount;
            MySummaryOutputBuffer.SetEndOfRowset();
        }

    }

    public override void MyAddressInput_ProcessInputRow(MyAddressInputBuffer Row)
    {

        {
            MyAddressOutputBuffer.AddRow();
            MyAddressOutputBuffer.AddressID = Row.AddressID;
            MyAddressOutputBuffer.City = Row.City;
        }

        if (Row.City.ToUpper() == "REDMOND")
        {
            myRedmondAddressCount += 1;
        }

    }

}

請參閱

概念