org.springframework.xd.test.fixtures

Class JdbcSink

java.lang.Object

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

org.springframework.xd.test.fixtures.JdbcSink

All Implemented Interfaces:

Disposable

public class JdbcSink
extends AbstractModuleFixture<JdbcSink>
implements Disposable

Represents the jdbc sink module. Maintains an in memory relational database and exposes a JdbcTemplate so that assertions can be made against it.

Author:

Florent Biville, Glenn Renfro

Field Summary

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

label

Constructor Summary

Constructors

Constructor and Description
JdbcSink(javax.sql.DataSource dataSource) Initializes a JdbcSink with the DataSource.

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanup() If using a in memory database this method will shutdown the database.
JdbcSink	columns(java.lang.String columns) allows a user to set the columns (comma delimited list) that the sink will write its results to.
void	dropTable(java.lang.String tableName)
org.springframework.jdbc.core.JdbcTemplate	getJdbcTemplate()
JdbcSink	initializeDB(boolean initializeDB)
boolean	isInitializeDB()
boolean	isReady() Determines if a connection to the designated database can be made.
JdbcSink	tableName(java.lang.String tableName) Sets the table that the sink will write to.
protected java.lang.String	toDSL() Renders the DSL for this fixture.

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

JdbcSink

public JdbcSink(javax.sql.DataSource dataSource)

Initializes a JdbcSink with the DataSource. Using this DataSource a JDBCTemplate is created.

Parameters:

dataSource -

Method Detail

getJdbcTemplate

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

toDSL

protected java.lang.String toDSL()

Renders the DSL for this fixture.

Specified by:

toDSL in class AbstractModuleFixture<JdbcSink>

cleanup

public void cleanup()

If using a in memory database this method will shutdown the database.

Specified by:

cleanup in interface Disposable

dropTable

public void dropTable(java.lang.String tableName)

tableName

public JdbcSink tableName(java.lang.String tableName)

Sets the table that the sink will write to.

Parameters:

tableName - the name of the table.

Returns:

an instance to this jdbc sink.

columns

public JdbcSink columns(java.lang.String columns)

allows a user to set the columns (comma delimited list) that the sink will write its results to.

Parameters:

columns - a comma delimited list of column names.

Returns:

an instance to this jdbc sink.

isReady

public boolean isReady()

Determines if a connection to the designated database can be made.

Returns:

true if a connection can be made. False if not.

isInitializeDB

public boolean isInitializeDB()

initializeDB

public JdbcSink initializeDB(boolean initializeDB)