@Test
	public void testJdbcSinkWithCustomColumnNames() throws Exception {
		JdbcSink jdbcSink = newJdbcSink().columns("foo,bar");

		HttpSource httpSource = newHttpSource();


		String streamName = generateStreamName().replaceAll("-", "_");
		stream().create(streamName, "%s | %s", httpSource, jdbcSink);
		String json = "{\"foo\":5, \"bar\": \"hello\"}";
		httpSource.ensureReady().postData(json);

		String query = String.format("SELECT foo, bar FROM %s", streamName);
		Result result = jdbcSink.getJdbcTemplate().queryForObject(query, new BeanPropertyRowMapper<>(Result.class));
		assertEquals("hello", result.getBar());
		assertEquals(5, result.getFoo());
	}
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