Bir özel veri akışı bileşeni oluşturma
In Microsoft SQL Server Integration Services, the data flow task exposes an object model that lets developers create custom data flow components—sources, transformations, and destinations—by using the Microsoft .NET Framework and managed code.
veri akışı görevi içeren bileşenlerden koleksiyon bir IDTSComponentMetaData100 arabirim ve topluluğu IDTSPath100 nesneleri tanımlamak bileşenleri arasındaki veri taşıma
Tasarım süresi ve çalışma süresi
Çalışmaya başlamadan önce veri akışı görevi bir tasarım-'olduğu söylenirsaat durumunu artımlı değişiklikler geçer gibi.Değişiklikleri kaldırmalarının bileşenleri, kaldırmalarının bileşenleri ve değişiklikleri bileşen meta veriler bağlayan yol nesneleri içerebilir.meta veriler değişiklikleri olduğunda bileşeni izlemek ve değişiklikleri güncelleştiren.Örneğin, bir bileşeni belirli değişiklikleri engelleyebilirsiniz veya yanıt olarak bir değişiklik ek değişiklikler yapmak için.Tasarım sırasında saat, tasarımcı tasarım - aracılığıyla bir bileşenle etkileşimsaat IDTSDesigntimeComponent100 arabirim.
yürütmek sırasında saat, veri akışı görevi bileşenleri dizisini inceler, yürütmek planı hazırlar ve iş planı yürütmek alt iş parçacığı havuzu yönetir.Her iş parçacığı için veri akışı görevi iç bazı iş gerçekleştirmesine rağmen asıl görevi, iş parçacığı ile çalışma - bileşenin yöntemleri çağırmaktırsaat IDTSRuntimeComponent100 arabirim.
Bir bileşeni oluşturma
Oluşturmak için bir veri akışı bileşeni, bir sınıftan türer PipelineComponent taban sınıfı, Uygula DtsPipelineComponentAttribute , sınıf ve temel tanýmýna uygun yöntemlerini geçersiz kılınThe PipelineComponent implements the IDTSDesigntimeComponent100 and IDTSRuntimeComponent100 interfaces, and exposes their methods for you to override in your component.
Sizin bileşeni tarafından kullanılan nesneleri türüne bağlı olarak, projenizi bazılarını veya tümünü aşağıdaki derlemeler başvurular gerektirir:
Özellik |
Derleme başvurusu yapmak için |
Ad alanı almak için |
---|---|---|
Veri akışı |
Microsoft.sqlserver.PipelineHost |
[ N:Microsoft.SqlServer.Dts.Pipeline ] |
Veri akışı sarıcı |
Microsoft.sqlserver.DTSPipelineWrap |
[ N:Microsoft.SqlServer.Dts.Pipeline.Wrapper ] |
Çalışma zamanı |
Microsoft.sqlserver.ManagedDTS |
[ N:Microsoft.SqlServer.Dts.Runtime ] |
Runtime sarıcı |
Microsoft.sqlserver.DTSRuntimeWrap |
[ N:Microsoft.SqlServer.Dts.Runtime.Wrapper ] |
Aşağıdaki kod örneği, temel sınıfından türer ve uygulanan basit bir bileşeni gösterir DtsPipelineComponentAttribute.
using System;
using Microsoft.SqlServer.Dts.Pipeline;
using Microsoft.SqlServer.Dts.Pipeline.Wrapper;
namespace Microsoft.Samples.SqlServer.Dts
{
[DtsPipelineComponent(DisplayName = "SampleComponent", ComponentType = ComponentType.Transform )]
public class BasicComponent: PipelineComponent
{
// TODO: Override the base class methods.
}
}
Imports Microsoft.SqlServer.Dts.Pipeline
Imports Microsoft.SqlServer.Dts.Pipeline.Wrapper
<DtsPipelineComponent(DisplayName:="SampleComponent", ComponentType:=ComponentType.Transform)> _
Public Class BasicComponent
Inherits PipelineComponent
' TODO: Override the base class methods.
End Class
|