Antes de empezar
Los nodos pueden invocar expresiones ESQL utilizando la sintaxis ESQL del nodo Compute. Puede crear y modificar los componentes del mensaje utilizando expresiones ESQL y puede hacer referencia a los elementos del mensaje de entrada y de los datos de una base de datos externa.
String dataSourceName = "miOrigenDatos";
String statement = "SET OutputRoot.XML.data = (SELECT Field2 FROM Database.Table1 WHERE Field1 = 1);";
String statement = "PASSTHRU( 'INSERT INTO Database.Table1 VALUES( InputRoot.XML.DataField1, InputRoot.XML.DataField2)');";
int transactionType = MbSQLStatement.SQL_TRANSACTION_AUTO;
MbSQLStatement sql = createSQLStatement(dataSourceName, statement, transactionType);Puede utilizar el método createSQLStatement(dataSource, statement) para tomar por omisión el tipo de transacción MbSQLStatement.SQL_TRANSACTION_AUTO).
MbMessageAssembly newAssembly = new MbMessageAssembly(assembly, assembly.getMessage());
sql.select(assembly, newAssembly);
sql.execute(assembly);
Para obtener más información sobre ESQL, consulte el apartado Visión general de ESQL.
Utilice la clase MbException para detectar excepciones y acceder a ellas. La clase MbException devuelve una matriz de objetos de excepción que representan los hijos de una excepción en la lista de excepciones de intermediario. Cada elemento devuelto especifica su tipo de excepción. Si una excepción no tiene hijos, se devuelve una matriz vacía. El siguiente código de ejemplo muestra cómo puede utilizarse la clase MbException en el método evaluate de su nodo definido por el usuario.
public void evaluate(MbMessageAssembly assembly, MbInputTerminal inTerm) throws MbException { try { // funcionalidad de plug-in } catch(MbException ex) { traverse(ex, 0); throw ex; // si se vuelve a generar, debe ser la excepción original que se ha captado } } void traverse(MbException ex, int level) { if(ex != null) { // Aquí realizar cualquier acción System.out.println("Level: " + level); System.out.println(ex.toString()); System.out.println("traceText: " + ex.getTraceText()); // atravesar la jerarquía MbException e[] = ex.getNestedExceptions(); int size = e.length; for(int i = 0; i < size; i++) { traverse(e[i], level + 1); } } }
Consulte el javadoc si desea ver más información detallada sobre la utilización de la clase MbException.
Puede desarrollar un proceso de mensaje definido por el usuario o un nodo de salida de tal forma que éste pueda acceder a todas las excepciones actuales. Por ejemplo, para detectar excepciones de base de datos, puede utilizar la clase MbSQLStatement. Esta clase establece el valor del atributo 'throwExceptionOnDatabaseError', que determina el comportamiento de intermediario cuando encuentra un error de base de datos. Si se establece en verdadero, cuando se genera una excepción, el método evaluate puede detectarla y manejarla en la extensión definida por el usuario.
El siguiente ejemplo de código muestra cómo utilizar la clase MbSQLStatement.
public void evaluate(MbMessageAssembly assembly, MbInputTerminal inTerm) throws MbException { MbMessage newMsg = new MbMessage(assembly.getMessage()); MbMessageAssembly newAssembly = new MbMessageAssembly(assembly, newMsg); String table = assembly.getMessage().getRootElement().getLastChild().getFirstChild().getName(); MbSQLStatement state = createSQLStatement( "nombreBd", "SET OutputRoot.XML.integer[] = PASSTHRU('SELECT * FROM " + table + "');" ); state.setThrowExceptionOnDatabaseError(false); state.setTreatWarningsAsErrors(true); state.select( assembly, newAssembly ); int sqlCode = state.getSQLCode(); if(sqlCode != 0) { // Aquí realizar manejo de errores System.out.println("sqlCode = " + sqlCode); System.out.println("sqlNativeError = " + state.getSQLNativeError()); System.out.println("sqlState = " + state.getSQLState()); System.out.println("sqlErrorText = " + state.getSQLErrorText()); } getOutputTerminal("out").propagate(newAssembly); }
Para grabar en un dispositivo de salida, es necesario volver a convertir el mensaje lógico (jerárquico) a una corriente de bits en su método evaluate. Para realizar esta tarea utilice el método getBuffer en MbMessage, como se indica a continuación:
public void evaluate( MbMessageAssembly assembly, MbInputTerminal in) throws MbException { MbMessage msg = assembly.getMessage(); byte[] bitstream = msg.getBuffer(); // grabar la corriente de bits en algún lugar writeBitstream( bitstream ); // método de usuario }
Normalmente, dado que para un nodo de salida el mensaje no se propaga a ningún terminal de salida, simplemente puede volver a este punto.