Поделиться через


MainPipeClass Класс

Определение

Добавляет и подключает компоненты в макет потока данных.

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
Наследование
MainPipeClass
Атрибуты
Реализации

Примеры

В следующем примере кода в пакет добавляется задача потока данных, добавляется исходный компонент OLE DB и целевой компонент OLE DB, а также устанавливается путь между двумя компонентами.

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  

Комментарии

Этот класс представляет задачу потока данных и используется при программном построении макета потока данных. Экземпляр класса создается путем добавления задачи потока данных в Executables коллекцию объекта Package. Компоненты добавляются в задачу с помощью ComponentMetaDataCollection свойства. Соединения устанавливаются между компонентами, использующими PathCollection свойство.

Конструкторы

MainPipeClass()

Инициализирует новый экземпляр класса MainPipeClass.

Свойства

AutoAdjustBufferSize

Автоматически задает размер буферов в потоке данных.

AutoGenerateIDForNewObjects

Возвращает или задает значение, указывающее, будет ли поток данных автоматически формировать и устанавливать свойство идентификатора для вновь созданных объектов.

BLOBTempStoragePath

Возвращает или задает значение, указывающее местоположение в файловой системе, используемое для временного хранения на диске больших двоичных объектов (BLOBs).

BufferManager

Возвращает диспетчер буферов для главного канала.

BufferTempStoragePath

Возвращает или задает путь файловой системы для временного кэширования данных буфера.

ComponentMetaDataCollection

Возвращает коллекцию компонентов потока данных в задаче.

DefaultBufferMaxRows

Возвращает или задает максимальное число строк, которое задача может поместить в буфер IDTSBuffer100.

DefaultBufferSize

Возвращает или задает размер по умолчанию для объекта IDTSBuffer100, созданного задачей.

EnableCacheUpdate

Возвращает или задает значение, указывающее, включает ли задача потока данных обновления кэша.

EnableDisconnectedColumns

Возвращает или задает значение, указывающее, включает ли задача отсоединенные столбцы.

EngineThreads

Возвращает или задает число потоков, используемых задачей потока данных.

Events

Задает интерфейс события, который используется потоком данных и содержащимися в нем компонентами для вызова событий во время выполнения.

IDTSObjectModel100_AutoGenerateIDForNewObjects

Возвращает или задает значение, указывающее, будет ли поток данных автоматически формировать и устанавливать свойство идентификатора для вновь созданных объектов.

IDTSObjectModel100_ComponentMetaDataCollection

Возвращает коллекцию компонентов потока данных в задаче.

IDTSObjectModel100_EnableCacheUpdate

Возвращает или задает значение, указывающее, включает ли задача потока данных обновления кэша.

IDTSObjectModel100_EnableDisconnectedColumns

Возвращает или задает значение, указывающее, включает ли задача потока данных отсоединенные столбцы в главном канале.

IDTSObjectModel100_IsSavingXml

Возвращает или задает значение, указывающее, сохраняет ли задача потока данных данные в XML-формате.

IDTSObjectModel100_PathCollection

Возвращает коллекцию IDTSPathCollection100 для задачи потока данных.

IDTSPipeline130_AutoGenerateIDForNewObjects

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_BLOBTempStoragePath

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_BufferManager

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_BufferTempStoragePath

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_ComponentMetaDataCollection

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_DefaultBufferMaxRows

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_DefaultBufferSize

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_EnableCacheUpdate

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_EnableDisconnectedColumns

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_EngineThreads

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_Events

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_IsSavingXml

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_PathCollection

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_PersistenceCustomPropertyCollection[DTSPersistenceFormat]

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_RunInOptimizedMode

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_VariableDispenser

Добавляет и подключает компоненты в макет потока данных.

IsSavingXml

Возвращает или задает значение, указывающее, сохраняет ли задача потока данных данные в XML-формате.

PathCollection

Возвращает коллекцию IDTSPathCollection100 для задачи потока данных.

PersistenceCustomPropertyCollection[DTSPersistenceFormat]

Возвращает формат хранения коллекции пользовательских свойств задачи потока данных.

RunInOptimizedMode

Возвращает или задает значение, показывающее, запущена ли задача потока данных в оптимизированном режиме.

VariableDispenser

Задает объект IDTSVariableDispenser100, использующийся для блокировки переменных в пакете для чтения и записи.

Методы

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()

Задает задачу потока данных для обновления кэша из предыдущей версии.

IDTSPipeline130_get_AutoGenerateIDForNewObjects()

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_get_BLOBTempStoragePath()

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_get_BufferManager()

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_get_BufferTempStoragePath()

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_get_ComponentMetaDataCollection()

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_get_DefaultBufferMaxRows()

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_get_DefaultBufferSize()

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_get_EnableCacheUpdate()

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_get_EnableDisconnectedColumns()

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_get_EngineThreads()

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_get_IsSavingXml()

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_get_PathCollection()

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_get_PersistenceCustomPropertyCollection(DTSPersistenceFormat)

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_get_RunInOptimizedMode()

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_GetNextPasteID()

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_GetObjectByID(Int32)

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_New()

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_set_AutoGenerateIDForNewObjects(Boolean)

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_set_BLOBTempStoragePath(String)

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_set_BufferTempStoragePath(String)

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_set_DefaultBufferMaxRows(Int32)

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_set_DefaultBufferSize(Int32)

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_set_EnableCacheUpdate(Boolean)

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_set_EnableDisconnectedColumns(Boolean)

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_set_EngineThreads(Int32)

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_set_Events(IDTSComponentEvents100)

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_set_IsSavingXml(Boolean)

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_set_RunInOptimizedMode(Boolean)

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_set_VariableDispenser(IDTSVariableDispenser100)

Добавляет и подключает компоненты в макет потока данных.

IDTSPipeline130_UpdateCacheOnInputColumns()

Добавляет и подключает компоненты в макет потока данных.

New()

Создает новый экземпляр MainPipeClass.

UpdateCacheOnInputColumns()

Задает кэш для обновления из предыдущей версии.

Применяется к