org.springframework.xd.test.fixtures

Class JdbcSource

java.lang.Object

org.springframework.xd.test.fixtures.AbstractModuleFixture<JdbcSink>

org.springframework.xd.test.fixtures.JdbcSource

All Implemented Interfaces:

Disposable

public class JdbcSource
extends AbstractModuleFixture<JdbcSink>
implements Disposable

Represents the jdbc source module. Embeds a datasource to which data can be added, so that it gets picked up by the module.

Author:

Eric Bottard

Field Summary

Fields inherited from class org.springframework.xd.test.fixtures.AbstractModuleFixture

label

Constructor Summary

Constructors

Constructor and Description
JdbcSource(javax.sql.DataSource dataSource)

Method Summary

Methods

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)

Methods inherited from class org.springframework.xd.test.fixtures.AbstractModuleFixture

label, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

JdbcSource

public JdbcSource(javax.sql.DataSource dataSource)

Method Detail

getJdbcTemplate

public org.springframework.jdbc.core.JdbcTemplate getJdbcTemplate()

toDSL

protected java.lang.String toDSL()

Description copied from class: AbstractModuleFixture

Returns a representation of the module suitable for inclusion in a stream definition, e.g. file --dir=xxxx --name=yyyy

Specified by:

toDSL in class AbstractModuleFixture<JdbcSink>

cleanup

public void cleanup()

Description copied from interface: Disposable

Free up resources that this fixture may have created.

Specified by:

cleanup in interface Disposable

update

public JdbcSource update(java.lang.String update)

query

public JdbcSource query(java.lang.String query)

fixedDelay

public JdbcSource fixedDelay(int delay)