org.culturegraph.mf.sql.pipe
Class SqlStreamPipe

java.lang.Object
  org.culturegraph.mf.framework.DefaultSender<R>
      org.culturegraph.mf.framework.DefaultStreamPipe<org.culturegraph.mf.framework.StreamReceiver>
          org.culturegraph.mf.sql.pipe.SqlStreamPipe

All Implemented Interfaces:

org.culturegraph.mf.framework.LifeCycle, org.culturegraph.mf.framework.Receiver, org.culturegraph.mf.framework.Sender<org.culturegraph.mf.framework.StreamReceiver>, org.culturegraph.mf.framework.StreamPipe<org.culturegraph.mf.framework.StreamReceiver>, org.culturegraph.mf.framework.StreamReceiver

@Description(value="Executes a prepared query for each record received.")
@In(value=org.culturegraph.mf.framework.StreamReceiver.class)
@Out(value=org.culturegraph.mf.framework.StreamReceiver.class)
public final class SqlStreamPipe
extends org.culturegraph.mf.framework.DefaultStreamPipe<org.culturegraph.mf.framework.StreamReceiver>

Executes a prepared query for each record received. Each row of the result sets produced by the query is emitted as a new record. The module also emits generated keys as new records. Use SqlStreamSink for SQL statements which do not produce any result sets.

Author:

Christoph Böhme

See Also:

SqlStreamSink

Field Summary

static String

ID_PARAMETER

Constructor Summary

SqlStreamPipe(Connection connection)

SqlStreamPipe(String datasource)

Method Summary

void	endRecord()
void	literal(String name, String value)
void	setIdColumnLabel(String idColumnLabel)
void	setQuery(String sql)
void	startRecord(String id)

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

endEntity, startEntity

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

ID_PARAMETER

public static final String ID_PARAMETER

See Also:

Constant Field Values

Constructor Detail

SqlStreamPipe

public SqlStreamPipe(String datasource)

SqlStreamPipe

public SqlStreamPipe(Connection connection)

Method Detail

setQuery

public void setQuery(String sql)

setIdColumnLabel

public void setIdColumnLabel(String idColumnLabel)

startRecord

public void startRecord(String id)

Specified by:

startRecord in interface org.culturegraph.mf.framework.StreamReceiver

Overrides:

startRecord in class org.culturegraph.mf.framework.DefaultStreamPipe<org.culturegraph.mf.framework.StreamReceiver>

endRecord

public void endRecord()

Specified by:

endRecord in interface org.culturegraph.mf.framework.StreamReceiver

Overrides:

endRecord in class org.culturegraph.mf.framework.DefaultStreamPipe<org.culturegraph.mf.framework.StreamReceiver>

literal

public void literal(String name,
                    String value)

Specified by:

literal in interface org.culturegraph.mf.framework.StreamReceiver

Overrides:

literal in class org.culturegraph.mf.framework.DefaultStreamPipe<org.culturegraph.mf.framework.StreamReceiver>