如何写入脚本组件中的变量

Question

我想使用 C# 使用脚本组件向包中的变量写入一个值。

目前我正在使用这些代码：

public class ScriptMain : UserComponent
{
string s, r, m;   
public override void PreExecute()
{
    base.PreExecute();

}

public override void PostExecute()
{
    base.PostExecute();

    Variables.SNumber = s;
    Variables.RNumber = r;
    Variables.MNumber = m;       
   }

public override void Input0_ProcessInputRow(Input0Buffer Row)
{


    if (Row.Col1.Equals("MyName"))
    {

       s = Row.Column4.Substring(122, 5).Trim();
       r  = Row.Column8.Substring(5, 14).Trim();
       m = Row.Column8.Substring(66, 4).Trim() + "." + Row.Column8.Substring(70,  
              2).Trim();   
   }     

}

}

SNumber、Mnumber 和 RNumber 是包中的全局变量。在脚本组件之后，我使用派生列来分配值。 但变量没有价值。请帮助我。 谢谢

Answer 1

看来这是数据流任务中的脚本组件。不幸的是，你不能在这个意义上使用变量。您要么必须创建逐行保留这些值的列，要么必须发挥创意。

这里的一种方法是将数据流通过管道传输到记录集目标，创建对象类型的变量，以及用于保存此数据流中所需的每一列的变量。然后，您可以对现在存储在 Object 变量中的 Recordset 目标使用 Foreach 循环。如果您需要逐行执行某些操作，而该操作本身不是数据流，那么您现在就可以实现这一点，因为数据流任务会为每一行调用一次。 （这很麻烦，并且更适合您以外的其他需求）

您应该能够在派生列中实现上面想要做的事情。

数据流中的脚本组件参考：http://msdn.microsoft.com/en -us/library/aa337079.aspx

Answer 2

您在问题中尝试实现的过程可以借助脚本组件转换任务中的输出列来完成，而不是使用变量。下面的示例解释了如何实现这一点，并演示了如何在脚本组件中使用变量。不过，使用派生列转换任务也可以实现相同的功能。

此示例读取 CSV 文件，并根据第一列值，从给定位置和长度开始从第二列中提取值。所有这些值都将存储在一个变量中。

分步过程：

1. 创建一个 CSV 文件，如屏幕截图 #1 所示。如果第一列的值为 Customer，我们将从第二列值的第 9 个字符中提取 6 个字符。如果第一列的值为 Vendor，我们将从第二列值的 21 字符中提取 7 个字符。对于每个其他值，程序包将假定第二列值为零。

2. 使用SQL 脚本部分下的脚本创建一个名为dbo.Destination的表。该包会将 CSV 数据插入到该表中。

3. 在 SSIS 包上，创建 6 个变量，如屏幕截图 #2 所示。配置 OLE DB 连接 以连接到 SQL Server 实例。配置平面文件连接以读取 CSV 文件，如屏幕截图 #3 - #6 所示。另外，将数据流任务放置在包的控制流选项卡上。

4. 使用平面文件源、脚本组件转换任务（请参阅屏幕截图#7）和配置数据流选项卡OLE DB 目标。

5. 配置平面文件源任务，如屏幕截图#8和#9所示。

6. 配置脚本组件转换任务，如屏幕截图#10和#11所示。创建一个名为 SNumber 数据类型为四字节有符号整数 [DT_I4] 的新输出列来存储提取的值。将脚本组件代码替换为脚本组件代码部分下显示的代码。 PreExecute 方法读取包变量的值，Input0_ProcessInputRow 方法处理逻辑以填充输出列 SNumber。

7. 配置 OLE DB 目标 任务，如屏幕截图 #12 和 #13 所示。

8. 屏幕截图 #14 显示示例包执行。

9. Screenshot #15 显示包执行后表 dbo.Destination 中的数据。

希望有帮助。

SQL 脚本：
。

CREATE TABLE [dbo].[Destination](
    [Id] [int] IDENTITY(1,1) NOT NULL,
    [Header] [varchar](50) NOT NULL,
    [Value] [varchar](50) NOT NULL,
    [SNumber] [int] NOT NULL,
 CONSTRAINT [PK_Destination] PRIMARY KEY CLUSTERED ([Id] ASC)) ON [PRIMARY]
GO

脚本组件代码：

C#代码，只能在SSIS 2008及更高版本中使用。
。

/* Microsoft SQL Server Integration Services Script Component
*  Write scripts using Microsoft Visual C# 2008.
*  ScriptMain is the entry point class of the script.*/

using System;
using System.Data;
using Microsoft.SqlServer.Dts.Pipeline.Wrapper;
using Microsoft.SqlServer.Dts.Runtime.Wrapper;

[Microsoft.SqlServer.Dts.Pipeline.SSISScriptComponentEntryPointAttribute]
public class ScriptMain : UserComponent
{
    IDTSVariables100 varCollection = null;
    string customer = string.Empty;
    int customerPosition = 0;
    int customerLength = 0;
    string vendor = string.Empty;
    int vendorPosition = 0;
    int vendorLength = 0;

    public override void PreExecute()
    {
        this.VariableDispenser.LockForRead("User::Customer");
        this.VariableDispenser.LockForRead("User::CustomerPosition");
        this.VariableDispenser.LockForRead("User::CustomerLength");
        this.VariableDispenser.LockForRead("User::Vendor");
        this.VariableDispenser.LockForRead("User::VendorPosition");
        this.VariableDispenser.LockForRead("User::VendorLength");
        this.VariableDispenser.GetVariables(out varCollection);

        customer = varCollection["User::Customer"].Value.ToString();
        customerPosition = Convert.ToInt32(varCollection["User::CustomerPosition"].Value);
        customerLength = Convert.ToInt32(varCollection["User::CustomerLength"].Value);
        vendor = varCollection["User::Vendor"].Value.ToString();
        vendorPosition = Convert.ToInt32(varCollection["User::VendorPosition"].Value);
        vendorLength = Convert.ToInt32(varCollection["User::VendorLength"].Value);

        base.PreExecute();
    }

    public override void PostExecute()
    {
        base.PostExecute();
    }

    public override void Input0_ProcessInputRow(Input0Buffer Row)
    {
        if (Row.Header.ToString().Trim() == customer)
        {
            Row.SNumber = Convert.ToInt32(Row.Value.Substring(customerPosition, customerLength));
        }
        else if (Row.Header.ToString().Trim() == vendor)
        {
            Row.SNumber = Convert.ToInt32(Row.Value.Substring(vendorPosition, vendorLength));
        }
        else
        {
            Row.SNumber = 0;
        }
    }

}

屏幕截图 #1：

屏幕截图 #2：

屏幕截图 #3：

屏幕截图 #4：

屏幕截图 #5 ：

屏幕截图#6：

屏幕截图 #7：

屏幕截图 #8：

屏幕截图 #9：

< img src="https://i.sstatic.net/uHbBE.png" alt="9">

屏幕截图 #10：

屏幕截图 #11：

屏幕截图#12:

屏幕截图 #13:

屏幕截图 #14:

屏幕截图 #15：

Answer 3

在转换编辑器上选择变量作为 ReadWriteVariable，然后使用以下代码：

this.ReadWriteVariables["User::YourVariable"].Value = "New Value";

Answer 4

看起来您可以在这里完全避免脚本组件，而只需使用派生列任务，为 SNumber、RNumber 和 MNumber 创建 3 个新列，并使用类似的表达式

[Col1]=="MyName" ? ltrim(Substring([Column4],122,5)) : NULL(DT_WSTR,5)

，依此类推。