Compartir a través de


MainPipeClass Clase

Definición

Agrega y conecta componentes en un diseño de flujo de datos.

public ref class MainPipeClass : Microsoft::SqlServer::Dts::Pipeline::Wrapper::IDTSPipeline130, Microsoft::SqlServer::Dts::Pipeline::Wrapper::MainPipe
[System.Runtime.InteropServices.ClassInterface(System.Runtime.InteropServices.ClassInterfaceType.None)]
[System.Runtime.InteropServices.Guid("C4D4D1F8-B3EF-4A16-9E0B-BD837F067CAA")]
[System.Runtime.InteropServices.TypeLibType(System.Runtime.InteropServices.TypeLibTypeFlags.FCanCreate)]
public class MainPipeClass : Microsoft.SqlServer.Dts.Pipeline.Wrapper.IDTSPipeline130, Microsoft.SqlServer.Dts.Pipeline.Wrapper.MainPipe
[System.Runtime.InteropServices.ClassInterface(System.Runtime.InteropServices.ClassInterfaceType.None)]
[System.Runtime.InteropServices.TypeLibType(System.Runtime.InteropServices.TypeLibTypeFlags.FCanCreate)]
[System.Runtime.InteropServices.Guid("A28DC28C-BEA5-4208-AED4-82EB7A1DB758")]
public class MainPipeClass : Microsoft.SqlServer.Dts.Pipeline.Wrapper.IDTSPipeline130, Microsoft.SqlServer.Dts.Pipeline.Wrapper.MainPipe
[System.Runtime.InteropServices.ClassInterface(System.Runtime.InteropServices.ClassInterfaceType.None)]
[System.Runtime.InteropServices.TypeLibType(System.Runtime.InteropServices.TypeLibTypeFlags.FCanCreate)]
[System.Runtime.InteropServices.Guid("D9DA2996-AD06-4166-9C0C-C53E29834AF2")]
public class MainPipeClass : Microsoft.SqlServer.Dts.Pipeline.Wrapper.IDTSPipeline130, Microsoft.SqlServer.Dts.Pipeline.Wrapper.MainPipe
[<System.Runtime.InteropServices.ClassInterface(System.Runtime.InteropServices.ClassInterfaceType.None)>]
[<System.Runtime.InteropServices.Guid("C4D4D1F8-B3EF-4A16-9E0B-BD837F067CAA")>]
[<System.Runtime.InteropServices.TypeLibType(System.Runtime.InteropServices.TypeLibTypeFlags.FCanCreate)>]
type MainPipeClass = class
    interface IDTSPipeline100
    interface MainPipe
    interface IDTSObjectModel100
    interface IDTSPipeline130
[<System.Runtime.InteropServices.ClassInterface(System.Runtime.InteropServices.ClassInterfaceType.None)>]
[<System.Runtime.InteropServices.TypeLibType(System.Runtime.InteropServices.TypeLibTypeFlags.FCanCreate)>]
[<System.Runtime.InteropServices.Guid("A28DC28C-BEA5-4208-AED4-82EB7A1DB758")>]
type MainPipeClass = class
    interface IDTSPipeline100
    interface MainPipe
    interface IDTSObjectModel100
    interface IDTSPipeline130
[<System.Runtime.InteropServices.ClassInterface(System.Runtime.InteropServices.ClassInterfaceType.None)>]
[<System.Runtime.InteropServices.TypeLibType(System.Runtime.InteropServices.TypeLibTypeFlags.FCanCreate)>]
[<System.Runtime.InteropServices.Guid("D9DA2996-AD06-4166-9C0C-C53E29834AF2")>]
type MainPipeClass = class
    interface IDTSPipeline100
    interface MainPipe
    interface IDTSObjectModel100
    interface IDTSPipeline130
Public Class MainPipeClass
Implements IDTSPipeline130, MainPipe
Herencia
MainPipeClass
Atributos
Implementaciones

Ejemplos

En el ejemplo de código siguiente se agrega una tarea de flujo de datos a un paquete, se agrega un componente de origen OLE DB y un componente de destino OLE DB y se establece una ruta de acceso entre los dos componentes.

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]);  
        }  
    }  
}  
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  

Comentarios

Esta clase representa la tarea de flujo de datos y se usa cuando se crea mediante programación un diseño de flujo de datos. Se crea una instancia de la clase agregando la tarea flujo de datos a la Executables colección de .Package Los componentes se agregan a la tarea mediante la ComponentMetaDataCollection propiedad . Las conexiones se establecen entre componentes mediante la PathCollection propiedad .

Constructores

MainPipeClass()

Inicializa una nueva instancia de MainPipeClass.

Propiedades

AutoAdjustBufferSize

Establece automáticamente el tamaño de los búferes del flujo de datos.

AutoGenerateIDForNewObjects

Obtiene o establece un valor que especifica si un flujo de datos genera y establece automáticamente la propiedad del identificador para los objetos recién creados.

BLOBTempStoragePath

Obtiene o establece un valor que especifica la ubicación del sistema de archivos donde escribir temporalmente en el disco objetos binarios grandes (BLOB).

BufferManager

Obtiene el administrador de búfer de la canalización principal.

BufferTempStoragePath

Obtiene o establece la ruta de acceso al sistema de archivos usada para almacenar temporalmente en memoria caché los datos del búfer.

ComponentMetaDataCollection

Obtiene la colección de componentes de flujo de datos de la tarea.

DefaultBufferMaxRows

Obtiene o establece el número máximo de filas que permite la tarea en un búfer IDTSBuffer100.

DefaultBufferSize

Obtiene o establece el tamaño predeterminado de los objetos IDTSBuffer100 creados por una tarea.

EnableCacheUpdate

Obtiene o establece un valor que indica si la tarea de flujo de datos habilita las actualizaciones de caché.

EnableDisconnectedColumns

Obtiene o establece un valor que indica si la tarea habilita las columnas desconectadas.

EngineThreads

Obtiene o establece el número de subprocesos utilizados por una tarea Flujo de datos.

Events

Establece la interfaz de eventos que utiliza un flujo de datos y los componentes que contiene para producir eventos durante la ejecución.

IDTSObjectModel100_AutoGenerateIDForNewObjects

Obtiene o establece un valor que especifica si un flujo de datos genera y establece automáticamente la propiedad del identificador para los objetos recién creados.

IDTSObjectModel100_ComponentMetaDataCollection

Obtiene la colección de componentes de flujo de datos de la tarea.

IDTSObjectModel100_EnableCacheUpdate

Obtiene o establece un valor que indica si la tarea de flujo de datos habilita las actualizaciones de caché.

IDTSObjectModel100_EnableDisconnectedColumns

Obtiene o establece un valor que indica si la tarea de flujo de datos habilita las columnas desconectadas en la canalización principal.

IDTSObjectModel100_IsSavingXml

Obtiene o establece un valor que indica que la tarea de flujo de datos se guarde en formato Xml.

IDTSObjectModel100_PathCollection

Obtiene la colección IDTSPathCollection100 para una tarea Flujo de datos.

IDTSPipeline130_AutoGenerateIDForNewObjects

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_BLOBTempStoragePath

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_BufferManager

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_BufferTempStoragePath

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_ComponentMetaDataCollection

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_DefaultBufferMaxRows

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_DefaultBufferSize

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_EnableCacheUpdate

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_EnableDisconnectedColumns

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_EngineThreads

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_Events

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_IsSavingXml

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_PathCollection

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_PersistenceCustomPropertyCollection[DTSPersistenceFormat]

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_RunInOptimizedMode

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_VariableDispenser

Agrega y conecta componentes en un diseño de flujo de datos.

IsSavingXml

Obtiene o establece un valor que indica si la tarea se guarda en formato Xml.

PathCollection

Obtiene la colección IDTSPathCollection100 para una tarea Flujo de datos.

PersistenceCustomPropertyCollection[DTSPersistenceFormat]

Obtiene el formato de persistencia de la colección de propiedades personalizadas de la tarea Flujo de datos.

RunInOptimizedMode

Obtiene o establece un valor que especifica si una tarea Flujo de datos se ejecuta en modo optimizado.

VariableDispenser

Establece IDTSVariableDispenser100 que se emplea para bloquear la lectura y escritura de las variables de un paquete.

Métodos

GetNextPasteID()

Obtiene el siguiente identificador disponible generado por una tarea Flujo de datos.

GetObjectByID(Int32)

Recupera un objeto contenido en una tarea Flujo de datos.

IDTSObjectModel100_get_AutoGenerateIDForNewObjects()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSObjectModel100_get_ComponentMetaDataCollection()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSObjectModel100_get_EnableCacheUpdate()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSObjectModel100_get_EnableDisconnectedColumns()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSObjectModel100_get_IsSavingXml()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSObjectModel100_get_PathCollection()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSObjectModel100_GetObjectByID(Int32)

Recupera un objeto contenido en una tarea Flujo de datos.

IDTSObjectModel100_New()

Restablece el diseño de componentes en una tarea Flujo de datos.

IDTSObjectModel100_set_AutoGenerateIDForNewObjects(Boolean)

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSObjectModel100_set_EnableCacheUpdate(Boolean)

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSObjectModel100_set_EnableDisconnectedColumns(Boolean)

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSObjectModel100_set_IsSavingXml(Boolean)

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSObjectModel100_UpdateCacheOnInputColumns()

Establece la tarea de flujo de datos para que actualice la memoria caché desde la versión anterior.

IDTSPipeline130_get_AutoGenerateIDForNewObjects()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_get_BLOBTempStoragePath()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_get_BufferManager()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_get_BufferTempStoragePath()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_get_ComponentMetaDataCollection()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_get_DefaultBufferMaxRows()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_get_DefaultBufferSize()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_get_EnableCacheUpdate()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_get_EnableDisconnectedColumns()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_get_EngineThreads()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_get_IsSavingXml()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_get_PathCollection()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_get_PersistenceCustomPropertyCollection(DTSPersistenceFormat)

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_get_RunInOptimizedMode()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_GetNextPasteID()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_GetObjectByID(Int32)

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_New()

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_set_AutoGenerateIDForNewObjects(Boolean)

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_set_BLOBTempStoragePath(String)

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_set_BufferTempStoragePath(String)

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_set_DefaultBufferMaxRows(Int32)

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_set_DefaultBufferSize(Int32)

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_set_EnableCacheUpdate(Boolean)

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_set_EnableDisconnectedColumns(Boolean)

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_set_EngineThreads(Int32)

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_set_Events(IDTSComponentEvents100)

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_set_IsSavingXml(Boolean)

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_set_RunInOptimizedMode(Boolean)

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_set_VariableDispenser(IDTSVariableDispenser100)

Agrega y conecta componentes en un diseño de flujo de datos.

IDTSPipeline130_UpdateCacheOnInputColumns()

Agrega y conecta componentes en un diseño de flujo de datos.

New()

Crea una nueva instancia de MainPipeClass.

UpdateCacheOnInputColumns()

Establece la memoria caché para actualizar desde la versión anterior.

Se aplica a