创建SSIS自定义数据流组件+ SSIS 2008

是SSIS自定义组件的新手。刚刚开始编写一个组件，其中输入行数永远不会与输出行数相同。 foreach输入行它会进行一些验证并生成需要映射到输出缓冲区的n行。创建SSIS自定义数据流组件+ SSIS 2008

所以在设计时验证编码后，一切都很好。

我运行时的代码如下：

public override void PreExecute() 
    { 
     IDTSInput100 input = ComponentMetaData.InputCollection[0]; 
     inputBufferColumnIndex = new int[input.InputColumnCollection.Count]; 

     for (int x = 0; x < input.InputColumnCollection.Count; x++) 
     { 
      IDTSInputColumn100 column = input.InputColumnCollection[x]; 
      inputBufferColumnIndex[x] = BufferManager.FindColumnByLineageID (input.Buffer, column.LineageID); 
     } 

     IDTSOutput100 output = ComponentMetaData.OutputCollection[0]; 
     outputBufferColumnIndex = new int[output.OutputColumnCollection.Count]; 

     for (int x = 0; x < output.OutputColumnCollection.Count; x++) 
     { 
      IDTSOutputColumn100 outcol = output.OutputColumnCollection[x]; 
      outputBufferColumnIndex[x] = BufferManager.FindColumnByLineageID(input.Buffer, outcol.LineageID); 
     } 

    } 


    public override void ProcessInput(int inputID, PipelineBuffer buffer) 
    { 
     if(!buffer.EndOfRowset) 
     { 
      while (buffer.NextRow()) 
      { 
       var rec = new Record 
           { 
            Source = buffer[0].ToString(), 
            Nk = buffer[1].ToString(), 
            Guid = new Guid(buffer[2].ToString()), 
            FromDate = Convert.ToDateTime(buffer[3].ToString()), 
            ToDate = Convert.ToDateTime(buffer[4].ToString()) 
           }; 
       sourceRecords.Add(rec); 
      } 
      ProcessArray(sourceRecords,buffer); 
     } 
    } 
    public void ProcessArray(List<Record> records, PipelineBuffer buffer) 
    { 
     //Get Distinct NKs from the source Records 
     List<string> nKs = (from c in records select c.Nk).Distinct().ToList(); 


     foreach (var nk in nKs) 
     { 
      //Get all the record for particular NK 
      List<Record> filteredRecords = (from c in sourceRecords where c.Nk == nk select c) 
               .OrderBy(c => c.Source) 
               .ThenBy(c => c.FromDate) 
               .ThenBy(c => c.ToDate).ToList(); 

      foreach (var filteredRecord in filteredRecords) 
      { 
       _start = filteredRecord.FromDate; 
       _end = filteredRecord.ToDate; 
       while (filteredRecord.WriteComplete == false) 
       { 
        foreach (var record in filteredRecords) 
        { 
         if (record.FromDate > _start && record.FromDate < _end) _end = record.ToDate; 
         if (record.ToDate < _end && record.ToDate > _start) _end = record.ToDate; 
        } 

        //Output0Buffer.AddRow(); 
        //Output0Buffer.outSource = filteredRecord.Source; 
        //Output0Buffer.outNK = filteredRecord.Nk; 
        //Output0Buffer.outRecid = filteredRecord.Guid; 
        //Output0Buffer.outFromDate = _start; 
        //Output0Buffer.outToDate = _end; 
        buffer.SetString(5,filteredRecord.Source); 
        buffer.SetString(6,filteredRecord.Nk); 
        buffer.SetGuid(7,filteredRecord.Guid); 
        buffer.SetDateTime(8,filteredRecord.FromDate); 
        buffer.SetDateTime(9,filteredRecord.ToDate); 

        _start = _end; 
        _end = filteredRecord.ToDate; 

        if (_start == _end) filteredRecord.WriteComplete = true; 
       } 
      } 
     } 
    } 
} 
public class Record 
{ 
    public Guid Guid { get; set; } 
    public string Nk { get; set; } 
    public string Source { get; set; } 
    public DateTime FromDate { get; set; } 
    public DateTime ToDate { get; set; } 
    public bool WriteComplete { get; set; } 
}

在我ProcessArray方法我试图填充输出缓冲区。我甚至不确定这可以做到。

任何指导将不胜感激。

谢谢

来源

2010-07-06 Sreedhar