org.eclipse.smila.jdbc

Class JdbcLoggingPipelet

java.lang.Object

org.eclipse.smila.jdbc.AbstractJdbcPipelet

org.eclipse.smila.jdbc.JdbcLoggingPipelet

All Implemented Interfaces:

Pipelet

public class JdbcLoggingPipelet
extends AbstractJdbcPipelet

Pipelet that logs given statement (PreparedStatement) into a database via JdbcWriterService for each input record. 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
JdbcLoggingPipelet()

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

JdbcLoggingPipelet

public JdbcLoggingPipelet()

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.