PipelineComponent.PreExecute Método

Definición

Espacio de nombres:

Microsoft.SqlServer.Dts.Pipeline

Ensamblado:

Microsoft.SqlServer.PipelineHost.dll

Recibe una llamada después de PrepareForExecute() y antes de PrimeOutput(Int32, Int32[], PipelineBuffer[]) y ProcessInput(Int32, PipelineBuffer).

public:
 virtual void PreExecute();

public virtual void PreExecute ();

abstract member PreExecute : unit -> unit
override this.PreExecute : unit -> unit

Public Overridable Sub PreExecute ()

Ejemplos

En el ejemplo siguiente se muestra cómo buscar los índices de columna de las columnas en .InputColumnCollection Se almacenan en una variable local y, a continuación, se usan en ProcessInput para tener acceso a las columnas de .PipelineBuffer

int[] bufferColumnIndex;  
public override void PreExecute()  
{  
    IDTSInput100 input = ComponentMetaData.InputCollection[0];  
    bufferColumnIndex = new int[input.InputColumnCollection.Count];  
    for ( int x=0; x < input.InputColumnCollection.Count; x++)  
    {  
        bufferColumnIndex[x] = BufferManager.FindColumnByLineageID( input.Buffer, input.InputColumnCollection[x].LineageID);  
    }  
}  
public override void ProcessInput( int inputID, PipelineBuffer buffer )  
{  
    while( buffer.NextRow() )  
    {  
        for( int x=0; x < bufferColumnIndex.Length(); x++ )  
        {  
            if( !buffer.IsNull(bufferColumnIndex[x]))  
            {  
                // TODO: Access the column data.  
            }  
        }  
    }  
}  

Private bufferColumnIndex As Integer()   

Public Overrides Sub PreExecute()   
 Dim input As IDTSInput100 = ComponentMetaData.InputCollection(0)   
 bufferColumnIndex = New Integer(input.InputColumnCollection.Count - 1) {}   
 Dim x As Integer = 0   
 While x < input.InputColumnCollection.Count  
   bufferColumnIndex(x) = BufferManager.FindColumnByLineageID(input.Buffer, input.InputColumnCollection(x).LineageID)   
   x -= 1  
 End While   
End Sub   

Public Overrides Sub ProcessInput(ByVal inputID As Integer, ByVal buffer As PipelineBuffer)   
 While buffer.NextRow   
   Dim x As Integer = 0   
   While x < bufferColumnIndex.Length   
     If Not buffer.IsNull(bufferColumnIndex(x)) Then   
     End If   
     x -= 1  
   End While   
 End While   
End Sub  

Comentarios

Los desarrolladores de componentes deben factorizar la mayor cantidad de funcionalidad PreExecute posible porque se llama una vez por componente en lugar de una vez por búfer para ProcessInput. Los componentes deben localizar los índices de sus columnas de entrada y salida en PipelineBuffer mediante una llamada al FindColumnByLineageID método de BufferManager.