@Test
	public void testJdbcSinkWithCustomColumnNamesWithUnderscores() throws Exception {
		JdbcSink jdbcSink = newJdbcSink().columns("foo_bar,bar_foo,bar_baz");

		HttpSource httpSource = newHttpSource();

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

		String query = String.format("SELECT foo_bar, bar_foo, bar_baz FROM %s", streamName);
		Map<String, Object> result = jdbcSink.getJdbcTemplate().queryForMap(query);
		assertEquals("hello", result.get("bar_foo"));
		assertEquals("5", result.get("foo_bar"));
		assertEquals("good_bye", result.get("bar_baz"));
	}
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