public JdbcSink jdbc() {
		if (environment.getDataSource() == null) {
			return null;
		}
		jdbcSink = new JdbcSink(environment.getDataSource());

		if (!jdbcSink.isReady()) {
			throw new IllegalStateException("Unable to connect to database.");
		}
		return jdbcSink;
	}
Construct a new jdbcSink that will write the output to a table .

@return a JdbcSink instance.
spring-xd-integration-test/src/main/java/org/springframework/xd/integration/fixtures/Sinks.java