Ejemplo de Apache Camel para insertar una fila en una tabla

Question

Quiero insertar exchange.body en una tabla de base de datos para una de las condiciones de mi ruta.

• ¿Hay algún ejemplo/tutorial del componente camel-jdbc para insertar el cuerpo del mensaje?
• ¿Puedo importar la declaración SQL y pasarle exchange.body?

Miré http://camel.apache.org/jdbc.html ejemplo, pero no pude entenderlo.

Aquí el ejemplo de Spring es confuso para mí. No entendí por qué está configurando el cuerpo como consulta SQL e importando de nuevo una consulta desde la ruta de la clase. (No hay ningún ejemplo de consulta de inserción mencionado aquí.)

Answer 1

Es probable que necesite reestructurar su carga útil antes de insertarla de todos modos, por lo que probablemente no haya problema para realizar una transformación utilizando el método de Camel para configurar el cuerpo. a la declaración INSERT apropiada.

Lo importante es qué clase de estructura de carga tiene su mensaje entrante. En el caso básica - es una cadena - que debe ser bastante simple

// In a Java bean/processor before the JDBC endpoint. 
// Update: make sure to sanitize the payload from SQL injections if it contains user inputs or external data not generated by trusted sources. 
exchange.getIn().setBody("INSERT INTO MYTABLE VALUES('" + exchange.getIn().getBody(String.class) + "', 'fixedValue', 1.0, 42)"); 

En caso de que su mensaje contiene estructuras de datos complejas, este código será, por supuesto, ser más compleja, pero es más o menos la misma manera que la aplicación regular generará Consultas SQL.

La ruta de clase ejemplo usted se refiere a

<jdbc:embedded-database id="testdb" type="DERBY"> 
     <jdbc:script location="classpath:sql/init.sql"/> 
</jdbc:embedded-database> 

simplemente muestra cómo probar el componente JDBC iniciando un servidor de base de datos integrada (Apache Derby) y rellenarla con algunos datos iniciales (SQL/init.sql archivo). Esta parte no es realmente parte del componente core jdbc, sino simplemente en la documentación para iniciar y ejecutar una muestra sin necesidad de configurar un servidor DB y configurar las propiedades de la conexión JDBC.

Dicho esto, es posible que desee utilizar el componente SQL para escenarios más complejos.

Answer 2

Si desea insertar usando la misma instrucción (cambiando solo los parámetros) - use SQL component.

Si desea insertar usando declaración SQL arbitraria en el componente - use JDBC component. el uso de componentes

SQL:

from("direct:start").to("sql:insert into table foo (c1, c1) values ('#','#')"); 

com.google.common.collect.Lists; 
producerTemplate.sendBody("direct:start", Lists.newArrayList("value1","value2")); 

JDBC uso de componentes:

from("direct:start").to("jdbc:dataSource"); 

producerTemplate.sendBody("direct:start", "insert into table foo (c1, c1) values ('value1','value2')");