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  

注解

该类代表数据流任务，用于程序化构建数据流布局。 通过将数据流任务添加到ExecutablesPackage集合中创建该类的实例。 组件是通过该 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	设置 used 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()	设置缓存从之前的版本升级。