以指令碼元件建立來源

通常來源元件使用現有的連接管理員，以連接到它將資料載入資料流程的資料來源。在 [指令碼轉換編輯器] 的 [連接管理員] 頁面上，按一下 [加入]，加入適當的連接管理員。

然而，連接管理員只是一種便利的單位，用以封裝和儲存連接至特定類型的資料來源所需的資訊。您必須撰寫自己的自訂程式碼，以載入或是儲存資料，以及 (可能的話) 開啟和關閉連至資料來源的連接。

如需有關如何透過指令碼元件使用連接管理員的一般資訊，請參閱＜連接到指令碼元件中的資料來源＞。

如需有關 [指令碼轉換編輯器] 的 [連接管理員] 頁面的詳細資訊，請參閱＜指令碼轉換編輯器 (連接管理員頁面)＞。

來源元件沒有輸入，而且支援一或多個輸出。在 [指令碼轉換編輯器] 的 [輸入及輸出] 頁面上，預設已建立單一輸出，但是尚未建立輸出資料行。在編輯器的此頁面上，您可能會需要或想要設定下列項目。

• 您必須為每個輸出手動加入和設定輸出資料行。為每個輸出選取 [輸出資料行] 資料夾，然後使用 [加入資料行] 與 [移除資料行] 按鈕，為來源元件的每個輸出管理輸出資料行。之後，您將在指令碼中使用這裡所指派的名稱來參考輸出資料行，方法是使用在自動產生的程式碼中為您建立的具有類型之存取子屬性。

• 您可能會想要建立一或多個其他輸出，例如含有非預期值的資料列之模擬錯誤輸出。使用 [加入輸出] 和 [移除輸出] 按鈕管理來源元件的輸出。所有的輸入資料列都會導向至所有可用的輸出，除非您也為那些輸出的 ExclusionGroup 屬性指定相同的非零值，也就是您想要將每個輸入資料列導向至有著相同 ExclusionGroup 值的其中一個輸出。至於選取哪一個特定的整數值以識別 ExclusionGroup 則無關緊要。

  [!附註]

  當您不想要輸出所有的資料列時，也可以使用具有單一輸出的非零 ExclusionGroup 屬性值。然而，在此情況下，您必須為要傳送至輸出的每個資料列，明確地呼叫 DirectRowTo<outputbuffer> 方法。

• 您可能會想要將易記名稱指派給輸出。之後，您將在指令碼中使用輸出的名稱來加以參考，方法是使用在自動產生的程式碼中為您建立的具有類型之存取子屬性。

• 通常，在相同 ExclusionGroup 中的多個輸出都有相同的輸出資料行。然而，如果您正在建立模擬的錯誤輸出，可能會想要加入更多的資料行以儲存錯誤資訊。如需有關資料流程引擎如何處理錯誤資料列的詳細資訊，請參閱＜使用資料流程元件中的錯誤輸出＞。不過，在指令碼元件中，您必須撰寫自已的程式碼，以適當的錯誤資訊填入其他資料行。如需詳細資訊，請參閱＜模擬指令碼元件的錯誤輸出＞。

如需有關 [指令碼轉換編輯器] 的 [輸入及輸出] 頁面的詳細資訊，請參閱＜指令碼轉換編輯器 (輸入及輸出頁面)＞。

如果有任何現有變數的值是您想要在指令碼中使用的，可以在 [指令碼轉換編輯器] 的 [指令碼] 頁面上，將該變數加入 ReadOnlyVariables 與 ReadWriteVariables 屬性欄位中。

當您在屬性欄位中輸入多個變數時，請用逗號分隔變數名稱。您也可以按一下 ReadOnlyVariables 與 ReadWriteVariables 屬性欄位旁邊的省略符號 (…) 按鈕，並選取 [選取變數] 對話方塊中的變數，來輸入多個變數。

如需有關如何透過指令碼元件使用變數的一般資訊，請參閱＜在指令碼元件中使用變數＞。

如需有關 [指令碼轉換編輯器] 的 [指令碼] 頁面的詳細資訊，請參閱＜指令碼轉換編輯器 (指令碼頁面)＞。

當您在建立和設定來源元件之後開啟 VSTA IDE，可編輯的 ScriptMain 類別會出現在程式碼編輯器中。您在 ScriptMain 類別中撰寫自訂程式碼。

ScriptMain 類別包括 CreateNewOutputRows 方法的 Stub。CreateNewOutputRows 是來源元件中最重要的方法。

如果您在 VSTA 中開啟 [專案總管] 視窗，可以看到指令碼元件也會產生唯讀的 BufferWrapper 與 ComponentWrapper 專案項目。ScriptMain 類別會繼承 ComponentWrapper 專案項目中的 UserComponent 類別。

在執行階段，資料流程引擎會叫用 UserComponent 類別中的 PrimeOutput 方法，它會覆寫 ScriptComponent 父類別的 PrimeOutput 方法。PrimeOutput 方法會依序呼叫下列方法：

1. 您在 ScriptMain 中覆寫以便從資料來源將資料列加入輸出緩衝區的 CreateNewOutputRows 方法，一開始會是空的。

2. FinishOutputs 方法預設是空的。在 ScriptMain 中覆寫此方法以執行完成輸出所需的處理。

3. 私用 MarkOutputsAsFinished 方法 (呼叫 ScriptBuffer 父類別的 SetEndOfRowset 方法) 用以指出輸出已完成的資料流程引擎。在自己的程式碼中不必明確地呼叫 SetEndOfRowset。

為了完成建立自訂來源元件，您可能會想要以 ScriptMain 類別中提供的下列方法來撰寫指令碼。

1. 覆寫 AcquireConnections 方法以連接至外部資料來源。從連接管理員擷取連接物件，或是必要的連接資訊。

2. 如果您可以同時載入所有的來源資料，請覆寫 PreExecute 方法以載入資料。例如，您可以針對連至 SQL Server 資料庫的 ADO.NET 連接，執行 SqlCommand，並同時將所有的來源資料載入 SqlDataReader。如果您必須一次載入一個資料列的來源資料 (例如，在讀取文字檔時)，可以在 CreateNewOutputRows 中循環使用資料列時載入資料。

3. 使用覆寫的 CreateNewOutputRows 方法將新資料列加入空的輸出緩衝區，並將新輸出資料列中的每個資料行填入值。使用每個輸出緩衝區的 AddRow 方法，加入空的新資料列，然後設定每個資料行的值。通常您會複製從外部來源載入的資料行值。

4. 覆寫 PostExecute 方法以完成處理資料。例如，您可以關閉用以載入資料的 SqlDataReader。

5. 視需要，覆寫 ReleaseConnections 方法從外部資料來源中斷連接。

這個範例示範一個來源元件，它使用現有的 ADO.NET 連接管理員，從 SQL Server 資料表將資料載入資料流程。

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

1. 建立一個 ADO.NET 連接管理員，以使用 SqlClient 提供者連接到 AdventureWorks 資料庫。

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

3. 開啟 [指令碼轉換編輯器]。在 [輸入及輸出] 頁面上，以更具描述性的名稱重新命名預設輸出，例如 MyAddressOutput，以及加入和設定兩個輸出資料行：AddressID 與 City。

4. 在 [連接管理員] 頁面上，加入或建立 ADO.NET 連接管理員，並指定一個名稱，例如 MyADONETConnection。

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

6. 建立和設定目的地元件，例如 SQL Server 目的地，或是在Creating a Destination with the Script Component中所示範的範例目的地元件，它需要 AddressID 與 City 資料行。然後將來源元件連接到目的地 (不需要任何轉換，就可以直接將來源連接到目的地)。您可以在 AdventureWorks 資料庫中執行下列 Transact-SQL 命令，以建立目的地資料表：

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

7. 執行範例。

   Imports System.Data.SqlClient
   ...
   Public Class ScriptMain
       Inherits UserComponent
   
       Dim connMgr As IDTSConnectionManager100
       Dim sqlConn As SqlConnection
       Dim sqlReader As SqlDataReader
   
       Public Overrides Sub AcquireConnections(ByVal Transaction As Object)
   
           connMgr = Me.Connections.MyADONETConnection
           sqlConn = CType(connMgr.AcquireConnection(Nothing), SqlConnection)
   
       End Sub
   
       Public Overrides Sub PreExecute()
   
           Dim cmd As New SqlCommand("SELECT AddressID, City, StateProvinceID FROM Person.Address", sqlConn)
           sqlReader = cmd.ExecuteReader
   
       End Sub
   
       Public Overrides Sub CreateNewOutputRows()
   
           Do While sqlReader.Read
               With MyAddressOutputBuffer
                   .AddRow()
                   .AddressID = sqlReader.GetInt32(0)
                   .City = sqlReader.GetString(1)
               End With
           Loop
   
       End Sub
   
       Public Overrides Sub PostExecute()
   
           sqlReader.Close()
   
       End Sub
   
       Public Overrides Sub ReleaseConnections()
   
           connMgr.ReleaseConnection(sqlConn)
   
       End Sub
   
   End Class
   

   using System.Data.SqlClient;
   public class ScriptMain:
       UserComponent
   
   {
       IDTSConnectionManager100 connMgr;
       SqlConnection sqlConn;
       SqlDataReader sqlReader;
   
       public override void AcquireConnections(object Transaction)
       {
           connMgr = this.Connections.MyADONETConnectionManager;
           sqlConn = (SqlConnection)connMgr.AcquireConnection(null);
   
       }
   
       public override void PreExecute()
       {
   
           SqlCommand cmd = new SqlCommand("SELECT AddressID, City, StateProvinceID FROM Person.Address", sqlConn);
           sqlReader = cmd.ExecuteReader();
   
       }
   
       public override void CreateNewOutputRows()
       {
   
           while (sqlReader.Read())
           {
               {
                   MyAddressOutputBuffer.AddRow();
                   MyAddressOutputBuffer.AddressID = sqlReader.GetInt32(0);
                   MyAddressOutputBuffer.City = sqlReader.GetString(1);
               }
           }
   
       }
   
       public override void PostExecute()
       {
   
           sqlReader.Close();
   
       }
   
       public override void ReleaseConnections()
       {
   
           connMgr.ReleaseConnection(sqlConn);
   
       }
   
   }
   

這個範例示範一個來源元件，它使用現有的一般檔案連接管理員，從一般檔案將資料載入資料流程。透過從 SQL Server 將它匯出，就會建立一般檔案來源資料。

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

1. 使用 SQL Server 匯入和匯出精靈從 AdventureWorks 範例資料庫將 Person.Address 資料表匯出至以逗號分隔的一般檔案。這個範例使用的檔案名稱為 ExportedAddresses.txt。

2. 建立一般檔案連接管理員以連接至匯出的資料檔案。

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

4. 開啟 [指令碼轉換編輯器]。在 [輸入及輸出] 頁面上，以更具描述性的名稱重新命名預設輸出，例如 MyAddressOutput。加入和設定兩個輸出資料行：AddressID 與 City。

5. 在 [連接管理員] 頁面上，使用更具描述性的名稱 (例如 MyFlatFileSrcConnectionManager) 以加入或建立一般檔案連接管理員。

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

7. 建立和設定目的地元件，例如 SQL Server 目的地，或是在Creating a Destination with the Script Component中所示範的範例目的地元件。然後將來源元件連接到目的地 (不需要任何轉換，就可以直接將來源連接到目的地)。您可以在 AdventureWorks 資料庫中執行下列 Transact-SQL 命令，以建立目的地資料表：

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

8. 執行範例。

   Imports System.IO
   ...
   Public Class ScriptMain
       Inherits UserComponent
   
       Private textReader As StreamReader
       Private exportedAddressFile As String
   
       Public Overrides Sub AcquireConnections(ByVal Transaction As Object)
   
           Dim connMgr As IDTSConnectionManager100 = _
               Me.Connections.MyFlatFileSrcConnectionManager
           exportedAddressFile = _
               CType(connMgr.AcquireConnection(Nothing), String)
   
       End Sub
   
       Public Overrides Sub PreExecute()
           MyBase.PreExecute()
           textReader = New StreamReader(exportedAddressFile)
       End Sub
   
       Public Overrides Sub CreateNewOutputRows()
   
           Dim nextLine As String
           Dim columns As String()
   
           Dim delimiters As Char()
           delimiters = ",".ToCharArray
   
           nextLine = textReader.ReadLine
           Do While nextLine IsNot Nothing
               columns = nextLine.Split(delimiters)
               With MyAddressOutputBuffer
                   .AddRow()
                   .AddressID = columns(0)
                   .City = columns(3)
               End With
               nextLine = textReader.ReadLine
           Loop
   
       End Sub
   
       Public Overrides Sub PostExecute()
           MyBase.PostExecute()
           textReader.Close()
   
       End Sub
   
   End Class
   

   using System.IO;
   public class ScriptMain:
       UserComponent
   
   {
       private StreamReader textReader;
       private string exportedAddressFile;
   
       public override void AcquireConnections(object Transaction)
       {
   
           IDTSConnectionManager100 connMgr = this.Connections.MyFlatFileSrcConnectionManager;
           exportedAddressFile = (string)connMgr.AcquireConnection(null);
   
       }
   
       public override void PreExecute()
       {
           base.PreExecute();
           textReader = new StreamReader(exportedAddressFile);
       }
   
       public override void CreateNewOutputRows()
       {
   
           string nextLine;
           string[] columns;
   
           char[] delimiters;
           delimiters = ",".ToCharArray();
   
           nextLine = textReader.ReadLine();
           while (nextLine != null)
           {
               columns = nextLine.Split(delimiters);
               {
                   MyAddressOutputBuffer.AddRow();
                   MyAddressOutputBuffer.AddressID = columns[0];
                   MyAddressOutputBuffer.City = columns[3];
               }
               nextLine = textReader.ReadLine();
           }
   
       }
   
       public override void PostExecute()
       {
   
           base.PostExecute();
           textReader.Close();
   
       }
   
   }