IDTSPath90.AttachPathAndPropagateNotifications Method

Article
12/03/2008

Establishes a path between two components and notifies the affected components.

Namespace: Microsoft.SqlServer.Dts.Pipeline.Wrapper
Assembly: Microsoft.SqlServer.DTSPipelineWrap (in microsoft.sqlserver.dtspipelinewrap.dll)

Syntax

'Declaration
<DispIdAttribute(104)> _
Sub AttachPathAndPropagateNotifications ( _
    <InAttribute> pIDTSOutput As IDTSOutput90, _
    <InAttribute> pIDTSInput As IDTSInput90 _
)

[DispIdAttribute(104)] 
void AttachPathAndPropagateNotifications (
    [InAttribute] IDTSOutput90 pIDTSOutput,
    [InAttribute] IDTSInput90 pIDTSInput
)

[DispIdAttribute(104)] 
void AttachPathAndPropagateNotifications (
    [InAttribute] IDTSOutput90^ pIDTSOutput, 
    [InAttribute] IDTSInput90^ pIDTSInput
)

/** @attribute DispIdAttribute(104) */ 
void AttachPathAndPropagateNotifications (
    /** @attribute InAttribute() */ IDTSOutput90 pIDTSOutput, 
    /** @attribute InAttribute() */ IDTSInput90 pIDTSInput
)

DispIdAttribute(104) 
function AttachPathAndPropagateNotifications (
    pIDTSOutput : IDTSOutput90, 
    pIDTSInput : IDTSInput90
)

Parameters

pIDTSOutput
The output of the upstream component.

pIDTSInput
The input of the downstream component.

Remarks

In addition to establishing the flow of data between an IDTSOutput90 and an IDTSInput90 input, this method also notifies each component of the event by calling the OnInputPathAttached and OnOutputPathAttached methods of the component.

Example

The following code example demonstrates how to create a new path and establish the path between two components.

using System;
using Microsoft.SqlServer.Dts.Pipeline.Wrapper;
using Microsoft.SqlServer.Dts.Runtime;

...

    public static void main( string []args )
    {
        // Create the package and add a data flow task.
        Package p = new Package();
        TaskHost th = p.Executables.Add("DTS.Pipeline",null) as TaskHost;
        MainPipe m = th.InnerObject as MainPipe;

        // Create an OLE DB source component.
        IDTSComponentMetaData90 md = AddComponentToDataFlow( m , "DTSAdapter.OLEDBSource");
        IDTSComponentMetaData90 oledbSrc = m.ComponentMetaDataCollection.New();
        CManagedComponentWrapper90 srcWrp = oledbSrc.Instantiate();
        srcWrp.ProvideComponentProperties();

        // Create an OLE DB destination component.
        IDTSComponentMetaData90 oledbDest = AddComponentToDataFlow( m , "DTSAdapter.OLEDBDestination");
        IDTSComponentMetaData90 destWrp = oledbDest.ComponentMetaDataCollection.New();
        CManagedComponentWrapper90 destWrp = md.Instantiate();
        destWrp.ProvideComponentProperties();

        // Establish the path.
        IDTSPath90 path = m.PathCollection.New();
        path. AttachPathAndPropagateNotifications( oledbSrc.OutputCollection[0], oledbDest.InputCollection[0]);

}
public IDTSComponentMetaData90 AddComponentToDataFlow( MainPipe mp , string Component )
{
    if( mp != null )
    {
        IDTSComponentMetaData90 md = mp.ComponentMetaDataCollection.New();
        md.ComponentClassID = Component;
        CManagedComponentWrapper wrp = md.Instantiate();
        wrp.ProvideComponentProperties();

        return md;
    }
    throw new Exception( "DataFlow task does not exist.");
}

Imports Microsoft.SqlServer.Dts.Pipeline.Wrapper 
Imports Microsoft.SqlServer.Dts.Runtime

...

Public Shared Sub main(ByVal args As String()) 
 Dim p As Package = New Package 
 Dim th As TaskHost = CType(ConversionHelpers.AsWorkaround(p.Executables.Add("DTS.Pipeline", Nothing), GetType(TaskHost)), TaskHost) 
 Dim m As MainPipe = CType(ConversionHelpers.AsWorkaround(th.InnerObject, GetType(MainPipe)), MainPipe) 
 Dim md As IDTSComponentMetaData90 = AddComponentToDataFlow(m, "DTSAdapter.OLEDBSource") 
 Dim oledbSrc As IDTSComponentMetaData90 = m.ComponentMetaDataCollection.New 
 Dim srcWrp As CManagedComponentWrapper90 = oledbSrc.Instantiate 
 srcWrp.ProvideComponentProperties 
 Dim oledbDest As IDTSComponentMetaData90 = AddComponentToDataFlow(m, "DTSAdapter.OLEDBDestination") 
 Dim destWrp As IDTSComponentMetaData90 = oledbDest.ComponentMetaDataCollection.New 
 Dim destWrp As CManagedComponentWrapper90 = md.Instantiate 
 destWrp.ProvideComponentProperties 
 Dim path As IDTSPath90 = m.PathCollection.New 
 path.AttachPathAndPropagateNotifications(oledbSrc.OutputCollection(0), oledbDest.InputCollection(0)) 
End Sub 

Public Function AddComponentToDataFlow(ByVal mp As MainPipe, ByVal Component As String) As IDTSComponentMetaData90 
 If Not (mp Is Nothing) Then 
   Dim md As IDTSComponentMetaData90 = mp.ComponentMetaDataCollection.New 
   md.ComponentClassID = Component 
   Dim wrp As CManagedComponentWrapper = md.Instantiate 
   wrp.ProvideComponentProperties 
   Return md 
 End If 
 Throw New Exception("DataFlow task does not exist.") 
End Function

Thread Safety

Any public static (Shared in Microsoft Visual Basic) members of this type are thread safe. Any instance members are not guaranteed to be thread safe.

Platforms

Development Platforms

For a list of the supported platforms, see Hardware and Software Requirements for Installing SQL Server 2005.

Target Platforms