使用脚本组件创建同步转换

转换组件具有一个输入。

在**“脚本转换编辑器”的“输入列”**页中，列列表显示数据流上游组件的输出中可用的列。选择要转换或传递的列。将要就地转换的所有列标记为读/写。

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

转换组件支持一个或多个输出。

在**“脚本转换编辑器”的“输入和输出”**页中，您可以看到已创建一个输出，但是还没有创建任何输出列。在编辑器的这一页，可能需要或希望配置以下各项。

• 创建一个或多个附加输出，如包含意外值的行的模拟错误输出。使用**“添加输出”和“删除输出”**按钮可以管理同步转换组件的输出。所有输入行都定向到所有可用输出，除非您表示希望将每一行重定向到一个输出或其他输出。您可通过为输出的 ExclusionGroup 属性指定一个非零的整数值来表示希望重定向行。在 ExclusionGroup 中输入的用于标识输出的特定整数值并不重要，但是您必须对指定的输出组使用同一个整数。

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

• 为输入和输出指定一个更具说明性的名称。脚本组件可以使用这些名称来生成类型化取值函数属性，这些属性用于在脚本中引用输入和输出。

• 对于同步转换，将列保持原样。通常，同步转换不会向数据流添加列。会在缓冲区中就地修改数据，然后将缓冲区传递到数据流的下一个组件中。如果是这种情况，您不需要对转换的输出显式添加和配置输出列。输出显示在编辑器中，并且不包含任何显式定义的列。

• 向行级错误的模拟错误输出添加新列。通常，同一 ExclusionGroup 中的多个输出具有一组相同的输出列。但是，如果要创建模拟的错误输出，则可能要添加多个列来包含错误信息。有关数据流引擎如何处理错误行的信息，请参阅在数据流组件中使用错误输出。请注意，在脚本组件中，必须编写您自己的代码以便使用适当的错误信息填充这些附加列。有关详细信息，请参阅模拟脚本组件的错误输出。

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

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

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

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

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

创建并配置转换组件后打开 VSTA IDE 时，可编辑的 ScriptMain 类将显示在代码编辑器中，其中有 ProcessInputRow 方法的存根。在 ScriptMain 类中可编写自定义代码，ProcessInputRow 是转换组件中最重要的方法。

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

在运行时，数据流引擎调用 UserComponent 类中的 ProcessInput 方法，该方法重写 ScriptComponent 父类的 ProcessInput 方法。而 ProcessInput 方法遍历输入缓冲区中的所有行并为每一行调用一次 ProcessInputRow 方法。

具有同步传输的转换组件是要编写的所有数据流组件中最简单的部分。例如，本主题中稍后演示的单个输出示例包含以下自定义代码：

    Row.City = UCase(Row.City)

    Row.City = (Row.City).ToUpper();

若要完成创建自定义同步转换组件，必须使用已重写的 ProcessInputRow 方法来转换输入缓冲区的每行中的数据。缓冲区写满后，数据流引擎会将此缓冲区传递给数据流中的下一个组件。

根据需要，您还可以在 ScriptMain 类中可用的 PreExecute 和 PostExecute 方法中编写脚本来执行预处理或最终处理。

将输入行定向到两个或多个可能的输出中的一个输出时所需的自定义代码比之前讨论的单个输出方案所需的代码要少得多。例如，本主题中稍后演示的两个输出示例包含以下自定义代码：

 [Visual Basic]
    Row.City = UCase(Row.City)
    If Row.City = "REDMOND" Then
        Row.DirectRowToMyRedmondAddresses()
    Else
        Row.DirectRowToMyOtherAddresses()
    End If

 [C#]
        Row.City = (Row.City).ToUpper();

        if (Row.City=="REDMOND")
        {
            Row.DirectRowToMyRedmondAddresses();
        }
        else
        {
            Row.DirectRowToMyOtherAddresses();
        }

在此示例中，脚本组件将基于已配置的输出的名称为您生成 DirectRowTo<OutputBufferX> 方法。您可以使用类似的代码将错误行定向到模拟的错误输出。

此示例演示具有单个输出的同步转换组件。此转换将传递 AddressID 列，并将 City 列转换为大写。

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

1. 向数据流设计器图面添加新的脚本组件并将其配置为转换。

2. 在 SSIS 设计器中将源或另一转换的输出连接到新转换组件。此输出应提供 AdventureWorks 示例数据库的 Person.Address 表中的数据，其中包含 AddressID 和 City 列。

3. 打开**“脚本转换编辑器”。在“输入列”**页中，选择 AddressID 和 City 列。将 City 列标记为读/写。

4. 在**“输入和输出”**页上，使用更具说明性的名称（如 MyAddressInput 和 MyAddressOutput）重命名输入和输出。请注意，输出的 SynchronousInputID 与输入的 ID 相对应。因此，您不需要添加和配置输出列。

5. 在**“脚本”页中，单击“编辑脚本”并输入下面的脚本。然后关闭脚本开发环境和“脚本转换编辑器”**。

6. 创建并配置目标组件，如 SQL Server 目标，或使用脚本组件创建目标中演示的示例目标组件，该目标组件需要 AddressID 和 City 列。然后，将转换的输出连接到目标组件。在 AdventureWorks 数据库中运行以下 Transact-SQL 命令，以创建目标表：

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

7. 运行该示例。

Public Class ScriptMain
    Inherits UserComponent

    Public Overrides Sub MyAddressInput_ProcessInputRow(ByVal Row As MyAddressInputBuffer)

        Row.City = UCase(Row.City)

    End Sub

End Class

 [C#]
public class ScriptMain:
    UserComponent

{
    public override void MyAddressInput_ProcessInputRow(MyAddressInputBuffer Row)
    {

        Row.City = (Row.City).ToUpper();

    }

}

此示例演示具有两个输出的同步转换组件。此转换将传递 AddressID 列，并将 City 列转换为大写。如果城市名为 Redmond，则将行定向到一个输出；将所有其他行定向到另一个输出。

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

1. 向数据流设计器图面添加新的脚本组件并将其配置为转换。

2. 在 SSIS 设计器中将源或另一转换的输出连接到新转换组件。此输出应提供 AdventureWorks 示例数据库的 Person.Address 表中的数据，其中至少包含 AddressID 和 City 列。

3. 打开**“脚本转换编辑器”。在“输入列”**页中，选择 AddressID 和 City 列。将 City 列标记为读/写。

4. 在**“输入和输出”**页中，创建第二个输出。添加新的输出后，请确保将该输出的 SynchronousInputID 设置为输入的 ID。已对第一个输出设置此属性，该输出是默认创建的。对于每个输出，将 ExclusionGroup 属性设置为同一非零值，以指示您将在两个互相排斥的输出间拆分输入行。无需向输出添加任何输出列。

5. 使用更具说明性的名称（如 MyAddressInput、MyRedmondAddresses 和 MyOtherAddresses）重命名输入和输出。

6. 在**“脚本”页中，单击“编辑脚本”并输入下面的脚本。然后关闭脚本开发环境和“脚本转换编辑器”**。

7. 创建并配置两个目标组件，如 SQL Server 目标、平面文件目标，或在使用脚本组件创建目标中演示的示例目标组件，这两个目标组件需要 AddressID 和 City 列。然后，将转换的每个输出连接到任一目标组件。可通过在 AdventureWorks 数据库中运行与下列命令（具有唯一表名）类似的 Transact-SQL 命令来创建目标表：

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

8. 运行该示例。

Public Class ScriptMain
    Inherits UserComponent

    Public Overrides Sub MyAddressInput_ProcessInputRow(ByVal Row As MyAddressInputBuffer)

        Row.City = UCase(Row.City)

        If Row.City = "REDMOND" Then
            Row.DirectRowToMyRedmondAddresses()
        Else
            Row.DirectRowToMyOtherAddresses()
        End If

    End Sub

End Class

public class ScriptMain:
    UserComponent

public override void MyAddressInput_ProcessInputRow(MyAddressInputBuffer Row)
    {

        Row.City = (Row.City).ToUpper();

        if (Row.City == "REDMOND")
        {
            Row.DirectRowToMyRedmondAddresses();
        }
        else
        {
            Row.DirectRowToMyOtherAddresses();
        }

    }
}