public class JdbcSource extends AbstractModuleFixture<JdbcSink> implements Disposable
jdbc source module. Embeds a datasource to which
data can be added, so that it gets picked up by the module.label| Constructor and Description |
|---|
JdbcSource(javax.sql.DataSource dataSource) |
| Modifier and Type | Method and Description |
|---|---|
void |
cleanup()
Free up resources that this fixture may have created.
|
JdbcSource |
fixedDelay(int delay) |
org.springframework.jdbc.core.JdbcTemplate |
getJdbcTemplate() |
JdbcSource |
query(java.lang.String query) |
protected java.lang.String |
toDSL()
Returns a representation of the module suitable for inclusion in a stream definition, e.g.
file --dir=xxxx --name=yyyy |
JdbcSource |
update(java.lang.String update) |
label, toStringpublic org.springframework.jdbc.core.JdbcTemplate getJdbcTemplate()
protected java.lang.String toDSL()
AbstractModuleFixturefile --dir=xxxx --name=yyyytoDSL in class AbstractModuleFixture<JdbcSink>public void cleanup()
Disposablecleanup in interface Disposablepublic JdbcSource update(java.lang.String update)
public JdbcSource query(java.lang.String query)
public JdbcSource fixedDelay(int delay)