PipelineComponent Kelas

Referensi

Definisi

Ruang nama:: Microsoft.SqlServer.Dts.Pipeline

Rakitan:: Microsoft.SqlServer.PipelineHost.dll

Penting

Beberapa informasi terkait produk prarilis yang dapat diubah secara signifikan sebelum dirilis. Microsoft tidak memberikan jaminan, tersirat maupun tersurat, sehubungan dengan informasi yang diberikan di sini.

Menentukan kelas dasar yang digunakan saat mengembangkan komponen aliran data terkelola.

public ref class PipelineComponent

public class PipelineComponent

type PipelineComponent = class

Public Class PipelineComponent

Warisan: Object
PipelineComponent

Turunan: Microsoft.SqlServer.Dts.Pipeline.PipelineComponentExt

Microsoft.SqlServer.Dts.Pipeline.ScriptComponentHost

Contoh

Contoh kode berikut menunjukkan komponen yang mengimplementasikan DtsPipelineComponentAttribute dan mewarisi dari PipelineComponent kelas .

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

Keterangan

Warisi dari kelas ini untuk membuat komponen aliran data Anda sendiri. Kelas ini mengimplementasikan antarmuka komponen yang diperlukan, IDTSDesigntimeComponent100 dan IDTSRuntimeComponent100. Anda mengambil alih implementasi kelas dasar metode ini untuk menyediakan fungsionalitas komponen Anda. PipelineComponent menyediakan metode pembantu selain metode antarmuka komponen untuk membantu Anda dalam mengembangkan komponen Anda.

Konstruktor

PipelineComponent()

Menginisialisasi instans baru kelas PipelineComponent.

Bidang

s_STOCKPROPNAME_COMPFLAGS	Berisi nama properti ComparisonFlags dari komponen aliran data.
s_STOCKPROPNAME_DELOUTPUTONPATHDETACHED	Berisi nama properti DeleteOutputOnPathDetached dari komponen aliran data.
s_STOCKPROPNAME_EXCLGROUP	Berisi nama properti ExclusionGroup dari komponen aliran data.
s_STOCKPROPNAME_HASSIDEEFFECTS	Berisi nama properti HasSideEffects dari komponen aliran data.
s_STOCKPROPNAME_ISDISTRIBUTABLE	Berisi nama properti IsDistributable dari komponen aliran data.
s_STOCKPROPNAME_ISERROROUT	Berisi nama properti IsErrorOut dari komponen aliran data.
s_STOCKPROPNAME_ISSORTED	Berisi nama properti IsSorted komponen aliran data.
s_STOCKPROPNAME_REFMETADATAID	Berisi nama properti ReferenceMetaDataID dari komponen aliran data.
s_STOCKPROPNAME_SORTKEYPOS	Berisi nama properti SortKeyPosition komponen aliran data.
s_STOCKPROPNAME_SYNCINPUTID	Berisi nama properti SynchronousInputID dari komponen aliran data.

Properti

BufferManager	IDTSBufferManager100 Mendapatkan komponen alur.
ComponentMetaData	IDTSComponentMetaData100 Mendapatkan untuk komponen.
ErrorSupport	ErrorSupport Mengembalikan objek yang memungkinkan komponen memunculkan kesalahan, peringatan, atau peristiwa informasi lainnya berdasarkan HRESULT yang dikembalikan oleh komponen Layanan Integrasi yang ditulis dalam kode asli.
EventInfos	IDTSEventInfos100 Mendapatkan koleksi PipelineComponent objek .
LogEntryInfos	IDTSLogEntryInfos100 Mendapatkan kumpulan peristiwa pengelogan yang telah didaftarkan komponen.
ReferenceTracker	Mendapatkan yang IDTSObjectReferenceTracker100 terkait dengan komponen.
VariableDispenser	IDTSVariableDispenser100 Mendapatkan komponen aliran data.

Metode

AcquireConnections(Object)	Membuat koneksi ke manajer koneksi.
AddErrorOutput(String, Int32, Int32)	IDTSOutput100 Menambahkan objek dan menandainya sebagai output kesalahan dengan mengatur properti ke IsErrorOut true.
BufferTypeToDataRecordType(DataType)	Mengembalikan jenis data terkelola berdasarkan jenis data Integration Services.
Cleanup()	Membebaskan sumber daya dan menyelesaikan eksekusi komponen.
ConvertBufferDataTypeToFitManaged(DataType, Boolean)	Mendapatkan Layanan DataType Integrasi yang sesuai dari kode terkelola.
DataRecordTypeToBufferType(Type)	Mendapatkan Layanan DataType Integrasi yang sesuai dengan jenis terkelola.
DeleteExternalMetadataColumn(Int32, Int32)	Menghapus kolom metadata eksternal pada indeks yang ditentukan dari kumpulan kolom metadata eksternal.
DeleteInput(Int32)	IDTSInput100 Menghapus objek dari IDTSInputCollection100 koleksi.
DeleteOutput(Int32)	IDTSOutput100 Menghapus objek dari IDTSOutputCollection100 koleksi.
DeleteOutputColumn(Int32, Int32)	IDTSOutputColumn100 Menghapus objek dari IDTSOutputColumnCollection100 koleksi.
DescribeRedirectedErrorCode(Int32)	Menyediakan informasi kode kesalahan untuk baris yang PipelineBuffer ditambahkan ke buffer output.
GetDependentInputs(Int32)	Mengembalikan kumpulan ID input input yang menunggu lebih banyak data, dan dengan demikian memblokir input yang ditentukan.
GetErrorOutputInfo(Int32, Int32)	Mengembalikan indeks dan ID output kesalahan komponen.
idxOfBufferType(DataType)	Menentukan jenis indeks buffer.
idxOfDataRecordType(Type)	Menentukan jenis indeks rekaman data.
Initialize()	Saat ditimpa di kelas turunan, menginisialisasi instans baru komponen aliran data kustom.
InsertExternalMetadataColumnAt(Int32, Int32, String, String)	Menyisipkan kolom metadata eksternal baru ke dalam kumpulan kolom metadata eksternal pada indeks yang ditentukan.
InsertInput(DTSInsertPlacement, Int32)	IDTSInput100 Menambahkan objek ke IDTSInputCollection100.
InsertOutput(DTSInsertPlacement, Int32)	Menambahkan objek baru IDTSOutput100
InsertOutputColumnAt(Int32, Int32, String, String)	Membuat objek baru IDTSOutputColumn100 dan menyisipkannya ke IDTSOutputColumnCollection100dalam .
IsCompatibleNumericTypes(DataType, DataType)	Menentukan apakah dua jenis data numerik kompatibel untuk mendukung konversi dari satu jenis ke jenis lainnya.
IsInputReady(Int32[], Boolean[])	Menentukan input mana yang dilampirkan ke komponen yang menunggu lebih banyak data, dan yang memiliki cukup data untuk diproses dan diblokir.
MapInputColumn(Int32, Int32, Int32)	Membuat hubungan antara kolom input dan kolom metadata eksternal terkait.
MapOutputColumn(Int32, Int32, Int32, Boolean)	Membuat hubungan antara kolom output dan kolom metadata eksternal terkait.
OnDeletingInputColumn(Int32, Int32)	IDTSInputColumn100 Menghapus objek dari IDTSInputColumnCollection100.
OnInputPathAttached(Int32)	Dipanggil ketika IDTSInput100 objek terhubung ke komponen melalui IDTSPath100 antarmuka.
OnInputPathDetached(Int32)	Dipanggil ketika IDTSInput100 objek terputus dari komponen melalui IDTSPath100 antarmuka.
OnOutputPathAttached(Int32)	Dipanggil ketika IDTSOutput100 objek komponen dilampirkan ke komponen hilir.
PerformDowngrade(Int32, DTSTargetServerVersion)	Secara default PerformDowngrade tidak boleh melempar ComponentDowngradeFailedException karena runtime hanya dapat menentukan apakah akan memanggil metode ini dengan targetServerVersion; tidak dapat memeriksa versi komponen karena tidak tahu apakah versi komponen telah diubah antara dua versi SSIS, sementara metode PerformUpgrade akan memeriksa apakah versi komponen dalam xml paket lebih kecil dari versi komponen saat ini sebelum dipanggil.
PerformUpgrade(Int32)	Meningkatkan metadata komponen ke versi komponen yang diinstal pada komputer lokal.
PostExecute()	Dipanggil pada akhir eksekusi komponen, tetapi sebelum Cleanup().
PreExecute()	Dipanggil setelah PrepareForExecute(), dan sebelum PrimeOutput(Int32, Int32[], PipelineBuffer[]) dan ProcessInput(Int32, PipelineBuffer).
PrepareForExecute()	Dipanggil sebelum PreExecute().
PrimeOutput(Int32, Int32[], PipelineBuffer[])	Dipanggil pada waktu proses untuk komponen sumber dan komponen transformasi dengan output asinkron untuk memungkinkan komponen ini menambahkan baris ke buffer output.
ProcessInput(Int32, PipelineBuffer)	Dipanggil pada durasi ketika PipelineBuffer komponen dari hulu tersedia untuk komponen untuk membiarkan komponen memproses baris masuk.
ProvideComponentProperties()	Dipanggil saat komponen pertama kali ditambahkan ke tugas aliran data, untuk menginisialisasi ComponentMetaData komponen.
RegisterEvents()	Saat Anda mengembangkan komponen aliran data kustom, Anda mengambil alih metode ini untuk membuat peristiwa kustom.
RegisterLogEntries()	Mendaftarkan peristiwa yang akan dicatat komponen.
ReinitializeMetaData()	Memperbaiki kesalahan apa pun yang diidentifikasi selama validasi yang menyebabkan komponen kembali VS_NEEDSNEWMETADATA pada waktu desain.
ReleaseConnections()	Membebaskan koneksi yang dibuat selama AcquireConnections(Object). Dipanggil pada waktu desain dan durasi.
RemoveAllInputsOutputsAndCustomProperties()	Menghapus setiap IDTSInput100 objek dan IDTSOutput100 dari komponen.
SetComponentProperty(String, Object)	Menetapkan nilai ke IDTSCustomProperty100 komponen.
SetExternalMetadataColumnDataTypeProperties(Int32, Int32, DataType, Int32, Int32, Int32, Int32)	Mengatur properti tipe data dari kolom metadata eksternal yang ditentukan.
SetExternalMetadataColumnProperty(Int32, Int32, String, Object)	Mengatur properti individual dari kolom metadata eksternal.
SetInputColumnProperty(Int32, Int32, String, Object)	Menetapkan nilai ke IDTSCustomProperty100 IDTSInputColumn100 objek .
SetInputProperty(Int32, String, Object)	Menetapkan nilai ke IDTSCustomProperty100 IDTSInput100 objek .
SetOutputColumnDataTypeProperties(Int32, Int32, DataType, Int32, Int32, Int32, Int32)	Mengatur properti IDTSOutputColumn100 tipe data objek.
SetOutputColumnProperty(Int32, Int32, String, Object)	Mengatur nilai IDTSCustomProperty100 untuk objek IDTSOutputColumn100 .
SetOutputProperty(Int32, String, Object)	Mengatur nilai IDTSCustomProperty100 pada IDTSOutput100 objek.
SetUsageType(Int32, IDTSVirtualInput100, Int32, DTSUsageType)	IDTSInputColumn100 Membuat objek di IDTSInputColumnCollection100 komponen dan mengatur UsageType properti kolom.
Validate()	Memverifikasi bahwa komponen dikonfigurasi dengan benar.

Berlaku untuk

Bagikan melalui