- 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.helpers.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