@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.helpers.DefaultStreamPipe<org.culturegraph.mf.framework.StreamReceiver>
Use SqlStreamSink
for SQL statements which do not produce any result
sets.
SqlStreamSink
Modifier and Type | Field and Description |
---|---|
static String |
ID_PARAMETER |
Constructor and Description |
---|
SqlStreamPipe(Connection connection) |
SqlStreamPipe(String dataSource) |
Modifier and Type | Method and Description |
---|---|
void |
endRecord() |
void |
literal(String name,
String value) |
void |
setIdColumnLabel(String idColumnLabel) |
void |
setQuery(String sql) |
void |
startRecord(String id) |
endEntity, startEntity
closeStream, isClosed, resetStream, setReceiver
public static final String ID_PARAMETER
public SqlStreamPipe(String dataSource)
public SqlStreamPipe(Connection connection)
public void setQuery(String sql)
public void setIdColumnLabel(String idColumnLabel)
public void startRecord(String id)
startRecord
in interface org.culturegraph.mf.framework.StreamReceiver
startRecord
in class org.culturegraph.mf.framework.helpers.DefaultStreamPipe<org.culturegraph.mf.framework.StreamReceiver>
public void endRecord()
endRecord
in interface org.culturegraph.mf.framework.StreamReceiver
endRecord
in class org.culturegraph.mf.framework.helpers.DefaultStreamPipe<org.culturegraph.mf.framework.StreamReceiver>
Copyright © 2017. All rights reserved.