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()	获取数据流任务生成的下一个可用 ID。
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()	设置缓存以便从以前的版本升级。