PipelineBuffer Klasse

Definition

public ref class PipelineBuffer : IDisposable

public class PipelineBuffer : IDisposable

type PipelineBuffer = class
    interface IDisposable

Public Class PipelineBuffer
Implements IDisposable

Vererbung

Object

PipelineBuffer

Implementiert

IDisposable

Beispiele

Im folgenden Beispiel wird eine Transformationskomponente gezeigt, die die Zeilen und Spalten einer PipelineBuffer In ProcessInputbeschreibt.

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.  
         }  
      }  
      }  
   }  
}  

Im folgenden Beispiel wird eine Quellkomponente dargestellt, die Zeilen zum Ausgabepuffer 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();  
      }  
   }  
}  

Hinweise

Es PipelineBuffer handelt sich um einen zweidimensionalen Datenspeicher mit Zeilen und Spalten. Es wird von der Datenflussaufgabe erstellt und für verwaltete Datenflusskomponenten während der Ausführung bereitgestellt. Die spalten, die in einem Puffer enthalten sind, basieren auf den Spalten in den IDTSOutputColumnCollection100 Sammlungen der Komponenten im Diagramm.

Quellkomponenten und Komponenten mit asynchronen Ausgabeausgaben erhalten einen Puffer für jede der Ausgabeobjekte, die mit einer nachgelagerten Komponente verbunden sind. Diese Puffer werden als Ausgabepuffer bezeichnet und enthalten keine Zeilen. Die Komponente, die den Ausgabepuffer empfängt, fügt dem Puffer Zeilen hinzu und ruft die SetEndOfRowset Methode beim Abschluss auf. Diese Methode legt den Wert der EndOfRowset Eigenschaft true auf den endgültigen Puffer fest. Der Datenflussvorgang stellt dann diesen Puffer für die nächste Komponente im Diagramm bereit.

Transformationskomponenten mit synchronen Ausgabeen und Zielkomponenten empfangen PipelineBuffer Objekte in der ProcessInput Methode. Der PipelineBuffer Empfangene in dieser Methode ist ein Input Puffer und enthält die Zeilen, die von vorgelagerten Komponenten hinzugefügt wurden. Dieser Puffer ist eingeschränkt und kann nicht zum Hinzufügen oder Entfernen von Zeilen aus dem Puffer verwendet werden.

Das PipelineBuffer wird in verwaltetem Code geschrieben und unterstützt verwaltete Datenflusskomponentenentwickler, indem Daten zwischen verwaltetem Code und dem zugrunde IDTSBuffer100 liegenden COM-Objekt ge marshallt werden.

Eine vollständige Liste der Integration Services-Datentypen und die entsprechenden Get und Set methoden der PipelineBuffer Klasse, die mit jedem Datentyp verwendet werden sollen, finden Sie unter Arbeiten mit Datentypen im Datenfluss.

Konstruktoren

Eigenschaften

Methoden

Gilt für: