Respuesta a actualizaciones de base de datos

Implemente un flujo de mensajes que responda a las actualizaciones de la base de datos y presente los datos a otra aplicación.

Antes de empezar

  • Cree una tabla de sucesos (una tabla de base de datos que sirve como almacén temporal para datos de sucesos).
  • Cree un desencadenante en la tabla de datos de la aplicación. El desencadenante inserta una fila en el almacén de sucesos siempre que cambien los datos de la aplicación.
  • Configure el componente de tiempo de ejecución de IBM® Integration Bus para conectarse a la base de datos; consulte Habilitación de conexiones ODBC a las bases de datos.

Plataforma z/OSSi utiliza IBM DB2® en z/OS®, el ID de usuario (o el grupo de usuarios) requiere permiso para realizar una sentencia SELECT en SYSIBM.SYSJAROBJECTS.

No es necesario tener experiencia de ESQL para realizar esta tarea.

Acerca de esta tarea

Escenario: una empresa minorista utiliza una base de datos relacional para gestionar su inventario de acciones. Desde una adquisición reciente, se añade al entorno un nuevo conjunto de aplicaciones basadas en XML y WebSphere® MQ . Las aplicaciones notifican a las partes interesadas todos los cambios en los niveles de las acciones. Las aplicaciones tienen un modelo de esquema XSD predefinido que describe el mensaje de entrada.
Este diagrama se describe en el texto anterior.
IBM Integration Bus se utiliza para responder a las actualizaciones de la base de datos y para notificar la aplicación WebSphere MQ de estos cambios.
  1. Un nodo DatabaseInput recupera los datos.
  2. Un nodo de transformación, como un nodo Cálculo o un nodo Cartografía , transforma los datos en el formato de destino.
  3. Un nodo de salida o solicitud, como por ejemplo un nodo MQOutput , envía el mensaje transformado al sistema de destino.
Realizará las siguientes acciones:
  1. Descubrimiento del modelo de base de datos
  2. Crear un nuevo modelo de mensaje para la entrada de base de datos
  3. Crear el flujo de mensajes
  4. Probar el flujo

Descubrimiento del modelo de base de datos

Cree un archivo .dbm que utilizará para crear el modelo de mensaje. Cree un proyecto de diseño de datos y utilice un asistente para proporcionar detalles de IBM Integration Bus del almacén de sucesos de base de datos y la tabla de datos.

Procedimiento

  1. Haga clic en Archivo > Nuevo > Definición de DataBase.
  2. Pulse Nuevo para crear un nuevo proyecto de diseño de datos o seleccione un proyecto de diseño de datos existente en la lista desplegable.
  3. Seleccione el tipo de base de datos y la versión adecuados y, a continuación, pulse Siguiente.
  4. Seleccione una conexión JDBC existente o cree una conexión a la base de datos. Si crea una conexión, pruébela.
  5. Seleccione el esquema de la base de datos que utilizará para crear la definición de mensaje.
  6. Seleccione los elementos de la base de datos que necesita para el modelo. Necesita Tablas y Desencadenantes.
    Se crea el modelo de datos y puede ver los detalles de las tablas de base de datos que se describen en el esquema seleccionado.

Crear un nuevo modelo de mensaje para la entrada de base de datos

Cree un nuevo archivo de modelo de esquema de mensaje a partir de la definición de datos descubierta si necesita un modelo de la estructura de datos que presentará la entrada de base de datos. Necesita un modelo si desea correlacionar gráficamente esta entrada. El modelo también permite el completado automático de vías de acceso de la asistencia de contenido en el editor de ESQL si está transformando los datos en ESQL.

Procedimiento

  1. Pulse Archivo > Nuevo > Modelo de mensaje
  2. En la sección Otros , seleccione Base de datosy, a continuación, pulse Siguiente.
  3. Seleccione Crear un archivo de esquema XML desde una definición de base de datosy, a continuación, pulse Siguiente.
  4. Vaya a y seleccione el archivo .dbm de definición de base de datos que ha creado durante el descubrimiento y, a continuación, pulse Siguiente.
  5. Asegúrese de que las tablas de base de datos que se utilizarán estén seleccionadas.
  6. Pulse Siguiente y luego Acabado.

Resultados

El asistente Nuevo modelo de mensaje crea un archivo de modelo de mensaje de esquema XML en la ubicación que ha seleccionado.

Creación del flujo de mensajes

Cree y configure un flujo que conste de un nodo DatabaseInput , un nodo Cartografía y un nodo MQOutput . Utilizará el archivo de esquema que describe el mensaje de entrada para crear un archivo de definición de mensajes.

Procedimiento

  1. Cree un proyecto de integración que haga referencia al proyecto de diseño de datos y al proyecto de conjunto de mensajes que ha creado anteriormente.
  2. Cree un flujo de mensajes y arrastre un nodo de DatabaseInput al lienzo.
  3. Configure el nodo como se muestra a continuación:
    1. Establezca Fuente de datos en la conexión ODBC que ha creado anteriormente.
    2. Siga las instrucciones de Configuración de un nodo DatabaseInput para configurar los procedimientos ESQL para proporcionar detalles del almacén de sucesos y los datos de la aplicación.
  4. Para habilitar la correlación gráfica desde los datos de base de datos con el formato de mensaje de salida, además de Crear el nuevo modelo de mensaje para la entrada de base de datos como se ha indicado más arriba, también necesita un modelo de mensaje para el mensaje de destino. Puede ser un modelo de mensaje de esquema DFDL o XML, según corresponda a su escenario.
  5. Arrastre un nodo de Cartografía al flujo y configúrelo.
    1. Establezca el origen del mapa en el mensaje que ha definido en Crear un nuevo modelo de mensaje para la entrada de base de datos.
    2. Establezca el destino de correlación en el mensaje TARGET que acaba de definir.
    Puede utilizar otros métodos para transformar el mensaje; consulte Transformación y enriquecimiento de mensajes.
  6. Arrastre un nodo MQOutput al lienzo y establezca el nombre del gestor de colas y el nombre de cola.

Comprobación del flujo

Utilice el depurador para probar el flujo.

Procedimiento

  1. Inicie el depurador y, a continuación, añada puntos de interrupción al flujo.
  2. Despliegue el flujo.
  3. Cambie el origen de datos, por ejemplo añadiendo una fila nueva.
    Puede cambiar datos desde dentro de IBM Integration Toolkit. En Explorador de fuentes de datos, pulse el botón derecho del ratón en la tabla y seleccione Datos > Editar.
  4. Utilice el depurador para comprobar que el flujo funciona correctamente.