public class JdbcSource extends AbstractModuleFixture<JdbcSink> implements Disposable
jdbc
ソースモジュールを表します。データを追加できるデータソースを埋め込んで、モジュールによって取得されるようにします。label
コンストラクターと説明 |
---|
JdbcSource(javax.sql.DataSource dataSource) |
修飾子と型 | メソッドと説明 |
---|---|
void | cleanup() この フィクスチャによって作成された可能性のあるリソースを解放します。 |
JdbcSource | fixedDelay(int delay) |
org.springframework.jdbc.core.JdbcTemplate | getJdbcTemplate() |
JdbcSource | query(java.lang.String query) |
protected java.lang.String | toDSL() ストリーム定義に含めるのに適したモジュールの表現を返します。 例: file --dir=xxxx --name=yyyy |
JdbcSource | update(java.lang.String update) |
label, toString
public org.springframework.jdbc.core.JdbcTemplate getJdbcTemplate()
protected java.lang.String toDSL()
AbstractModuleFixture
file --dir=xxxx --name=yyyy
AbstractModuleFixture<JdbcSink>
の toDSL
public void cleanup()
Disposable
Disposable
の cleanup
public JdbcSource update(java.lang.String update)
public JdbcSource query(java.lang.String query)
public JdbcSource fixedDelay(int delay)