在SSIS平面文件连接中列出列

Question

我正试图从一个将DB表导出到平面文件的SSIS包中生成一个列'start/length'spec文档。从处理平面文件连接的ConnectionManager对象获取Columns属性时，我碰到了一堵砖墙。我能够获得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"]; 

Answer 1

UPDATE：好的答案下面好像它在这方面是不相关的（尽管在某种意义上仍然是有用的，所以我会离开它）。我没有考虑到Flat File ConnectionManager具有可用的列，而不必通过具有输出/输入列的源/目标组件

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

或者，将您的配置管理器的InnerObject强制转换为公开Columns属性的IDTSConnectionManagerFlatFile100。

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

---

不知道如何相关，这是你的情况下，如果你仍然需要这一点，但我只是做了一件相似的，所以我想我会分享：

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

据我所见，唯一的区别是你必须intergate你的加载包，以获得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(); 
     } 
    } 
}