@Test
	public void testFileJdbcJob() {
		String data = UUID.randomUUID().toString();
		jdbcSink.getJdbcTemplate().getDataSource();
		FileJdbcJob job = new FileJdbcJob(DEFAULT_DIRECTORY, FileJdbcJob.DEFAULT_FILE_NAME,
				FileJdbcJob.DEFAULT_TABLE_NAME, FileJdbcJob.DEFAULT_NAMES,
				FileJdbcJob.DEFAULT_DELETE_FILES);

		job(jobName, job.toDSL(), true);
		// Setup data files to be used for test
		assertTrue(setupDataFiles(getContainerHostForJob(jobName), DEFAULT_DIRECTORY,
				DEFAULT_FILE_NAME + ".out", data));

		jobLaunch(jobName);
		String query = String.format("SELECT data FROM %s", tableName);

		waitForTablePopulation(query, jdbcSink.getJdbcTemplate(), 1);

		List<String> results = jdbcSink.getJdbcTemplate().queryForList(query, String.class);
		assertEquals(1, results.size());

		for (String result : results) {
			assertEquals(data, result);
		}
	}
Asserts that fileJdbcJob has written the test data from a file to the table.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/FileJdbcTest.java