2

我正在尝试从将数据库表导出到平面文件的 SSIS 包中生成列“开始/长度”规范文档。Columns在从处理平面文件连接的 ConnectionManager 对象中获取属性时，我遇到了一些难题。我能够获得该Columns属性，但我无法对它做任何事情，因为我无法确定将其转换为的任何类型。如果我将它转换为 DTSProperty，我会在对象上获得非常少的有用属性。如果我将属性设为object，我只能确定它是System.__ComObject.

如何将 Columns 属性检索为一个有用的对象，希望是一个可以迭代的集合？

示例代码：

        DTSRT.Application dtap = new Application();
        DTSRT.Package pkg = dtap.LoadFromDtsServer(@"\MSDB\ExportSamples", "ERISIA", null);
        DTSRT.ConnectionManager ffcn = pkg.Connections["DestinationConnectionFlatFile"];
        DtsProperty cols = ffcn.Properties["Columns"];
4

1 回答 1

2

更新：好的，下面的答案在这种情况下似乎无关紧要（尽管在某种意义上仍然有用，所以我会留下它）。我没有考虑到平面文件 ConnectionManager 有可用的列，而不是必须通过带有输出/输入列的源/目标组件

Columns 属性的值 (GetValue) 应转换为 IDTSConnectionManagerFlatFileColumns100（如果使用 SQL Server 2005 API，则为 90）

或者，将您的配置管理器的 InnerObject 转换为 IDTSConnectionManagerFlatFile100，它会公开一个 Columns 属性。

（这些接口可以在Microsoft.SqlServer.Dts.Runtime.Wrapper中找到）

不确定这与您的上下文有多相关，如果您仍然需要它，但我只是做了类似的事情，所以我想我会分享：

下面的代码将通过动态构建 SSIS 包列出 Excel 2007 文件的所有列（您需要引用 Microsoft.SqlServer.DTSPipelineWrap、Microsoft.SqlServer.DTSRuntimeWrap、Microsoft.SQLServer.ManagedDTS 和 Microsoft.SqlServer .PipelineHost）。

据我所知，唯一的区别是您必须查询已加载的包以获取 DataFlow 任务和相关的平面文件目标组件及其连接管理器（在我的情况下，我自己创建了相关的对象）并获取它输入列而不是输出列。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Microsoft.SqlServer.Dts.Runtime;
using Microsoft.SqlServer.Dts.Pipeline.Wrapper;

namespace SSISListColumns
{
    class Program
    {
        static void Main(string[] args)
        {
            // Create package
            Package package = new Package();

            // Create excel connection manager and set connection string
            string fileName = "sampledata.xlsx";
            ConnectionManager connection = package.Connections.Add("EXCEL");
            connection.Properties["ConnectionString"].SetValue(connection, string.Format(@"Provider=Microsoft.ACE.OLEDB.12.0;Data Source={0};Extended Properties=""Excel 12.0;HDR=YES""", fileName));

            // Add Data Flow task
            Executable e = package.Executables.Add("STOCK:PipelineTask");
            TaskHost thMainPipe = e as TaskHost;
            MainPipe dataFlowTask = thMainPipe.InnerObject as MainPipe; 

            // Add Excel Source component
            IDTSComponentMetaData100 component = dataFlowTask.ComponentMetaDataCollection.New();
            component.Name = "ExcelSource";
            component.ComponentClassID = "DTSAdapter.ExcelSource.2";

            // Set Excel Source properties (connection manager, access mode and sheet/rowset)
            CManagedComponentWrapper instance = component.Instantiate();
            instance.ProvideComponentProperties();

            if (component.RuntimeConnectionCollection.Count > 0)
            {
                component.RuntimeConnectionCollection[0].ConnectionManager = DtsConvert.GetExtendedInterface(package.Connections[0]);
                component.RuntimeConnectionCollection[0].ConnectionManagerID = package.Connections[0].ID;
            }
            instance.SetComponentProperty("AccessMode", 0);
            instance.SetComponentProperty("OpenRowset", "Sheet1$");

            // Activate
            instance.AcquireConnections(null);
            instance.ReinitializeMetaData();
            instance.ReleaseConnections();

            // List output columns
            var output = component.OutputCollection[0];
            foreach (IDTSOutputColumn100 column in output.OutputColumnCollection)
            {
                Console.WriteLine(column.Name);
            }

            Console.ReadKey();
        }
    }
}

于 2010-01-20T13:37:34.667 回答