@Test
	public void testJdbcSinkWith2InsertionsAndDefaultConfiguration() throws Exception {
		JdbcSink jdbcSink = newJdbcSink();

		HttpSource httpSource = newHttpSource();


		String streamName = generateStreamName().replaceAll("-", "_");
		stream().create(streamName, "%s | %s", httpSource, jdbcSink);
		httpSource.ensureReady().postData("Hi there!");
		httpSource.postData("How are you?");

		String query = String.format("SELECT payload FROM %s", streamName);
		List<String> result = jdbcSink.getJdbcTemplate().queryForList(query, String.class);
		assertThat(result, contains("Hi there!", "How are you?"));
	}
Tests for the jdbc related modules.

@author Eric Bottard
@author Florent Biville
@author Glenn Renfro
spring-xd-shell/src/test/java/org/springframework/xd/shell/command/AbstractJdbcModulesTests.java