org.eclipse.smila.jdbc

Class JdbcFetcherPipelet

java.lang.Object

org.eclipse.smila.jdbc.AbstractJdbcPipelet

org.eclipse.smila.jdbc.JdbcFetcherPipelet

All Implemented Interfaces:

Pipelet

public class JdbcFetcherPipelet
extends AbstractJdbcPipelet

Pipelet that fetches data from a database via JDBC, using a statement which is parameterized by record values. The result of the pipelet is the given input record enriched with the database result. If the database result contains multiple rows, all values of a column are merged. The values for the PreparedStatement are selected from the input record by following the configured value paths. If a value path references a single value, this is used. If it references a sequence of values, the first value is used. In any other case, the value is set 'null'.

Field Summary

Fields inherited from class org.eclipse.smila.jdbc.AbstractJdbcPipelet

_configuration, PARAM_DB_PROPS, PARAM_DB_URL, PARAM_STMT, PARAM_VALUE_PATHS, VALUE_PATH_SEPARATOR

Constructor Summary

Constructors

Constructor and Description
JdbcFetcherPipelet()

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String[]	process(Blackboard blackboard, java.lang.String[] recordIds) process given records.

Methods inherited from class org.eclipse.smila.jdbc.AbstractJdbcPipelet

configure, getDbProps, getDbUrl, getStatement, getStatementValues

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcFetcherPipelet

public JdbcFetcherPipelet()

Method Detail

process

public java.lang.String[] process(Blackboard blackboard,
                         java.lang.String[] recordIds)
                           throws ProcessingException

Description copied from interface: Pipelet

process given records.

Parameters:

blackboard - Blackboard holding and managing the records.

recordIds - Ids of records to process.

Returns:

Ids of records to be passed into the next pipelet. By default this should be the same as the passed in recordIds unless there is a specific (businesslogic) reason not to do so.

Throws:

ProcessingException - error during processing.