org.culturegraph.mf.sql.source
Class SqlStreamSource<T>

java.lang.Object
  org.culturegraph.mf.framework.DefaultSender<R>
      org.culturegraph.mf.framework.DefaultObjectPipe<T,org.culturegraph.mf.framework.StreamReceiver>
          org.culturegraph.mf.sql.source.SqlStreamSource<T>

All Implemented Interfaces:

org.culturegraph.mf.framework.LifeCycle, org.culturegraph.mf.framework.ObjectPipe<T,org.culturegraph.mf.framework.StreamReceiver>, org.culturegraph.mf.framework.ObjectReceiver<T>, org.culturegraph.mf.framework.Receiver, org.culturegraph.mf.framework.Sender<org.culturegraph.mf.framework.StreamReceiver>

@Description(value="Executes a prepared statement or stored procedure for each object received.")
@In(value=java.lang.String.class)
@Out(value=org.culturegraph.mf.framework.StreamReceiver.class)
public final class SqlStreamSource<T>
extends org.culturegraph.mf.framework.DefaultObjectPipe<T,org.culturegraph.mf.framework.StreamReceiver>

Executes a prepared statement or stored procedure for each object received. The string value of the object is passed into the SQL statement as a parameter named ":obj". The result sets created by executing the statement are returned as records. For each row in the result set one record is emitted.

Author:

Christoph Böhme

Field Summary

static String

PARAMETER

Constructor Summary

SqlStreamSource(Connection connection)

SqlStreamSource(String datasource)

Method Summary

void	process(T obj)
void	setIdColumnLabel(String idColumnLabel)
void	setStatement(String sql)

Methods inherited from class org.culturegraph.mf.framework.DefaultSender

closeStream, isClosed, resetStream, setReceiver

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.culturegraph.mf.framework.LifeCycle

closeStream, resetStream

Methods inherited from interface org.culturegraph.mf.framework.Sender

setReceiver

Field Detail

PARAMETER

public static final String PARAMETER

See Also:

Constant Field Values

Constructor Detail

SqlStreamSource

public SqlStreamSource(String datasource)

SqlStreamSource

public SqlStreamSource(Connection connection)

Method Detail

setStatement

public void setStatement(String sql)

setIdColumnLabel

public void setIdColumnLabel(String idColumnLabel)

process

public void process(T obj)

Specified by:

process in interface org.culturegraph.mf.framework.ObjectReceiver<T>

Overrides:

process in class org.culturegraph.mf.framework.DefaultObjectPipe<T,org.culturegraph.mf.framework.StreamReceiver>