MainPipeClass Clase

Definición

Espacio de nombres:

Microsoft.SqlServer.Dts.Pipeline.Wrapper

Ensamblado:

Microsoft.SqlServer.DTSPipelineWrap.dll

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.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.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

Object

MainPipeClass

Atributos

ClassInterfaceAttribute GuidAttribute TypeLibTypeAttribute

Implementaciones

IDTSObjectModel100 IDTSPipeline100 IDTSPipeline130 MainPipe

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.