發行項
04/02/2012

使用指令碼元件剖析非標準文字檔案格式

當來源資料是以非標準格式排列時，為了達成相同的結果，您可能會發現將所有剖析邏輯合併在單一指令碼中會比將多個 Integration Services 轉換鏈結在一起更方便。

範例 1：剖析以資料列分隔的記錄

範例 2：分割父記錄和子記錄

[!附註]

如果您要建立可以更輕鬆地在多個資料流程工作與多個封裝之間重複使用的元件，請考慮使用這個指令碼元件範例中的程式碼，做為自訂資料流程元件的起點。如需詳細資訊，請參閱＜開發自訂資料流程元件＞。

範例 1：剖析以資料列分隔的記錄

這則範例將示範如何取得每個資料行都以個別行顯示的文字檔案，並且使用指令碼元件，將它剖析成目的地資料表。

如需有關如何在資料流程中將指令碼元件設為當做轉換使用的詳細資訊，請參閱＜使用指令碼元件建立同步轉換＞和＜使用指令碼元件建立非同步轉換＞。

若要設定此指令碼元件範例

建立及儲存名為 rowdelimiteddata.txt 的文字檔案，其中包含下列來源資料：

FirstName: Nancy
LastName: Davolio
Title: Sales Representative
City: Seattle
StateProvince: WA

FirstName: Andrew
LastName: Fuller
Title: Vice President, Sales
City: Tacoma
StateProvince: WA

FirstName: Steven
LastName: Buchanan
Title: Sales Manager
City: London
StateProvince:

開啟 Management Studio 並連接至 SQL Server 的執行個體。

選取目的地資料庫，並且開啟新的查詢視窗。在查詢視窗中，執行下列指令碼來建立目的地資料表：

create table RowDelimitedData
(
FirstName varchar(32),
LastName varchar(32),
Title varchar(32),
City varchar(32),
StateProvince varchar(32)
)

開啟 BI Development Studio 並建立名為 ParseRowDelim.dtsx 的新 Integration Services 封裝。
將一般檔案連接管理員加入至此封裝、將它命名為 RowDelimitedData，並且將它設定為連接至您在先前步驟中建立的 rowdelimiteddata.txt 檔案。
將 OLE DB 連接管理員加入至此封裝，並且將它設定為連接至 SQL Server 的執行個體以及您在其中建立目的地資料表的資料庫。
將資料流程工作加入至此封裝，並且按一下 SSIS 設計師的 [資料流程] 索引標籤。
將一般檔案來源加入至資料流程，並且將它設定為使用 RowDelimitedData 連接管理員。在 [一般檔案來源編輯器] 的 [資料行] 頁面上，選取單一可用的外部資料行。
將指令碼元件加入至資料流程並將它設定為轉換。將一般檔案來源的輸出連接至指令碼元件。
按兩下指令碼元件，即可顯示 [指令碼轉換編輯器]。
在 [指令碼轉換編輯器] 的 [輸入資料行] 頁面上，選取單一可用的輸入資料行。
在 [指令碼轉換編輯器] 的 [輸入及輸出] 頁面上，選取 [Output 0] 並將其 SynchronousInputID 設定為 None。建立 5 個輸出資料行，全部都屬於字串 [DT_STR] 類型而且長度為 32：
- FirstName
- LastName
- Title
- City
- StateProvince
在 [指令碼轉換編輯器] 的 [指令碼] 頁面上，按一下 [編輯指令碼]，然後輸入範例之 ScriptMain 類別中所示的程式碼。關閉指令碼開發環境以及 [指令碼轉換編輯器]。
將 SQL Server 目的地加入至資料流程。將它設定為使用 OLE DB 連接管理員和 RowDelimitedData 資料表。將指令碼元件的輸出連接至這個目的地。
執行封裝。封裝完成之後，檢查 SQL Server 目的地資料表中的記錄。

    Public Overrides Sub Input0_ProcessInputRow(ByVal Row As Input0Buffer)

        Dim columnName As String
        Dim columnValue As String

        ' Check for an empty row.
        If Row.Column0.Trim.Length > 0 Then
            columnName = Row.Column0.Substring(0, Row.Column0.IndexOf(":"))
            ' Check for an empty value after the colon.
            If Row.Column0.Substring(Row.Column0.IndexOf(":")).TrimEnd.Length > 1 Then
                ' Extract the column value from after the colon and space.
                columnValue = Row.Column0.Substring(Row.Column0.IndexOf(":") + 2)
                Select Case columnName
                    Case "FirstName"
                        ' The FirstName value indicates a new record.
                        Me.Output0Buffer.AddRow()
                        Me.Output0Buffer.FirstName = columnValue
                    Case "LastName"
                        Me.Output0Buffer.LastName = columnValue
                    Case "Title"
                        Me.Output0Buffer.Title = columnValue
                    Case "City"
                        Me.Output0Buffer.City = columnValue
                    Case "StateProvince"
                        Me.Output0Buffer.StateProvince = columnValue
                End Select
            End If
        End If

    End Sub

public override void Input0_ProcessInputRow(Input0Buffer Row)
    {

        string columnName;
        string columnValue;

        // Check for an empty row.
        if (Row.Column0.Trim().Length > 0)
        {
            columnName = Row.Column0.Substring(0, Row.Column0.IndexOf(":"));
            // Check for an empty value after the colon.
            if (Row.Column0.Substring(Row.Column0.IndexOf(":")).TrimEnd().Length > 1)
            // Extract the column value from after the colon and space.
            {
                columnValue = Row.Column0.Substring(Row.Column0.IndexOf(":") + 2);
                switch (columnName)
                {
                    case "FirstName":
                        // The FirstName value indicates a new record.
                        this.Output0Buffer.AddRow();
                        this.Output0Buffer.FirstName = columnValue;
                        break;
                    case "LastName":
                        this.Output0Buffer.LastName = columnValue;
                        break;
                    case "Title":
                        this.Output0Buffer.Title = columnValue;
                        break;
                    case "City":
                        this.Output0Buffer.City = columnValue;
                        break;
                    case "StateProvince":
                        this.Output0Buffer.StateProvince = columnValue;
                        break;
                }
            }
        }

    }

範例 2：分割父記錄和子記錄

這則範例將示範如何取得文字檔案 (分隔符號資料列位於父記錄資料列前面，而且後面接著不定數目的子記錄資料列)，並且使用指令碼元件，將它剖析成適當正規化的父和子目的地資料表。您可以針對每筆父記錄和子記錄使用多個資料列或資料行的來源檔案輕鬆地調整這則簡單範例，只要存在可識別每筆記錄之開頭和結尾的方式即可。

注意
這則範例僅供示範使用。如果您執行此範例多次，它就會將重複的索引鍵值插入目的地資料表中。

若要設定此指令碼元件範例

建立及儲存名為 parentchilddata.txt 的文字檔案，其中包含下列來源資料：

******** PARENT 1 DATA child 1 data child 2 data child 3 data child 4 data ******** PARENT 2 DATA child 5 data child 6 data child 7 data child 8 data ********

開啟 SQL Server Management Studio 並連接至 SQL Server 的執行個體。

選取目的地資料庫，並且開啟新的查詢視窗。在查詢視窗中，執行下列指令碼來建立目的地資料表：

CREATE TABLE [dbo].[Parents](
[ParentID] [int] NOT NULL,
[ParentRecord] [varchar](32) NOT NULL,
 CONSTRAINT [PK_Parents] PRIMARY KEY CLUSTERED 
([ParentID] ASC)
)
GO
CREATE TABLE [dbo].[Children](
[ChildID] [int] NOT NULL,
[ParentID] [int] NOT NULL,
[ChildRecord] [varchar](32) NOT NULL,
 CONSTRAINT [PK_Children] PRIMARY KEY CLUSTERED 
([ChildID] ASC)
)
GO
ALTER TABLE [dbo].[Children] ADD CONSTRAINT [FK_Children_Parents] FOREIGN KEY([ParentID])
REFERENCES [dbo].[Parents] ([ParentID])

開啟 Business Intelligence Development Studio 並建立名為 SplitParentChild.dtsx 的新 Integration Services 封裝。
將一般檔案連接管理員加入至此封裝、將它命名為 ParentChildData，並且將它設定為連接至您在先前步驟中建立的 parentchilddata.txt 檔案。
將 OLE DB 連接管理員加入至此封裝，並且將它設定為連接至 SQL Server 的執行個體以及您在其中建立目的地資料表的資料庫。
將資料流程工作加入至此封裝，並且按一下 SSIS 設計師的 [資料流程] 索引標籤。
將一般檔案來源加入至資料流程，並且將它設定為使用 ParentChildData 連接管理員。在 [一般檔案來源編輯器] 的 [資料行] 頁面上，選取單一可用的外部資料行。
將指令碼元件加入至資料流程並將它設定為轉換。將一般檔案來源的輸出連接至指令碼元件。
按兩下指令碼元件，即可顯示 [指令碼轉換編輯器]。
在 [指令碼轉換編輯器] 的 [輸入資料行] 頁面上，選取單一可用的輸入資料行。
在 [指令碼轉換編輯器] 的 [輸入及輸出] 頁面上，選取 [Output 0]、將它重新命名為 ParentRecords 並將其 SynchronousInputID 設定為 None。建立 2 個輸出資料行：
- ParentID (主索引鍵)，屬於四位元組帶正負號的整數 [DT_I4] 類型
- ParentRecord，屬於字串 [DT_STR] 類型而且長度為 32
建立第二個輸出並將它命名為 ChildRecords。新輸出的 SynchronousInputID 已經設定為 None。建立 3 個輸出資料行：
- ChildID (主索引鍵)，屬於四位元組帶正負號的整數 [DT_I4] 類型
- ParentID (外部索引鍵)，也屬於四位元組帶正負號的整數 [DT_I4] 類型
- ChildRecord，屬於字串 [DT_STR] 類型而且長度為 50
在 [指令碼轉換編輯器] 的 [指令碼] 頁面上，按一下 [編輯指令碼]。在 ScriptMain 類別中，輸入此範例中所示的程式碼。關閉指令碼開發環境以及 [指令碼轉換編輯器]。
將 SQL Server 目的地加入至資料流程。將指令碼元件的 ParentRecords 輸出連接至這個目的地。將它設定為使用 OLE DB 連接管理員和 Parents 資料表。
將另一個 SQL Server 目的地加入至資料流程。將指令碼元件的 ChildRecords 輸出連接至這個目的地。將它設定為使用 OLE DB 連接管理員和 Children 資料表。
執行封裝。封裝完成之後，檢查兩個 SQL Server 目的地資料表中的父記錄和子記錄。

    Public Overrides Sub Input0_ProcessInputRow(ByVal Row As Input0Buffer)

        Static nextRowIsParent As Boolean = False
        Static parentCounter As Integer = 0
        Static childCounter As Integer = 0

        ' If current row starts with separator characters,
        '  then following row contains new parent record.
        If Row.Column0.StartsWith("***") Then
            nextRowIsParent = True
        Else
            If nextRowIsParent Then
                ' Current row contains parent record.
                parentCounter += 1
                Me.ParentRecordsBuffer.AddRow()
                Me.ParentRecordsBuffer.ParentID = parentCounter
                Me.ParentRecordsBuffer.ParentRecord = Row.Column0
                nextRowIsParent = False
            Else
                ' Current row contains child record.
                childCounter += 1
                Me.ChildRecordsBuffer.AddRow()
                Me.ChildRecordsBuffer.ChildID = childCounter
                Me.ChildRecordsBuffer.ParentID = parentCounter
                Me.ChildRecordsBuffer.ChildRecord = Row.Column0
            End If
        End If

    End Sub

public override void Input0_ProcessInputRow(Input0Buffer Row)
    {

    int static_Input0_ProcessInputRow_childCounter = 0;
    int static_Input0_ProcessInputRow_parentCounter = 0;
    bool static_Input0_ProcessInputRow_nextRowIsParent = false;

        // If current row starts with separator characters, 
        // then following row contains new parent record. 
        if (Row.Column0.StartsWith("***"))
        {
            static_Input0_ProcessInputRow_nextRowIsParent = true;
        }
        else
        {
            if (static_Input0_ProcessInputRow_nextRowIsParent)
            {
                // Current row contains parent record. 
                static_Input0_ProcessInputRow_parentCounter += 1;
                this.ParentRecordsBuffer.AddRow();
                this.ParentRecordsBuffer.ParentID = static_Input0_ProcessInputRow_parentCounter;
                this.ParentRecordsBuffer.ParentRecord = Row.Column0;
                static_Input0_ProcessInputRow_nextRowIsParent = false;
            }
            else
            {
                // Current row contains child record. 
                static_Input0_ProcessInputRow_childCounter += 1;
                this.ChildRecordsBuffer.AddRow();
                this.ChildRecordsBuffer.ChildID = static_Input0_ProcessInputRow_childCounter;
                this.ChildRecordsBuffer.ParentID = static_Input0_ProcessInputRow_parentCounter;
                this.ChildRecordsBuffer.ChildRecord = Row.Column0;
            }
        }

    }

掌握 Integration Services 的最新狀態