Udostępnij za pośrednictwem

  • Artykuł

Metoda PipelineBuffer.SetEndOfRowset

Powiadamia PipelineBuffer składnik zostało zakończone, dodawanie wierszy do buforu.

Przestrzeń nazw:  Microsoft.SqlServer.Dts.Pipeline
Zestaw:  Microsoft.SqlServer.PipelineHost (w Microsoft.SqlServer.PipelineHost.dll)

Składnia

'Deklaracja
Public Sub SetEndOfRowset
'Użycie
Dim instance As PipelineBuffer

instance.SetEndOfRowset()

public void SetEndOfRowset()

public:
void SetEndOfRowset()

member SetEndOfRowset : unit -> unit 

public function SetEndOfRowset()

Uwagi

Data flow components call this method when they have finished adding rows to an OutputPipelineBuffer.Wywołanie SetEndOfRowset powiadamia aparat przepływ danych składnik zostało zakończone, dodawanie wierszy do PipelineBuffer.SetEndOfRowset Metoda następnie ustawia wartość EndOfRowset Właściwość true na końcowym buforu.

PipelineBuffer Daje NotOutputBufferException po Mode z PipelineBuffer jest Input i ta metoda jest wywoływana.

Przykłady

W poniższym przykładzie wywołuje składnik źródło SetEndOfRowset Aby zasygnalizować, że jest gotowy, dodawanie wierszy do PipelineBuffer.

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

namespace Microsoft.Samples.SqlServer.Dts
{
  [DtsPipelineComponent(DisplayName = "SampleComponent")]
  public class SampleSourceComponent: PipelineComponent
  {

    public override void ProvideComponentProperties()
    {
    IDTSOutput100 output = ComponentMetaData.OutputCollection.New();
    output.Name = "SourceOutput";

    IDTSOutputColumn100 column = output.OutputColumnCollection.New();
    column.Name = "Column1";
    column.SetDataTypeProperties(DataType.DT_R8, 0, 0, 0, 0);
    }

    public override void PrimeOutput(int outputs, int[] outputIDs, PipelineBuffer[] buffers)
    {
      double d = 123.5;
      buffers[0].AddRow();
      buffers[0].SetDouble(0, d);
      buffers[0].SetEndOfRowset();
    }
  }
}

Imports System 
Imports Microsoft.SqlServer.Dts.Pipeline 
Imports Microsoft.SqlServer.Dts.Pipeline.Wrapper 
Imports Microsoft.SqlServer.Dts.Runtime.Wrapper 
Namespace Microsoft.Samples.SqlServer.Dts 

 <DtsPipelineComponent(DisplayName="SampleComponent")> _ 
 Public Class SampleSourceComponent 
 Inherits PipelineComponent 

   Public  Overrides Sub ProvideComponentProperties() 
     Dim output As IDTSOutput100 = ComponentMetaData.OutputCollection.New 
     output.Name = "SourceOutput" 
     Dim column As IDTSOutputColumn100 = output.OutputColumnCollection.New 
     column.Name = "Column1" 
     column.SetDataTypeProperties(DataType.DT_R8, 0, 0, 0, 0) 
   End Sub 

   Public  Overrides Sub PrimeOutput(ByVal outputs As Integer, ByVal outputIDs As Integer(), ByVal buffers As PipelineBuffer()) 
     Dim d As Double = 123.5 
     buffers(0).AddRow 
     buffers(0).SetDouble(0, d) 
     buffers(0).SetEndOfRowset 
   End Sub 
 End Class 
End Namespace