org.eclipse.smila.jdbc

Class AbstractJdbcPipelet

java.lang.Object

org.eclipse.smila.jdbc.AbstractJdbcPipelet

All Implemented Interfaces:

Pipelet

Direct Known Subclasses:

JdbcFetcherPipelet, JdbcLoggingPipelet, JdbcSelectPipelet

public abstract class AbstractJdbcPipelet
extends java.lang.Object
implements Pipelet

Abstract base class for JDBC Pipelets. Contains constants for database connection and SQL prepared statement parameters. 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

Modifier and Type	Field and Description
protected AnyMap	_configuration The pipelet configuration.
static java.lang.String	PARAM_DB_PROPS parameter for database specific properties, e.g. user/password.
static java.lang.String	PARAM_DB_URL parameter for database url.
static java.lang.String	PARAM_STMT parameter for the statement (PreparedStatement) to log.
static java.lang.String	PARAM_VALUE_PATHS parameter for the value paths which reference the values to use in the log statement.
static java.lang.String	VALUE_PATH_SEPARATOR The value path separator.

Constructor Summary

Constructors

Constructor and Description
AbstractJdbcPipelet()

Method Summary

Methods

Modifier and Type	Method and Description
void	configure(AnyMap configuration) set configuration of pipelet. called once after instantiation before the pipelet is actually used in a workflow.
protected AnyMap	getDbProps(ParameterAccessor paramAccessor)
protected java.lang.String	getDbUrl(ParameterAccessor paramAccessor)
protected java.lang.String	getStatement(ParameterAccessor paramAccessor)
protected java.util.List<Value>	getStatementValues(ParameterAccessor paramAccessor, AnyMap metadata)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.smila.processing.Pipelet

process

Field Detail

PARAM_DB_URL

public static final java.lang.String PARAM_DB_URL

parameter for database url.

See Also:

Constant Field Values

PARAM_DB_PROPS

public static final java.lang.String PARAM_DB_PROPS

parameter for database specific properties, e.g. user/password.

See Also:

Constant Field Values

PARAM_STMT

public static final java.lang.String PARAM_STMT

parameter for the statement (PreparedStatement) to log.

See Also:

Constant Field Values

PARAM_VALUE_PATHS

public static final java.lang.String PARAM_VALUE_PATHS

parameter for the value paths which reference the values to use in the log statement.

See Also:

Constant Field Values

VALUE_PATH_SEPARATOR

public static final java.lang.String VALUE_PATH_SEPARATOR

The value path separator.

See Also:

Constant Field Values

_configuration

protected AnyMap _configuration

The pipelet configuration.

Constructor Detail

AbstractJdbcPipelet

public AbstractJdbcPipelet()

Method Detail

getDbUrl

protected java.lang.String getDbUrl(ParameterAccessor paramAccessor)
                             throws ProcessingException

Throws:

ProcessingException

getDbProps

protected AnyMap getDbProps(ParameterAccessor paramAccessor)
                     throws ProcessingException

Throws:

ProcessingException

getStatement

protected java.lang.String getStatement(ParameterAccessor paramAccessor)
                                 throws ProcessingException

Throws:

ProcessingException

getStatementValues

protected java.util.List<Value> getStatementValues(ParameterAccessor paramAccessor,
                                       AnyMap metadata)
                                            throws ProcessingException

Throws:

ProcessingException

configure

public void configure(AnyMap configuration)
               throws ProcessingException

Description copied from interface: Pipelet

set configuration of pipelet. called once after instantiation before the pipelet is actually used in a workflow.

Specified by:

configure in interface Pipelet

Parameters:

configuration - configuration of pipelet.

Throws:

ProcessingException - configuration is not applicable for pipelet (missing properties, wrong datatypes)