PipelineBuffer.DirectErrorRow Método
Definición
Importante
Parte de la información hace referencia a la versión preliminar del producto, que puede haberse modificado sustancialmente antes de lanzar la versión definitiva. Microsoft no otorga ninguna garantía, explícita o implícita, con respecto a la información proporcionada aquí.
Envía una fila de PipelineBuffer a una IDTSOutput100 cuya propiedad IsErrorOut es true.
Sobrecargas
| DirectErrorRow(Int32, Int32, Int32) |
Envía una PipelineBuffer fila a una IDTSOutput100 cuya IsErrorOut propiedad es true. |
| DirectErrorRow(Int32, Int32, Int32, Int32) |
Envía una PipelineBuffer fila a una IDTSOutput100 cuya IsErrorOut propiedad es true. |
DirectErrorRow(Int32, Int32, Int32)
Envía una PipelineBuffer fila a una IDTSOutput100 cuya IsErrorOut propiedad es true.
public:
void DirectErrorRow(int outputID, int errorCode, int errorColumn);public void DirectErrorRow (int outputID, int errorCode, int errorColumn);member this.DirectErrorRow : int * int * int -> unitPublic Sub DirectErrorRow (outputID As Integer, errorCode As Integer, errorColumn As Integer)Parámetros
- outputID
- Int32
Id. de IDTSOutput100 de error donde se va a enviar la fila PipelineBuffer.
- errorCode
- Int32
El número de error que se produjo al procesar la fila.
- errorColumn
- Int32
Id. de la columna de PipelineBuffer que produjo el error.
Ejemplos
En el ejemplo de código siguiente se muestra cómo dirigir una fila de un búfer a una salida de error sincrónica mediante el DirectErrorRow método .
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;
else
defaultOutputID = ComponentMetaData.OutputCollection[0].ID;
while (buffer.NextRow())
{
try
{
/// 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
buffer.DirectRow(defaultOutputID);
}
catch
{
/// 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.");
}
else
{
/// No, the user specified to ignore the failure so
/// direct the row to the default output.
buffer.DirectRow(defaultOutputID);
}
}
}
}
Public Overrides Sub ProcessInput(ByVal inputID As Integer, ByVal buffer As PipelineBuffer)
Dim input As IDTSInput100 = ComponentMetaData.InputCollection.GetObjectByID(inputID)
Dim defaultOutputID As Integer = -1
Dim errorOutputID As Integer = -1
Dim errorOutputIndex As Integer = -1
GetErrorOutputInfo(errorOutputID, errorOutputIndex)
If errorOutputIndex = 0 Then
defaultOutputID = ComponentMetaData.OutputCollection(1).ID
Else
defaultOutputID = ComponentMetaData.OutputCollection(0).ID
End If
While buffer.NextRow
Try
buffer.DirectRow(defaultOutputID)
Catch
If input.ErrorRowDisposition = DTSRowDisposition.RD_RedirectRow Then
buffer.DirectErrorRow(errorOutputID, 0, errorColumnID)
Else
If input.ErrorRowDisposition = DTSRowDisposition.RD_FailComponent OrElse input.ErrorRowDisposition = DTSRowDisposition.RD_NotUsed Then
Throw New Exception("An error occurred, and the DTSRowDisposition is either not set, or is set to fail component.")
Else
buffer.DirectRow(defaultOutputID)
End If
End If
End Try
End While
End Sub
Comentarios
Los componentes de flujo de datos usan este método que tienen IDTSOutput100 objetos con la IsErrorOut propiedad establecida en true. Lo llama el componente cuando encuentra un error al procesar una fila de búfer y cuando RD_RedirectRow se especifica en la entrada, salida o columna.
Se aplica a
DirectErrorRow(Int32, Int32, Int32, Int32)
Envía una PipelineBuffer fila a una IDTSOutput100 cuya IsErrorOut propiedad es true.
public:
void DirectErrorRow(int row, int outputID, int errorCode, int errorColumn);public void DirectErrorRow (int row, int outputID, int errorCode, int errorColumn);member this.DirectErrorRow : int * int * int * int -> unitPublic Sub DirectErrorRow (row As Integer, outputID As Integer, errorCode As Integer, errorColumn As Integer)Parámetros
- row
- Int32
El índice de la fila que se va a dirigir a la salida de error.
- outputID
- Int32
Id. de IDTSOutput100 de error donde se va a enviar la fila PipelineBuffer.
- errorCode
- Int32
El número de error que se produjo al procesar la fila.
- errorColumn
- Int32
Id. de la columna de PipelineBuffer que produjo el error.
Comentarios
Un componente de flujo de datos llama a este método si el componente de flujo de datos tiene IDTSOutput100 objetos cuyas propiedades respectivas IsErrorOut se establecen en true. El componente llama a este método cuando el componente encuentra un error al procesar una fila de búfer y cuando RD_RedirectRow se especifica en la entrada, salida o columna.