MainPipeClass Kelas

Referensi

Definisi

Ruang nama:: Microsoft.SqlServer.Dts.Pipeline.Wrapper.Sql2012

Rakitan:: Microsoft.SqlServer.DTSPipelineWrap.dll

Penting

Beberapa informasi terkait produk prarilis yang dapat diubah secara signifikan sebelum dirilis. Microsoft tidak memberikan jaminan, tersirat maupun tersurat, sehubungan dengan informasi yang diberikan di sini.

public ref class MainPipeClass : Microsoft::SqlServer::Dts::Pipeline::Wrapper::Sql2012::MainPipe

[System.Runtime.InteropServices.ClassInterface(System.Runtime.InteropServices.ClassInterfaceType.None)]
[System.Runtime.InteropServices.Guid("5918251B-2970-45A4-AB5F-01C3C588FE5A")]
[System.Runtime.InteropServices.TypeLibType(System.Runtime.InteropServices.TypeLibTypeFlags.FCanCreate)]
public class MainPipeClass : Microsoft.SqlServer.Dts.Pipeline.Wrapper.Sql2012.MainPipe

[<System.Runtime.InteropServices.ClassInterface(System.Runtime.InteropServices.ClassInterfaceType.None)>]
[<System.Runtime.InteropServices.Guid("5918251B-2970-45A4-AB5F-01C3C588FE5A")>]
[<System.Runtime.InteropServices.TypeLibType(System.Runtime.InteropServices.TypeLibTypeFlags.FCanCreate)>]
type MainPipeClass = class
    interface IDTSPipeline100
    interface MainPipe
    interface IDTSObjectModel100

Public Class MainPipeClass
Implements MainPipe

Warisan: Object
MainPipeClass

Atribut: ClassInterfaceAttribute GuidAttribute TypeLibTypeAttribute

Penerapan: IDTSObjectModel100 IDTSPipeline100 MainPipe

Contoh

Contoh kode berikut menambahkan tugas aliran data ke paket, menambahkan komponen sumber OLE DB dan komponen tujuan OLE DB, dan menetapkan jalur di antara kedua komponen.

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

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]);  
        }  
    }  
}

Keterangan

Kelas ini mewakili tugas aliran data, dan digunakan saat membangun tata letak aliran data secara terprogram. Instans kelas dibuat dengan menambahkan tugas aliran data ke koleksi Executables dari Paket. Komponen ditambahkan ke tugas menggunakan ComponentMetaDataCollection properti . Koneksi dibuat di antara komponen menggunakan PathCollection properti .

Konstruktor

MainPipeClass()

Properti

AutoGenerateIDForNewObjects
BLOBTempStoragePath
BufferManager
BufferTempStoragePath
ComponentMetaDataCollection
DefaultBufferMaxRows
DefaultBufferSize
EnableCacheUpdate
EnableDisconnectedColumns
EngineThreads
Events
IDTSObjectModel100_AutoGenerateIDForNewObjects
IDTSObjectModel100_ComponentMetaDataCollection
IDTSObjectModel100_EnableCacheUpdate
IDTSObjectModel100_EnableDisconnectedColumns
IDTSObjectModel100_IsSavingXml
IDTSObjectModel100_PathCollection
IsSavingXml
PathCollection
PersistenceCustomPropertyCollection[DTSPersistenceFormat]
RunInOptimizedMode
VariableDispenser

Metode

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

Berlaku untuk

Keamanan Thread

Setiap anggota statis publik ( Dibagikan dalam Visual Basic) jenis ini aman untuk utas. Setiap anggota instans tidak dijamin aman untuk utas.

Bagikan melalui