org.apache.camel.component.jdbc
Class JdbcProducer

java.lang.Object
  org.apache.camel.support.ServiceSupport
      org.apache.camel.impl.DefaultProducer
          org.apache.camel.component.jdbc.JdbcProducer

All Implemented Interfaces:

org.apache.camel.IsSingleton, org.apache.camel.Processor, org.apache.camel.Producer, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class JdbcProducer
extends org.apache.camel.impl.DefaultProducer

Version:

Field Summary

Fields inherited from class org.apache.camel.impl.DefaultProducer

log

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

JdbcProducer(JdbcEndpoint endpoint, DataSource dataSource, int readSize, Map<String,Object> parameters)

Method Summary

protected List<Map<String,Object>>	extractResultSetData(ResultSet rs) Extract the result from the ResultSet
JdbcEndpoint	getEndpoint()
void	process(org.apache.camel.Exchange exchange) Execute sql of exchange and set results on output
protected void	setGeneratedKeys(org.apache.camel.Exchange exchange, ResultSet generatedKeys) Sets the generated if any to the Exchange in headers : - JdbcConstants.JDBC_GENERATED_KEYS_ROW_COUNT : the row count of generated keys - JdbcConstants.JDBC_GENERATED_KEYS_DATA : the generated keys data
protected void	setResultSet(org.apache.camel.Exchange exchange, ResultSet rs) Sets the result from the ResultSet to the Exchange as its OUT body.

Methods inherited from class org.apache.camel.impl.DefaultProducer

createExchange, createExchange, createExchange, doStart, doStop, isSingleton, toString

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

start, stop

Constructor Detail

JdbcProducer

public JdbcProducer(JdbcEndpoint endpoint,
                    DataSource dataSource,
                    int readSize,
                    Map<String,Object> parameters)
             throws Exception

Throws:

Exception

Method Detail

getEndpoint

public JdbcEndpoint getEndpoint()

Specified by:

getEndpoint in interface org.apache.camel.Producer

Overrides:

getEndpoint in class org.apache.camel.impl.DefaultProducer

process

public void process(org.apache.camel.Exchange exchange)
             throws Exception

Execute sql of exchange and set results on output

Throws:

Exception

setGeneratedKeys

protected void setGeneratedKeys(org.apache.camel.Exchange exchange,
                                ResultSet generatedKeys)
                         throws SQLException

Sets the generated if any to the Exchange in headers : - JdbcConstants.JDBC_GENERATED_KEYS_ROW_COUNT : the row count of generated keys - JdbcConstants.JDBC_GENERATED_KEYS_DATA : the generated keys data

Parameters:

exchange - The exchange where to store the generated keys

generatedKeys - The result set containing the generated keys

Throws:

SQLException

setResultSet

protected void setResultSet(org.apache.camel.Exchange exchange,
                            ResultSet rs)
                     throws SQLException

Sets the result from the ResultSet to the Exchange as its OUT body.

Throws:

SQLException

extractResultSetData

protected List<Map<String,Object>> extractResultSetData(ResultSet rs)
                                                 throws SQLException

Extract the result from the ResultSet

Parameters:

rs - rs produced by the SQL request

Returns:

All the resulting rows containing each field of the ResultSet

Throws:

SQLException