Partager via


MainPipeClass Classe

Définition

public ref class MainPipeClass : Microsoft::SqlServer::Dts::Pipeline::Wrapper::Sql2012::MainPipe
[System.Runtime.InteropServices.ClassInterface(System.Runtime.InteropServices.ClassInterfaceType.None)]
[System.Runtime.InteropServices.Guid("5918251B-2970-45A4-AB5F-01C3C588FE5A")]
[System.Runtime.InteropServices.TypeLibType(System.Runtime.InteropServices.TypeLibTypeFlags.FCanCreate)]
public class MainPipeClass : Microsoft.SqlServer.Dts.Pipeline.Wrapper.Sql2012.MainPipe
[<System.Runtime.InteropServices.ClassInterface(System.Runtime.InteropServices.ClassInterfaceType.None)>]
[<System.Runtime.InteropServices.Guid("5918251B-2970-45A4-AB5F-01C3C588FE5A")>]
[<System.Runtime.InteropServices.TypeLibType(System.Runtime.InteropServices.TypeLibTypeFlags.FCanCreate)>]
type MainPipeClass = class
    interface IDTSPipeline100
    interface MainPipe
    interface IDTSObjectModel100
Public Class MainPipeClass
Implements MainPipe
Héritage
MainPipeClass
Attributs
Implémente

Exemples

L’exemple de code suivant ajoute une tâche de flux de données à un package, ajoute un composant source OLE DB et un composant de destination OLE DB, et établit un chemin entre les deux composants.

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("DTS.Pipeline"), 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  
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("DTS.Pipeline")).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]);  
        }  
    }  
}  

Remarques

Cette classe représente la tâche de flux de données et est utilisée lors de la création par programme d’une disposition de flux de données. Une instance de la classe est créée en ajoutant la tâche de flux de données à la collection Exécutables d’un package. Les composants sont ajoutés à la tâche à l’aide de la ComponentMetaDataCollection propriété . Les connexions sont établies entre les composants à l’aide de la PathCollection propriété .

Constructeurs

MainPipeClass()

Propriétés

AutoGenerateIDForNewObjects
BLOBTempStoragePath
BufferManager
BufferTempStoragePath
ComponentMetaDataCollection
DefaultBufferMaxRows
DefaultBufferSize
EnableCacheUpdate
EnableDisconnectedColumns
EngineThreads
Events
IDTSObjectModel100_AutoGenerateIDForNewObjects
IDTSObjectModel100_ComponentMetaDataCollection
IDTSObjectModel100_EnableCacheUpdate
IDTSObjectModel100_EnableDisconnectedColumns
IDTSObjectModel100_IsSavingXml
IDTSObjectModel100_PathCollection
IsSavingXml
PathCollection
PersistenceCustomPropertyCollection[DTSPersistenceFormat]
RunInOptimizedMode
VariableDispenser

Méthodes

GetNextPasteID()
GetObjectByID(Int32)
IDTSObjectModel100_get_AutoGenerateIDForNewObjects()
IDTSObjectModel100_get_ComponentMetaDataCollection()
IDTSObjectModel100_get_EnableCacheUpdate()
IDTSObjectModel100_get_EnableDisconnectedColumns()
IDTSObjectModel100_get_IsSavingXml()
IDTSObjectModel100_get_PathCollection()
IDTSObjectModel100_GetObjectByID(Int32)
IDTSObjectModel100_New()
IDTSObjectModel100_set_AutoGenerateIDForNewObjects(Boolean)
IDTSObjectModel100_set_EnableCacheUpdate(Boolean)
IDTSObjectModel100_set_EnableDisconnectedColumns(Boolean)
IDTSObjectModel100_set_IsSavingXml(Boolean)
IDTSObjectModel100_UpdateCacheOnInputColumns()
New()
UpdateCacheOnInputColumns()

S’applique à

Cohérence de thread

Tous les membres statiques publics ( partagés en Visual Basic) de ce type sont thread-safe. Tous les membres de l'instance ne sont pas garantis comme étant thread-safe.