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	Получает или устанавливает значение, указывающее, генерирует ли поток данных автоматически, и устанавливает свойство ID для новых объектов.
BLOBTempStoragePath	Получает или устанавливает значение, указывающее расположение файловой системы, где временно записываются крупные бинарные объекты (BLOB) на диск.
BufferManager	Получает менеджер буферов для основной трубы.
BufferTempStoragePath	Получает или устанавливает путь файловой системы, используемый для временного кэширования буферных данных.
ComponentMetaDataCollection	Получает сбор компонентов потока данных в задаче.
DefaultBufferMaxRows	Получает или устанавливает максимальное количество строк, которое задача допускает в буфере IDTSBuffer100 .
DefaultBufferSize	Получает или устанавливает стандартный размер объектов, IDTSBuffer100 созданных задачей.
EnableCacheUpdate	Получает или устанавливает значение, указывающее, позволяет ли задача потока данных обновлять кэш.
EnableDisconnectedColumns	Получает или устанавливает значение, указывающее, включает ли задача разъединённые столбцы.
EngineThreads	Определяет или устанавливает количество потоков, используемых задачей потока данных.
Events	Устанавливает интерфейс событий, который используется поток данных, и компоненты, содержащиеся в нём, для создания событий во время выполнения.
IDTSObjectModel100_AutoGenerateIDForNewObjects	Получает или устанавливает значение, указывающее, генерирует ли поток данных автоматически, и устанавливает свойство ID для новых объектов.
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()	Задаёт задачу data flow для обновления кэша по сравнению с предыдущей версией.
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()	Устанавливает обновление кэша по сравнению с предыдущей версией.