Classe MainPipeClass
Adds and connects components in a data flow layout.
Espace de noms : Microsoft.SqlServer.Dts.Pipeline.Wrapper
Assembly : Microsoft.SqlServer.DTSPipelineWrap (dans Microsoft.SqlServer.DTSPipelineWrap.dll)
Syntaxe
'Déclaration
<GuidAttribute("E3CFBEA8-1F48-40D8-91E1-2DEDC1EDDD56")> _
<ClassInterfaceAttribute()> _
Public Class MainPipeClass _
Implements IDTSPipeline100, MainPipe, IDTSObjectModel100
'Utilisation
Dim instance As MainPipeClass
[GuidAttribute("E3CFBEA8-1F48-40D8-91E1-2DEDC1EDDD56")]
[ClassInterfaceAttribute()]
public class MainPipeClass : IDTSPipeline100,
MainPipe, IDTSObjectModel100
[GuidAttribute(L"E3CFBEA8-1F48-40D8-91E1-2DEDC1EDDD56")]
[ClassInterfaceAttribute()]
public ref class MainPipeClass : IDTSPipeline100,
MainPipe, IDTSObjectModel100
[<GuidAttribute("E3CFBEA8-1F48-40D8-91E1-2DEDC1EDDD56")>]
[<ClassInterfaceAttribute()>]
type MainPipeClass =
class
interface IDTSPipeline100
interface MainPipe
interface IDTSObjectModel100
end
public class MainPipeClass implements IDTSPipeline100, MainPipe, IDTSObjectModel100
Notes
This class represents the data flow task, and is used when programmatically building a data flow layout. An instance of the class is created by adding the data flow task to the Executables collection of a Package. Components are added to the task using the ComponentMetaDataCollection property. Connections are established between components using the PathCollection property.
Exemples
The following code example adds a data flow task to a package, adds an OLE DB source component and an OLE DB destination component, and establishes a path between the two components.
using System;
using Microsoft.SqlServer.Dts.Runtime;
using Microsoft.SqlServer.Dts.Pipeline.Wrapper;
namespace Microsoft.Samples.SqlServer.Dts
{
public class Class1
{
public static void Main(string []args)
{
// Create the package.
Package p = new Package();
// Add the data flow task.
MainPipe mp = ((TaskHost)p.Executables.Add("SSIS.Pipeline.2")).InnerObject as MainPipe;
// Add the OLE DB source component.
IDTSComponentMetaData100 mdOleDbSrc = mp.ComponentMetaDataCollection.New();
mdOleDbSrc.ComponentClassID = "DTSAdapter.OleDbSource";
mdOleDbSrc.Name = "OLEDB Source";
CManagedComponentWrapper wrpOledbSrc = mdOleDbSrc.Instantiate();
// Add the OLE DB destination component.
IDTSComponentMetaData100 mdOleDbDest = mp.ComponentMetaDataCollection.New();
mdOleDbDest.ComponentClassID = "DTSAdapter.OleDbDestination";
mdOleDbDest.Name = "OLEDB Destination";
CManagedComponentWrapper wrpOledbDest = mdOleDbSrc.Instantiate();
// Create a path and attach the output of the source to the input of the destination.
IDTSPath100 path = mp.PathCollection.New();
path.AttachPathAndPropagateNotifications(mdOleDbSrc.OutputCollection[0], mdOleDbDest.InputCollection[0]);
}
}
}
Imports System
Imports Microsoft.SqlServer.Dts.Runtime
Imports Microsoft.SqlServer.Dts.Pipeline.Wrapper
Namespace Microsoft.Samples.SqlServer.Dts
Public Class Class1
Public Shared Sub Main(ByVal args As String())
Dim p As Package = New Package
Dim mp As MainPipe = CType(CType(p.Executables.Add("SSIS.Pipeline.2"), TaskHost).InnerObject, MainPipe)
Dim mdOleDbSrc As IDTSComponentMetaData100 = mp.ComponentMetaDataCollection.New
mdOleDbSrc.ComponentClassID = "DTSAdapter.OleDbSource"
mdOleDbSrc.Name = "OLEDB Source"
Dim wrpOledbSrc As CManagedComponentWrapper = mdOleDbSrc.Instantiate
Dim mdOleDbDest As IDTSComponentMetaData100 = mp.ComponentMetaDataCollection.New
mdOleDbDest.ComponentClassID = "DTSAdapter.OleDbDestination"
mdOleDbDest.Name = "OLEDB Destination"
Dim wrpOledbDest As CManagedComponentWrapper = mdOleDbSrc.Instantiate
Dim path As IDTSPath100 = mp.PathCollection.New
path.AttachPathAndPropagateNotifications(mdOleDbSrc.OutputCollection(0), mdOleDbDest.InputCollection(0))
End Sub
End Class
End Namespace
Hiérarchie d'héritage
System. . :: . .Object
Microsoft.SqlServer.Dts.Pipeline.Wrapper..::..MainPipeClass
Sécurité des threads
Tous les membres publics static (Shared dans Visual Basic) de ce type sont thread-safe. Il n'est pas garanti que les membres d'instance soient thread-safe.