DFT 中的脚本任务未执行答案

【问题标题】：Script task in DFT doesnt get excecutedDFT 中的脚本任务未执行
【发布时间】：2012-12-18 20:58:56
【问题描述】：

我有一个场景，我必须从未知的 excel 文件及其未知的选项卡中获取数据。所以我创建了一个有 50 列的表。

问题是进入第二个循环后 ssis 包没有进行。第一个循环获取文件名，第二个循环获取该文件中的选项卡名称。第二个循环中的 DTF 打开 excel 文件选项卡并读取数据并将其写入数据库表

我创建了一个单独的变量来存储从 foreach 循环容器中检索的文件名和选项卡名，并在 DTF 任务中使用它们。甚至比 DFT 任务也能顺利完成。

在 DFT 内部，我只有一个脚本源来打开 excel 文件并读取数据，然后将其传递给 oledb 目标。

在厌倦了所有奇怪的事情之后，现在循环处理 DFT 任务。在 DFT 上方的 foreach 循环中，我放置了一个脚本任务并弹出了一些测试。 MessageBox.Show("blabla")。及其工作。现在怎么办？

下面是脚本任务中的代码。

public class ScriptMain : UserComponent
{
    private OleDbDataReader excelReader;
    private OleDbConnection excelConnection;
    private OleDbCommand excelCommand;
    public override void PreExecute()
    {
        base.PreExecute();
        // Open 
        GetDataFromExcelToReader(Variables.IndividualFileNamesForDFT, Variables.IndividualTabNamesForDFT);
    }
    public override void PostExecute()
    {
        base.PostExecute();
        excelReader.Close();
        excelConnection.Close();
    }
    private void GetDataFromExcelToReader(string p_strFileName, string p_strTabName)
    {
        string l_strConnectionString;
        if (File.Exists(p_strFileName))
        {
            string extension = Path.GetExtension(p_strFileName);
            extension = extension.Replace(".", "");
            if (extension.ToLower() == "xlsx")
            {
                l_strConnectionString = "Provider=Microsoft.ACE.OLEDB.12.0;" +
                "Data Source=" + p_strFileName + ";Extended Properties=\"Excel 12.0;HDR=NO;IMEX=1\";";
            }
            else
            {
                l_strConnectionString = "Provider=Microsoft.Jet.OLEDB.4.0;" +
                    "Data Source=" + p_strFileName + ";Extended Properties=\"Excel 4.0;HDR=NO;IMEX=1\";";
            }
            excelConnection = new OleDbConnection(l_strConnectionString);
            excelConnection.Open();
            excelCommand = excelConnection.CreateCommand();
            excelCommand.CommandText = "SELECT * FROM [" + p_strTabName + "A1:AX1048576]";
            excelCommand.CommandType = CommandType.Text;
            excelReader = excelCommand.ExecuteReader();
        }
    }
    public override void CreateNewOutputRows()
    {
        int counter = 0;
        while (excelReader.Read())
        {
                Output0Buffer.AddRow();
                Output0Buffer.FileName = Variables.IndividualFileNamesForDFT.ToString();
                Output0Buffer.TabName = Variables.IndividualTabNamesForDFT.ToString();
                Output0Buffer.Col1 = excelReader.FieldCount > 0 ? excelReader[0].ToString() : null;
                Output0Buffer.Col2 = excelReader.FieldCount > 1 ? excelReader[1].ToString() : null;
                Output0Buffer.Col3 = excelReader.FieldCount > 2 ? excelReader[2].ToString() : null;
                Output0Buffer.Col4 = excelReader.FieldCount > 3 ? excelReader[3].ToString() : null;
                Output0Buffer.Col5 = excelReader.FieldCount > 4 ? excelReader[4].ToString() : null;
                Output0Buffer.Col6 = excelReader.FieldCount > 5 ? excelReader[5].ToString() : null;
                Output0Buffer.Col7 = excelReader.FieldCount > 6 ? excelReader[6].ToString() : null;
                Output0Buffer.Col8 = excelReader.FieldCount > 7 ? excelReader[7].ToString() : null;
                Output0Buffer.Col9 = excelReader.FieldCount > 8 ? excelReader[8].ToString() : null;
                Output0Buffer.Col10 = excelReader.FieldCount > 9 ? excelReader[9].ToString() : null;
                Output0Buffer.Col11 = excelReader.FieldCount > 10 ? excelReader[10].ToString() : null;
                Output0Buffer.Col12 = excelReader.FieldCount > 11 ? excelReader[11].ToString() : null;
                Output0Buffer.Col13 = excelReader.FieldCount > 12 ? excelReader[12].ToString() : null;
                Output0Buffer.Col14 = excelReader.FieldCount > 13 ? excelReader[13].ToString() : null;
                Output0Buffer.Col15 = excelReader.FieldCount > 14 ? excelReader[14].ToString() : null;
                Output0Buffer.Col16 = excelReader.FieldCount > 15 ? excelReader[15].ToString() : null;
                Output0Buffer.Col17 = excelReader.FieldCount > 16 ? excelReader[16].ToString() : null;
                Output0Buffer.Col18 = excelReader.FieldCount > 17 ? excelReader[17].ToString() : null;
                Output0Buffer.Col19 = excelReader.FieldCount > 18 ? excelReader[18].ToString() : null;
                Output0Buffer.Col20 = excelReader.FieldCount > 19 ? excelReader[19].ToString() : null;
                Output0Buffer.Col21 = excelReader.FieldCount > 20 ? excelReader[20].ToString() : null;
                Output0Buffer.Col22 = excelReader.FieldCount > 21 ? excelReader[21].ToString() : null;
                Output0Buffer.Col23 = excelReader.FieldCount > 22 ? excelReader[22].ToString() : null;
                Output0Buffer.Col24 = excelReader.FieldCount > 23 ? excelReader[23].ToString() : null;
                Output0Buffer.Col25 = excelReader.FieldCount > 24 ? excelReader[24].ToString() : null;
                Output0Buffer.Col26 = excelReader.FieldCount > 25 ? excelReader[25].ToString() : null;
                Output0Buffer.Col27 = excelReader.FieldCount > 26 ? excelReader[26].ToString() : null;
                Output0Buffer.Col28 = excelReader.FieldCount > 27 ? excelReader[27].ToString() : null;
                Output0Buffer.Col29 = excelReader.FieldCount > 28 ? excelReader[28].ToString() : null;
                Output0Buffer.Col30 = excelReader.FieldCount > 29 ? excelReader[29].ToString() : null;
                Output0Buffer.Col31 = excelReader.FieldCount > 30 ? excelReader[30].ToString() : null;
                Output0Buffer.Col32 = excelReader.FieldCount > 31 ? excelReader[31].ToString() : null;
                Output0Buffer.Col33 = excelReader.FieldCount > 32 ? excelReader[32].ToString() : null;
                Output0Buffer.Col34 = excelReader.FieldCount > 33 ? excelReader[33].ToString() : null;
                Output0Buffer.Col35 = excelReader.FieldCount > 34 ? excelReader[34].ToString() : null;
                Output0Buffer.Col36 = excelReader.FieldCount > 35 ? excelReader[35].ToString() : null;
                Output0Buffer.Col37 = excelReader.FieldCount > 36 ? excelReader[36].ToString() : null;
                Output0Buffer.Col38 = excelReader.FieldCount > 37 ? excelReader[37].ToString() : null;
                Output0Buffer.Col39 = excelReader.FieldCount > 38 ? excelReader[38].ToString() : null;
                Output0Buffer.Col40 = excelReader.FieldCount > 39 ? excelReader[39].ToString() : null;
                Output0Buffer.Col41 = excelReader.FieldCount > 40 ? excelReader[40].ToString() : null;
                Output0Buffer.Col42 = excelReader.FieldCount > 41 ? excelReader[41].ToString() : null;
                Output0Buffer.Col43 = excelReader.FieldCount > 42 ? excelReader[42].ToString() : null;
                Output0Buffer.Col44 = excelReader.FieldCount > 43 ? excelReader[43].ToString() : null;
                Output0Buffer.Col45 = excelReader.FieldCount > 44 ? excelReader[44].ToString() : null;
                Output0Buffer.Col46 = excelReader.FieldCount > 45 ? excelReader[45].ToString() : null;
                Output0Buffer.Col47 = excelReader.FieldCount > 46 ? excelReader[46].ToString() : null;
                Output0Buffer.Col48 = excelReader.FieldCount > 47 ? excelReader[47].ToString() : null;
                Output0Buffer.Col49 = excelReader.FieldCount > 48 ? excelReader[48].ToString() : null;
                Output0Buffer.Col50 = excelReader.FieldCount > 49 ? excelReader[49].ToString() : null;
        }
    }
}

【问题讨论】：

您能否发布数据流脚本组件的代码，因为这似乎是卡住的地方
@lynamc 嗨，我在脚本任务中发布了代码
如果您有包裹的屏幕截图会有所帮助。这是你的图表的样子吗？ [Foreach 循环容器（文件枚举器）获取 excel 文档文件名列表] --> [Foreach 循环容器（项目/ADO 枚举器）通过列表并为每个 excel 文档尝试获取选项卡/工作表名称]。您的代码在第二个 Foreach 容器中运行？
@booyaa 我上传了图片，但这里没有显示。流程在这里 Foreach 循环（循环 excel 文件）-> 脚本任务（打开 excel 文件并获取选项卡）-> Foreach 循环（循环选项卡）-> DFT 任务 [脚本任务（打开 excel 文件）-> Oledb dest（加载数据表） )]

标签： ssis

【解决方案1】：

您真的需要阅读 A1:AX1048576 吗？它会处理这个并且只读取它需要的内容吗？

您可以尝试只读取您需要的 excel 文件的部分吗？例如，如果您有一个包含 10 列和 400 行的 excel 文件，请尝试读取 A1:Z9999 - 想知道脚本任务是否只是因为试图将所有这些内容放入内存而陷入困境，然后由于结果集非常巨大而将其丢弃到磁盘。 .

【讨论】：

是的，我倾向于同意 cairnz 的观点。实际上 where 根本不需要指定范围。你可以简单地说“SELECT * FROM [” + p_strTabName + “]”
因为我不知道行数，所以我考虑了所有行。但这不是问题。即使将行限制为 100，它仍然没有处理
哦，还有，只是作为一个有趣的问题。无需引用 Microsoft.Jet.OLEDB.4.0，因为 Microsoft.ACE.OLEDB.12.0 提供程序将很好地读取 xls 文件。但这不会导致您出现问题。我避免使用脚本组件，因为它们无法调试。但是，您可以在消息框中显示调试消息以查看它挂在哪里。
@lynamc 在处理完所有奇怪的事情之后，foreach 循环中的 DFT 任务现在已经完成了。在 DFT 上方的 foreach 循环中，我放置了一个脚本任务并弹出了一些测试。 MessageBox.Show("blabla")。及其工作。
这没有意义，你不能把它留在那里。你有什么改变吗？

【解决方案2】：

@Ciaran - 谢谢，插入选择特定范围只需打开完整选项卡即可解决我的问题。 "SELECT * FROM [" + p_strTabName + "]"

【讨论】：