PipelineBuffer.DirectRow Method

PipelineBuffer から指定された IDTSOutput90 に行を送信します。

名前空間: Microsoft.SqlServer.Dts.Pipeline
アセンブリ: Microsoft.SqlServer.PipelineHost (microsoft.sqlserver.pipelinehost.dll 内)

構文

'宣言
Public Sub DirectRow ( _
    outputID As Integer _
)

public void DirectRow (
    int outputID
)

public:
void DirectRow (
    int outputID
)

public void DirectRow (
    int outputID
)

public function DirectRow (
    outputID : int
)

パラメータ

• outputID
  PipelineBuffer 行が送信される IDTSOutput90 の ID です。

解説

更新されたサンプル コード :2005 年 12 月 5 日

DirectRow メソッドは、同じ ExclusionGroup に複数の出力を含むコンポーネントにより呼び出されます。これを使用して、PipelineBuffer 行を指定した出力 (コンポーネント内の特定の出力) に出力します。このメソッドはエラー出力にもエラー以外の出力にも使用できますが、DirectErrorRow メソッドは、行をエラー出力に送信するために使用されます。

同じ除外グループに 2 つの同期出力を持つコンポーネントが、行を特定の出力に出力させず、NextRow メソッドを使用してバッファを次の行に進めると、行は両方の出力に送信されます。

使用例

次の例は、同じ除外グループに 2 つの出力を含むコンポーネントを示します。ProcessInput の間、行は DirectRow メソッドを使用して、いずれかの出力に送信されます。

public override void ProvideComponentProperties()
{
    IDTSInput90 input = ComponentMetaData.InputCollection.New();
    Input.Name = "DTSSampleInput";

    IDTSOutput output = ComponentMetaData.OutputCollection.New();
    output.ExclusionGroup = 1;
    output.Name = "Output1";
    output.SynchronousInputID = input.ID;

    IDTSOutput output = ComponentMetaData.OutputCollection.New();
    output.ExclusionGroup = 1;
    output.Name = "Output2";
    output.SynchronousInputID = input.ID;
}
public override void ProcessInput(int inputID, PipelineBuffer buffer)
{
    IDTSInput90 input = ComponentMetaData.InputCollection.GetObjectByID(inputID);

    IDTSOutput90 output1 = ComponentMetaData.OutputCollection[0];
    IDTSOutput90 output2 = ComponentMetaData.OutputCollection[1];

    if(! buffer.EndOfRowset)
    {
        while( buffer.NextRow())
        {
            // TODO: Insert if/then block here.
            // If criteria is met, direct the buffer row to output1.
            buffer.DirectRow(output1.ID);
            // Otherwise, direct the row to output2.
            buffer.DirectRow(output2.ID);
        }
    }
}

Public Overrides Sub ProvideComponentProperties() 
 Dim input As IDTSInput90 = ComponentMetaData.InputCollection.New 
 Input.Name = "DTSSampleInput" 
 Dim output As IDTSOutput = ComponentMetaData.OutputCollection.New 
 output.ExclusionGroup = 1 
 output.Name = "Output1" 
 output.SynchronousInputID = input.ID 
 Dim output As IDTSOutput = ComponentMetaData.OutputCollection.New 
 output.ExclusionGroup = 1 
 output.Name = "Output2" 
 output.SynchronousInputID = input.ID 
End Sub 

Public  Overrides Sub ProcessInput(ByVal inputID As Integer, ByVal buffer As PipelineBuffer) 
 Dim input As IDTSInput90 = ComponentMetaData.InputCollection.GetObjectByID(inputID) 
 Dim output1 As IDTSOutput90 = ComponentMetaData.OutputCollection(0) 
 Dim output2 As IDTSOutput90 = ComponentMetaData.OutputCollection(1) 
 If Not buffer.EndOfRowset Then 
   While buffer.NextRow 
    ' TODO: Insert if/then block here.
    ' If criteria is met, direct the buffer row to output1.
     buffer.DirectRow(output1.ID) 
    ' Otherwise, direct the row to output2.
     buffer.DirectRow(output2.ID) 
   End While 
 End If 
End Sub

スレッド セーフ

この型の public static (Microsoft Visual Basic では共有 ) メンバは、スレッド セーフです。インスタンス メンバの場合は、スレッド セーフであるとは限りません。

プラットフォーム

開発プラットフォーム

サポートされているプラットフォームの一覧については、「SQL Server 2005 のインストールに必要なハードウェアおよびソフトウェア」を参照してください。

対象プラットフォーム

サポートされているプラットフォームの一覧については、「SQL Server 2005 のインストールに必要なハードウェアおよびソフトウェア」を参照してください。

参照

関連項目

PipelineBuffer Class
PipelineBuffer Members
Microsoft.SqlServer.Dts.Pipeline Namespace