项目
12/14/2010

使用脚本组件创建源

Integration Services 包的数据流中的源组件用于从数据源加载数据以传递到下游转换和目标。通常通过现有连接管理器连接数据源。

有关脚本组件的概述，请参阅用脚本组件扩展数据流。

脚本组件及其生成的基础结构代码可以大大简化自定义数据流组件的开发过程。但要了解脚本组件的工作原理，熟悉自定义数据流组件的开发步骤很有帮助。请参阅开发自定义数据流组件一节，特别是开发自定义源组件主题。

开始一个源组件

向 SSIS 设计器的“数据流”窗格添加脚本组件时，“选择脚本组件类型”对话框将打开并提示您选择“源”、“目标”或“转换”脚本。在此对话框中选择“源”。

在元数据设计模式下配置源组件

选择创建源组件后，可使用**“脚本转换编辑器”**配置该组件。有关详细信息，请参阅在脚本组件编辑器中配置脚本组件。

数据流源组件没有输入，支持一个或多个输出。在编写自定义脚本之前，必须在元数据设计模式下完成的一个步骤是使用**“脚本转换编辑器”**配置组件的输出。

还可以在**“脚本转换编辑器”的“脚本”**页上设置 ScriptLanguage 属性来指定脚本语言。

注意
若要设置脚本组件和脚本任务的默认脚本语言，请使用“选项”对话框的“常规”页上的“脚本语言”选项。有关详细信息，请参阅“常规”页。

添加连接管理器

源组件通常使用现有连接管理器连接将其中的数据加载到数据流的数据源。在**“脚本转换编辑器”的“连接管理器”页中，单击“添加”**以添加适当的连接管理器。

但是，连接管理器只是一个封装和存储连接特定类型数据源必需信息的便利单元。您必须编写自己的自定义代码才能加载或保存数据，并且才有可能打开和关闭与数据源的连接。

有关如何在脚本组件中使用连接管理器的常规信息，请参阅在脚本组件中连接数据源。

有关**“脚本转换编辑器”的“连接管理器”**页的详细信息，请参阅脚本转换编辑器（“连接管理器”页）。

配置输出和输出列

源组件没有输入，支持一个或多个输出。在**“脚本转换编辑器”的“输入和输出”**页中，默认情况下已创建一个输出，但是还没有创建任何输出列。在编辑器的这一页，可能需要或希望配置以下各项。

必须为每个输出手动添加和配置输出列。选择每个输出的“输出列”文件夹，然后使用**“添加列”和“删除列”**按钮管理源组件的每个输出的输出列。随后，将使用在自动生成的代码中创建的类型化取值函数属性，在脚本中通过您在此处指定的名称来引用输出列。

您可能希望创建一个或多个附加输出，如包含意外值的行的模拟错误输出。使用**“添加输出”和“删除输出”**按钮可以管理源组件的输出。所有输入行都定向到所有可用输出，除非您还为以下一些输出的 ExclusionGroup 属性指定了相同的非零值，您要在这些输出中将每一行只定向到共享同一 ExclusionGroup 值的输出之一。用于标识 ExclusionGroup 的所选特定整数值没有特殊要求。

注意
当您不希望输出所有行时，还可以对单个输出使用非零 ExclusionGroup 属性值。但是，在这种情况下，必须为希望发送给输出的每一行显式调用 DirectRowTo<outputbuffer> 方法。

您可以为输出指定一个友好名称。随后，将使用在自动生成的代码中创建的类型化取值函数属性，在脚本中通过输出的名称来引用输出。
通常，同一 ExclusionGroup 中的多个输出具有相同的输出列。但是，如果要创建模拟的错误输出，则可能要添加多个列来存储错误信息。有关数据流引擎如何处理错误行的信息，请参阅在数据流组件中使用错误输出。但是，在脚本组件中，必须编写您自己的代码以便使用适当的错误信息填充这些附加列。有关详细信息，请参阅模拟脚本组件的错误输出。

有关**“脚本转换编辑器”的“输入和输出”**页的详细信息，请参阅脚本转换编辑器（“输入和输出”页）。

添加变量

如果要在脚本中使用任何现有变量的值，可以在**“脚本转换编辑器”的“脚本”**页上的 ReadOnlyVariables 和 ReadWriteVariables 属性字段中添加这些变量。

在属性字段中输入多个变量时，请用逗号将变量名隔开。您还可以输入多个变量，方法是单击 ReadOnlyVariables 和 ReadWriteVariables 属性字段旁的省略号 (…) 按钮，然后在**“选择变量”**对话框中选择变量。

有关如何在脚本组件中使用变量的常规信息，请参阅在脚本组件中使用变量。

有关**“脚本转换编辑器”的“脚本”**页的详细信息，请参阅脚本转换编辑器（“脚本”页）。

在代码设计模式下编写源组件脚本

为组件配置完元数据后，可以打开 MicrosoftVisual Studio Tools for Applications (VSTA) IDE 编写自定义脚本的代码。若要打开 VSTA，请在**“脚本转换编辑器”的“脚本”页中，单击“编辑脚本”**。可使用 MicrosoftVisual Basic 2008 或 MicrosoftVisual C# 2008 编写您的脚本，具体取决于为 ScriptLanguage 属性选择的脚本语言。

有关适用于使用脚本组件创建的所有类型组件的重要信息，请参阅脚本组件的编码和调试。

了解自动生成的代码

创建并配置源组件后打开 VSTA IDE 时，可编辑的 ScriptMain 类将显示在代码编辑器中。您将在 ScriptMain 类中编写您的自定义代码。

ScriptMain 类包含 CreateNewOutputRows 方法的存根。CreateNewOutputRows 是源组件中最重要的方法。

如果在 VSTA 中打开**“项目资源管理器”**窗口，可以看到脚本组件还生成了只读的 BufferWrapper 和 ComponentWrapper 项目项。ScriptMain 类从 ComponentWrapper 项目项中的 UserComponent 类继承。

在运行时，数据流引擎调用 UserComponent 类中的 PrimeOutput 方法，该方法重写 ScriptComponent 父类的 PrimeOutput 方法。PrimeOutput 方法又调用下列方法：

CreateNewOutputRows 方法，在 ScriptMain 中要重写该方法，以将数据源中的行添加到最初为空的输出缓冲区中。
FinishOutputs 方法，默认情况下，该方法为空。在 ScriptMain 中要重写此方法，以执行完成输出所需的任何处理。
私有的 MarkOutputsAsFinished 方法，该方法调用 ScriptBuffer 父类的 SetEndOfRowset 方法来向数据流引擎指示输出已完成。您无需在自己的代码中显式调用 SetEndOfRowset。

编写自定义代码

为了完成创建自定义源组件，您可以在 ScriptMain 类的以下方法中编写脚本。

重写 AcquireConnections 方法以连接外部数据源。从连接管理器中提取连接对象或者需要的连接信息。
如果可同时加载所有源数据，请重写 PreExecute 方法以加载数据。例如，可以对连接到 SQL Server 数据库的 ADO.NET 连接执行 SqlCommand，然后同时将所有源数据加载到 SqlDataReader 中。如果必须每次加载一行源数据（例如，读取文本文件时），则可在 CreateNewOutputRows 中遍历行时加载数据。
使用重写的 CreateNewOutputRows 方法将新行添加到空的输出缓冲区中，然后在新输出行的每列中填充值。使用每个输出缓冲区的 AddRow 方法来添加空的新行，然后设置每列的值。通常，从外部源所加载的列复制值。
重写 PostExecute 方法以完成数据处理。例如，可以关闭用于加载数据的 SqlDataReader。
如果需要，重写 ReleaseConnections 方法以断开与外部数据源的连接。

示例

下面的示例演示在 ScriptMain 类中创建源组件所需的自定义代码。

注意
这些示例使用 AdventureWorks 示例数据库中的 Person.Address 表并在数据流中传递它的第一个和第四个列，即 intAddressID 和 nvarchar(30)City 列。在本节中，在源、转换和目标示例中使用相同的数据。每个示例的其他前提条件和假设都记录在文档中。

ADO.NET 源示例

本示例演示了使用现有 ADO.NET 连接管理器将 SQL Server 表中的数据加载到数据流中的源组件。

如果要运行此示例代码，必须按照如下方式配置包和组件：

创建使用 SqlClient 访问接口连接 AdventureWorks 数据库的 ADO.NET 连接管理器。
向数据流设计器图面添加新的脚本组件并将其配置为源。
打开**“脚本转换编辑器”。在“输入和输出”**页中，用更具说明性的名称（如 MyAddressOutput）重命名默认输出，然后添加并配置两个输出列 AddressID 和 City。
在**“连接管理器”**页中，添加或创建 ADO.NET 连接管理器，并以诸如 MyADONETConnection 的名称命名。
在**“脚本”页中，单击“编辑脚本”并输入下面的脚本。然后关闭脚本开发环境和“脚本转换编辑器”**。
创建并配置目标组件，如 SQL Server 目标，或者使用脚本组件创建目标中演示的示例目标组件，该组件需要 AddressID 和 City 列。然后将源组件连接到目标。（可以将源直接连接到目标，而不经任何转换。）在 AdventureWorks 数据库中运行以下 Transact-SQL 命令，以创建目标表：
```
CREATE TABLE [Person].[Address2](
    [AddressID] [int] NOT NULL,
    [City] [nvarchar](30) NOT NULL
)
```

运行该示例。

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 中导出来创建该数据。

如果要运行此示例代码，必须按照如下方式配置包和组件：

使用 SQL Server 导入和导出向导将 Person.Address 表从 AdventureWorks 示例数据库导出到以逗号分隔的平面文件。此示例使用文件名 ExportedAddresses.txt。
创建连接导出的数据文件的平面文件连接管理器。
向数据流设计器图面添加新的脚本组件并将其配置为源。
打开**“脚本转换编辑器”。在“输入和输出”**页中，用更具说明性的名称（如 MyAddressOutput）重命名默认输出。添加并配置两个输出列 AddressID 和 City。
在**“连接管理器”**页中，添加或创建平面文件连接管理器，并以说明性的名称命名，如 MyFlatFileSrcConnectionManager。
在**“脚本”页中，单击“编辑脚本”并输入下面的脚本。然后关闭脚本开发环境和“脚本转换编辑器”**。
创建并配置目标组件，如 SQL Server 目标，或者使用脚本组件创建目标中演示的示例目标组件。然后将源组件连接到目标。（可以将源直接连接到目标，而不经任何转换。）在 AdventureWorks 数据库中运行以下 Transact-SQL 命令，以创建目标表：
```
CREATE TABLE [Person].[Address2](
    [AddressID] [int] NOT NULL,
    [City] [nvarchar](30) NOT NULL
)
```

运行该示例。

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();

    }

}

使 Integration Services 保持最新

若要从 Microsoft 获得最新的下载内容、文章、示例和视频，以及从社区获得所选解决方案，请访问 MSDN 或 TechNet 上的 Integration Services 页：

若要获得有关这些更新的自动通知，请订阅该页上提供的 RSS 源。

请参阅

概念

使用脚本组件创建目标

开发自定义源组件

通过