PipelineComponent Classe

Definizione

Spazio dei nomi:

Microsoft.SqlServer.Dts.Pipeline

Assembly:

Microsoft.SqlServer.PipelineHost.dll

Definisce la classe base utilizzata nello sviluppo dei componenti del flusso dati gestiti.

public ref class PipelineComponent

public class PipelineComponent

type PipelineComponent = class

Public Class PipelineComponent

Ereditarietà

Object

PipelineComponent

Derivato

Microsoft.SqlServer.Dts.Pipeline.PipelineComponentExt

Microsoft.SqlServer.Dts.Pipeline.ScriptComponentHost

Esempio

Il seguente esempio di codice mostra un componente che implementa e DtsPipelineComponentAttribute eredita dalla PipelineComponent classe.

using System;  
using Microsoft.SqlServer.Dts.Pipeline.Wrapper;  
namespace Microsoft.Samples.SqlServer.Dts  
{  
    [DtsPipelineComponent(DisplayName="SampleComponent")]  
    public class SampleComponent : PipelineComponent  
    {  
        public override ProvideComponentProperties()  
        {  
            // TODO: Implement component intialization.  
        }  
        public override DTSValidationStatus Validate()  
        {  
            // TODO: Implement component validation.  
        }  
        public override void ProcessInput( int inputID, PipelineBuffer buffer)  
        {  
            // TODO: For transformation and destination components,  
            //  implement code to process incoming rows.  
        }  
    }  
}  

Imports System   
Imports Microsoft.SqlServer.Dts.Pipeline.Wrapper   
Namespace Microsoft.Samples.SqlServer.Dts   

 <DtsPipelineComponent(DisplayName="SampleComponent")> _   
 Public Class SampleComponent   
 Inherits PipelineComponent   

   Public Overrides Sub ProvideComponentProperties()   
    ' TODO: Implement component intialization.  
   End Sub   

   Public Overrides Function Validate() As DTSValidationStatus   
    ' TODO: Implement component validation.  
   End Function   

   Public Overrides Sub ProcessInput(ByVal inputID As Integer, ByVal buffer As PipelineBuffer)   
    ' TODO: For transformation and destination components,  
    '  implement code to process incoming rows.  
   End Sub   
 End Class   
End Namespace  

Commenti

Eredita da questa classe per creare il tuo componente di flusso dati. Questa classe implementa le interfacce componenti richieste, IDTSDesigntimeComponent100 e IDTSRuntimeComponent100. Sovrascrivi l'implementazione di classe base di questi metodi per fornire la funzionalità del tuo componente. PipelineComponent fornisce metodi di supporto oltre a quelli delle interfacce dei componenti per aiutarti a sviluppare il tuo componente.

Costruttori

Nome	Descrizione
PipelineComponent()	Inizializza una nuova istanza della classe PipelineComponent.

Campi

Nome	Descrizione
s_STOCKPROPNAME_COMPFLAGS	Contiene il nome della proprietà ComparisonFlags dei componenti del flusso di dati.
s_STOCKPROPNAME_DELOUTPUTONPATHDETACHED	Contiene il nome della proprietà DeleteOutputOnPathDetached dei componenti del flusso dati.
s_STOCKPROPNAME_EXCLGROUP	Contiene il nome della proprietà ExclusionGroup dei componenti del flusso di dati.
s_STOCKPROPNAME_HASSIDEEFFECTS	Contiene il nome della proprietà HasSideEffects dei componenti del flusso di dati.
s_STOCKPROPNAME_ISDISTRIBUTABLE	Contiene il nome della proprietà IsDistributable dei componenti del flusso di dati.
s_STOCKPROPNAME_ISERROROUT	Contiene il nome della proprietà IsErrorOut dei componenti del flusso di dati.
s_STOCKPROPNAME_ISSORTED	Contiene il nome della proprietà IsSorted dei componenti del flusso di dati.
s_STOCKPROPNAME_REFMETADATAID	Contiene il nome della proprietà ReferenceMetaDataID dei componenti del flusso di dati.
s_STOCKPROPNAME_SORTKEYPOS	Contiene il nome della proprietà SortKeyPosition dei componenti del flusso di dati.
s_STOCKPROPNAME_SYNCINPUTID	Contiene il nome della proprietà SynchronousInputID dei componenti del flusso di dati.

Proprietà

Nome	Descrizione
BufferManager	Ottiene il IDTSBufferManager100 componente della pipeline.
ComponentMetaData	Ottiene il IDTSComponentMetaData100 per un componente.
ErrorSupport	Restituisce un ErrorSupport oggetto che permette al componente di generare errori, avvisi o altri eventi informativi basati su HRESULT restituiti dai componenti dei Servizi di Integrazione scritti in codice nativo.
EventInfos	Ottiene la IDTSEventInfos100 raccolta dell'oggetto PipelineComponent .
LogEntryInfos	Riceve una IDTSLogEntryInfos100 raccolta di eventi di logging che il componente ha registrato.
ReferenceTracker	Ottiene l'associato IDTSObjectReferenceTracker100 al componente.
VariableDispenser	Ottiene il IDTSVariableDispenser100 componente del flusso dati.

Metodi

Nome	Descrizione
AcquireConnections(Object)	Stabilisce una connessione con un connection manager.
AddErrorOutput(String, Int32, Int32)	Aggiunge un IDTSOutput100 oggetto e lo segna come output di errore impostando la IsErrorOut proprietà su true.
BufferTypeToDataRecordType(DataType)	Restituisce un tipo di dato gestito basato su un tipo di dato di Integration Services.
Cleanup()	Libera risorse e completa l'esecuzione del componente.
ConvertBufferDataTypeToFitManaged(DataType, Boolean)	Ottiene i servizi DataType di integrazione appropriati dal codice gestito.
DataRecordTypeToBufferType(Type)	Ottiene i Servizi DataType di Integrazione che corrispondono a un tipo gestito.
DeleteExternalMetadataColumn(Int32, Int32)	Elimina la colonna dei metadati esterni nell'indice specificato dalla raccolta delle colonne di metadati esterne.
DeleteInput(Int32)	Elimina un IDTSInput100 oggetto dalla IDTSInputCollection100 collezione.
DeleteOutput(Int32)	Elimina un IDTSOutput100 oggetto dalla IDTSOutputCollection100 collezione.
DeleteOutputColumn(Int32, Int32)	Elimina un IDTSOutputColumn100 oggetto dalla IDTSOutputColumnCollection100 collezione.
DescribeRedirectedErrorCode(Int32)	Fornisce informazioni sul codice di errore per una PipelineBuffer riga aggiunta a un buffer di output.
GetDependentInputs(Int32)	Restituisce una raccolta degli ID degli input degli input che aspettano altri dati, bloccando quindi l'input specificato.
GetErrorOutputInfo(Int32, Int32)	Restituisce l'indice e l'ID dell'output di errore del componente.
idxOfBufferType(DataType)	Specifica il tipo di indice buffer.
idxOfDataRecordType(Type)	Specifica il tipo di indice dei dati dei record.
Initialize()	Quando viene sovrascritto in una classe derivata, inizializza una nuova istanza di un componente custom data flow.
InsertExternalMetadataColumnAt(Int32, Int32, String, String)	Inserisce una nuova colonna di metadati esterni nella collezione di colonne di metadati esterni all'indice specificato.
InsertInput(DTSInsertPlacement, Int32)	Aggiunge un IDTSInput100 oggetto all'oggetto IDTSInputCollection100.
InsertOutput(DTSInsertPlacement, Int32)	Aggiunge un nuovo IDTSOutput100 oggetto
InsertOutputColumnAt(Int32, Int32, String, String)	Crea un nuovo IDTSOutputColumn100 oggetto e lo inserisce nel IDTSOutputColumnCollection100file .
IsCompatibleNumericTypes(DataType, DataType)	Determina se due tipi di dati numerici sono compatibili per supportare una conversione da un tipo all'altro.
IsInputReady(Int32[], Boolean[])	Determina quali ingressi collegati a un componente stanno aspettando altri dati, e quali hanno abbastanza dati da elaborare e sono bloccati.
MapInputColumn(Int32, Int32, Int32)	Stabilisce una relazione tra una colonna di input e una corrispondente colonna di metadati esterna.
MapOutputColumn(Int32, Int32, Int32, Boolean)	Stabilisce una relazione tra una colonna di output e una corrispondente colonna esterna di metadati.
OnDeletingInputColumn(Int32, Int32)	Elimina un IDTSInputColumn100 oggetto dal IDTSInputColumnCollection100.
OnInputPathAttached(Int32)	Chiamato quando un IDTSInput100 oggetto è collegato al componente tramite l'interfaccia IDTSPath100 .
OnInputPathDetached(Int32)	Chiamato quando un IDTSInput100 oggetto viene disconnesso dal componente tramite l'interfaccia IDTSPath100 .
OnOutputPathAttached(Int32)	Chiamato quando un IDTSOutput100 oggetto del componente è collegato a un componente a valle.
PerformDowngrade(Int32, DTSTargetServerVersion)	Per impostazione predefinita, PerformDowngrade non dovrebbe lanciare ComponentDowngradeFailedException perché l'esecuzione può determinare se chiamare questo metodo solo tramite targetServerVersion; non può controllare la versione component perché non sa se la versione component è stata modificata tra due versioni SSIS, mentre il metodo PerformUpgrade controllerà se la versione component nel package xml è più piccola di quella attuale prima di essere chiamata.
PerformUpgrade(Int32)	Aggiorna i metadati del componente alla versione del componente installata sul computer locale.
PostExecute()	Chiamato alla fine dell'esecuzione dei componenti, ma prima Cleanup()di .
PreExecute()	Chiamato dopo PrepareForExecute(), e prima PrimeOutput(Int32, Int32[], PipelineBuffer[]) e ProcessInput(Int32, PipelineBuffer).
PrepareForExecute()	Chiamato prima PreExecute()di .
PrimeOutput(Int32, Int32[], PipelineBuffer[])	Chiamato in tempo di esecuzione per componenti sorgente e componenti di trasformazione con uscite asincrone per permettere a questi componenti di aggiungere righe ai buffer di output.
ProcessInput(Int32, PipelineBuffer)	Chiamato a tempo di esecuzione quando un PipelineBuffer componente a monte è disponibile per il componente per permettere al componente di processare le righe in ingresso.
ProvideComponentProperties()	Chiamato quando un componente viene aggiunto per la prima volta al compito di flusso dati, per inizializzare il ComponentMetaData del componente.
RegisterEvents()	Quando sviluppi un componente di flusso dati personalizzato, sovrascrivi questo metodo per creare eventi personalizzati.
RegisterLogEntries()	Registra gli eventi che il componente registrerà.
ReinitializeMetaData()	Ripara eventuali errori identificati durante la validazione che causano il ritorno VS_NEEDSNEWMETADATA del componente al momento della progettazione.
ReleaseConnections()	Libera le connessioni stabilite durante AcquireConnections(Object). Chiamato al momento della progettazione e dell'esecuzione.
RemoveAllInputsOutputsAndCustomProperties()	Elimina ogni IDTSInput100 oggetto IDTSOutput100 dal componente.
SetComponentProperty(String, Object)	Assegna un valore a IDTSCustomProperty100 del componente.
SetExternalMetadataColumnDataTypeProperties(Int32, Int32, DataType, Int32, Int32, Int32, Int32)	Imposta le proprietà del tipo di dato della colonna di metadati esterni specificata.
SetExternalMetadataColumnProperty(Int32, Int32, String, Object)	Imposta una proprietà individuale di una colonna di metadati esterna.
SetInputColumnProperty(Int32, Int32, String, Object)	Assegna un valore al IDTSCustomProperty100 di un IDTSInputColumn100 oggetto.
SetInputProperty(Int32, String, Object)	Assegna un valore al IDTSCustomProperty100 di un IDTSInput100 oggetto.
SetOutputColumnDataTypeProperties(Int32, Int32, DataType, Int32, Int32, Int32, Int32)	Imposta le proprietà del tipo di dato di un IDTSOutputColumn100 oggetto.
SetOutputColumnProperty(Int32, Int32, String, Object)	Stabilisce il valore di un IDTSCustomProperty100 per un IDTSOutputColumn100 oggetto.
SetOutputProperty(Int32, String, Object)	Imposta il valore di un IDTSCustomProperty100 su un IDTSOutput100 oggetto.
SetUsageType(Int32, IDTSVirtualInput100, Int32, DTSUsageType)	Crea un IDTSInputColumn100 oggetto nel IDTSInputColumnCollection100 componente e imposta la UsageType proprietà della colonna.
Validate()	Verifica che il componente sia configurato correttamente.