Esempio di Cammello Apache per inserire una riga in una tabella

Question

Voglio inserire exchange.body in una tabella di database per una delle condizioni del mio percorso.

• Esiste qualche esempio/esercitazione del componente camel-jdbc per inserire il corpo del messaggio?
• Posso importare la stessa istruzione SQL e passare exchange.body ad essa?

Ho guardato l'esempio http://camel.apache.org/jdbc.html, ma non riuscivo a capirlo.

Qui l'esempio di primavera è per me fonte di confusione. Non ho capito perché è l'impostazione del corpo come query SQL e di nuovo l'importazione di alcune query dal percorso classe. (Non vi è alcun esempio di query di inserimento menzionato.)

Answer 1

Probabilmente è necessario eseguire alcune ristrutturazioni del payload prima di inserirlo comunque, quindi non ci dovrebbero essere problemi per eseguire una trasformazione utilizzando qualsiasi metodo in Camel per impostare il corpo alla corretta istruzione INSERT.

L'importante è quale tipo di struttura del carico utile abbia il messaggio in arrivo. Nel caso di base - è una stringa - dovrebbe essere abbastanza semplice

// 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)"); 

Nel caso in cui il messaggio contiene strutture dati complesse, questo codice sarà ovviamente più complessa, ma è più o meno allo stesso modo regolare applicazione genererà Query SQL.

L'esempio classpath si sta riferendo a

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

mostra semplicemente come testare la componente JDBC avviando un server di database incorporato (Apache Derby) e popolarlo con alcuni dati iniziali (SQL/init.sql file). Questa parte non fa realmente parte del componente jdbc di base, ma semplicemente nella documentazione per ottenere ed eseguire un esempio senza la necessità di configurare un server DB e impostare le proprietà di connessione JDBC.

Detto questo, è possibile utilizzare il componente SQL per scenari più complessi.

Answer 2

Se si desidera inserire utilizzando la stessa istruzione (modifica solo dei parametri) - utilizzare SQL component.

Se si desidera inserire utilizzando istruzione SQL arbitraria nel componente - utilizzare JDBC component.

SQL utilizzo componente:

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 utilizzo componente:

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

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