PipelineBuffer.DirectErrorRow Method (Int32, Int32, Int32)


Sends a PipelineBuffer row to an IDTSOutput100 whose IsErrorOut property is true.

Namespace:   Microsoft.SqlServer.Dts.Pipeline
Assembly:  Microsoft.SqlServer.PipelineHost (in Microsoft.SqlServer.PipelineHost.dll)

public void DirectErrorRow(
	int outputID,
	int errorCode,
	int errorColumn


Type: System.Int32

The ID of the error IDTSOutput100 to send the PipelineBuffer row.

Type: System.Int32

The error number that occurred while processing the row.

Type: System.Int32

The ID of the PipelineBuffer column that caused the error.

This method is used by data flow components that have IDTSOutput100 objects with the IsErrorOut property set to true. It is called by the component when it encounters an error processing a buffer row, and when RD_RedirectRow is specified on the input, output, or column.

The following code example demonstrates how to direct a row in a buffer to a synchronous error output by using the DirectErrorRow method.

public override void ProcessInput(int inputID, PipelineBuffer buffer)
        IDTSInput100 input = ComponentMetaData.InputCollection.GetObjectByID(inputID);

        /// This code sample assumes the component has 2 outputs, one the default,
        /// the other the error output. If the errorOutputIndex returned from GetErrorOutputInfo
        /// is 0, then the default output is the second output in the collection.
        int defaultOutputID = -1;
        int errorOutputID = -1;
        int errorOutputIndex = -1;

        GetErrorOutputInfo(ref errorOutputID,ref errorOutputIndex);

        if (errorOutputIndex == 0)
            defaultOutputID = ComponentMetaData.OutputCollection[1].ID;
            defaultOutputID = ComponentMetaData.OutputCollection[0].ID;

        while (buffer.NextRow())
                /// TODO: Implement code to process the columns in the buffer row.

                /// Ideally, your code should detect potential exceptions prior to them occurring, rather
                /// than having a generic try/catch block such as this. 
                /// However, since the error or truncation implementation is specific to each component
                /// this sample focuses on actually directing the row, and not a single error or truncation.

                /// Unless an exception occurs, direct the row to the default 
                /// Yes. Has the user specified to redirect the row?
                if (input.ErrorRowDisposition == DTSRowDisposition.RD_RedirectRow)
                    /// Yes, direct the row to the error output.
                    /// TODO: Add code to include the errorColumnID
                    buffer.DirectErrorRow(errorOutputID, 0, errorColumnID);
                else if (input.ErrorRowDisposition == DTSRowDisposition.RD_FailComponent || input.ErrorRowDisposition == DTSRowDisposition.RD_NotUsed)
                    /// No, the user specified to fail the component, or the error row disposition was not set.
                    throw new Exception("An error occurred, and the DTSRowDisposition is either not set, or is set to fail component.");
                    /// No, the user specified to ignore the failure so 
                    /// direct the row to the default output.

Return to top