MainPipeClass Класс

Определение

Пространство имен:

Microsoft.SqlServer.Dts.Pipeline.Wrapper

Сборка:

Microsoft.SqlServer.DTSPipelineWrap.dll

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

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

Наследование

Object

MainPipeClass

Атрибуты

ClassInterfaceAttribute GuidAttribute TypeLibTypeAttribute

Реализации

IDTSObjectModel100 IDTSPipeline100 IDTSPipeline130 MainPipe

Примеры

В следующем примере кода в пакет добавляется задача потока данных, добавляется исходный компонент 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()	Задает кэш для обновления из предыдущей версии.