@Test
	public void testJDBCSink() {
		String data = UUID.randomUUID().toString();
		stream("dataSender", "trigger --payload='" + data + "'" + XD_DELIMITER + jdbcSink);

		String query = String.format("SELECT payload FROM %s", tableName);
		waitForTablePopulation(query, jdbcSink.getJdbcTemplate(), 1);
		assertEquals(
				data,
				jdbcSink.getJdbcTemplate().queryForObject(query, String.class));
	}
* Verifies that Jdbc sink has written the test data to the table.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/JdbcTest.java