PipelineBuffer Classe

Definizione

public ref class PipelineBuffer : IDisposable

public class PipelineBuffer : IDisposable

type PipelineBuffer = class
    interface IDisposable

Public Class PipelineBuffer
Implements IDisposable

Ereditarietà

Object

PipelineBuffer

Implementazioni

IDisposable

Esempio

Nell'esempio seguente viene illustrato un componente di trasformazione che esegue l'iterazione delle righe e delle colonne di un PipelineBuffer oggetto in ProcessInput.

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

namespace Microsoft.Samples.SqlServer.Dts  
{  
   [DtsPipelineComponent  
   (  
   DisplayName="SampleComponent",  
   ComponentType=ComponentType.Transform  
   )]  
   public class SampleComponent: PipelineComponent  
   {  
      public override void ProvideComponentProperties()  
      {  
         base.ProvideComponentProperties();  

         ///Name the input and output add by the base class.  
         ComponentMetaData.InputCollection[0].Name = "SampleInput";  
         ComponentMetaData.OutputCollection[0].Name = "SampleOutput";  
      }  

      public override void ProcessInput(int inputID, PipelineBuffer buffer)  
      {  

      IDTSInput100 input = ComponentMetaData.InputCollection.GetObjectByID(inputID);  

      while (buffer.NextRow())  
      {  
         foreach (IDTSInputColumn100 col in input.InputColumnCollection)  
         {  
            int colIndex = BufferManager.FindColumnByLineageID(input.Buffer,col.LineageID);  
            object colData = buffer[colIndex];  
            //TODO: Do something with the column data.  
         }  
      }  
      }  
   }  
}  

Nell'esempio seguente viene illustrato un componente di origine che aggiunge righe al buffer di output in PrimeOutput.

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

namespace Microsoft.Samples.SqlServer.Dts  
{  
   [DtsPipelineComponent  
   (  
      DisplayName="SampleComponent",  
      ComponentType=ComponentType.SourceComponent  
)]  
   public class SampleComponent: PipelineComponent  
   {  
      public override void PrimeOutput(int outputs, int[] outputIDs,PipelineBuffer[] buffers)  
      {  
         int rows = 100;  
         PipelineBuffer buf = buffers[0];  
         IDTSOutput100 output = ComponentMetaData.OutputCollection[0];  
         Random rand = new Random();  

         //Loop rows number of times  
         for(int r = 0; r < rows; r++)  
         {  
            buf.AddRow();  
            foreach( IDTSOutputColumn100 col in output.OutputColumnCollection)  
            {  
               int colIndex = BufferManager.FindColumnByLineageID( output.Buffer, col.LineageID);  
               // Note, buffer columns containing binary large objects  
               // can not be set using the following syntax. Instead,  
               // the AddBlobData and SetBytes methods are used.  
               buf[colIndex] = rand.Next();  
            }  
         }  
         buf.SetEndOfRowset();  
      }  
   }  
}  

Commenti

PipelineBuffer è un archivio dati bidimensionale in memoria contenente righe e colonne. Viene creato dall'attività flusso di dati e fornito ai componenti del flusso di dati gestiti durante l'esecuzione. Le colonne contenute in un buffer sono basate sulle colonne nelle IDTSOutputColumnCollection100 raccolte dei componenti del grafico.

I componenti di origine e i componenti con output asincroni ricevono un buffer per ognuno degli oggetti di output connessi a un componente downstream. Questi buffer vengono definiti buffer di output e non contengono righe. Il componente che riceve il buffer di output aggiunge righe al buffer e chiama il SetEndOfRowset metodo al termine. Questo metodo imposta il valore della EndOfRowset proprietà su true sul buffer finale. L'attività Flusso di dati fornisce quindi tale buffer al componente successivo nel grafico.

I componenti di trasformazione con output sincroni e componenti di destinazione ricevono PipelineBuffer oggetti nel ProcessInput metodo . L'oggetto PipelineBuffer ricevuto in questo metodo è un Input buffer e contiene le righe aggiunte ai componenti upstream. Questo buffer è limitato e non può essere usato per aggiungere o rimuovere righe dal buffer.

PipelineBuffer è scritto nel codice gestito e supporta gli sviluppatori di componenti flusso di dati gestiti eseguendo il marshalling dei dati tra il codice gestito e l'oggetto COM sottostanteIDTSBuffer100.

Per un elenco completo dei tipi di dati di Integration Services e dei metodi e Set corrispondenti Get della PipelineBuffer classe da usare con ogni tipo di dati, vedere Utilizzo dei tipi di dati nella Flusso di dati.

Costruttori

Proprietà

Metodi

Si applica a