diff --git a/batch/file-ingest-sftp-cf/artifacts/ingest-sftp-cf-1.0.0.jar b/batch/file-ingest-sftp-cf/artifacts/ingest-sftp-cf-1.0.0.jar
deleted file mode 100644
index adc4119..0000000
Binary files a/batch/file-ingest-sftp-cf/artifacts/ingest-sftp-cf-1.0.0.jar and /dev/null differ
diff --git a/batch/file-ingest-sftp-cf/data/people.csv b/batch/file-ingest-sftp-cf/data/people.csv
deleted file mode 100644
index 5f3258e..0000000
--- a/batch/file-ingest-sftp-cf/data/people.csv
+++ /dev/null
@@ -1,3 +0,0 @@
-Jane,Doe
-John,Doe
-Joe,Doe
\ No newline at end of file
diff --git a/batch/file-ingest-sftp-cf/pom.xml b/batch/file-ingest-sftp-cf/pom.xml
deleted file mode 100644
index 552b6f8..0000000
--- a/batch/file-ingest-sftp-cf/pom.xml
+++ /dev/null
@@ -1,128 +0,0 @@
-
-
- 4.0.0
- org.springframework
- ingest-sftp-cf
- 1.0.0
-
- org.springframework.boot
- spring-boot-starter-parent
- 2.0.1.RELEASE
-
-
- 1.8
- 3.7.0
- 1.2.2.RELEASE
- 5.0.4.RELEASE
- 2.4
- 1.6.0
- 2.0.2.RELEASE
-
-
-
- org.springframework.boot
- spring-boot-starter-batch
-
-
- com.h2database
- h2
-
-
- org.springframework.cloud
- spring-cloud-task-core
- ${spring.cloud.task.version}
-
-
- org.springframework.cloud
- spring-cloud-task-batch
- ${spring.cloud.task.version}
-
-
- commons-io
- commons-io
- ${commons.io.version}
-
-
- org.springframework.integration
- spring-integration-file
- ${spring.integration.version}
-
-
- org.springframework.integration
- spring-integration-sftp
- ${spring.integration.version}
-
-
- org.apache.sshd
- sshd-core
- ${sshd.core.version}
- test
-
-
- junit
- junit
- test
-
-
- org.hsqldb
- hsqldb
- test
-
-
- org.springframework.boot
- spring-boot-test
-
-
- org.springframework
- spring-test
-
-
- org.springframework.cloud
- spring-cloud-cloudfoundry-connector
- ${spring.cloud.connector.version}
-
-
- org.springframework.cloud
- spring-cloud-spring-service-connector
- ${spring.cloud.connector.version}
-
-
-
-
-
- org.springframework.boot
- spring-boot-maven-plugin
-
-
- org.apache.maven.plugins
- maven-compiler-plugin
- ${maven.compiler.plugin.version}
-
- ${java.version}
- ${java.version}
- ${java.version}
- ${java.version}
- -Xlint:all
-
-
-
-
-
-
- repository.spring.milestone
- Spring Milestone Repository
- http://repo.spring.io/milestone
-
-
-
-
- spring-milestones
- Spring Milestones
- https://repo.spring.io/milestone
-
- false
-
-
-
-
diff --git a/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/Application.java b/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/Application.java
deleted file mode 100644
index 1cbaf9d..0000000
--- a/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/Application.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package org.springframework.ingest;
-
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.cloud.task.configuration.EnableTask;
-
-/**
- * Main entry point for the ingest sample application.
- *
- * @author Chris Schaefer
- */
-@EnableTask
-@SpringBootApplication
-public class Application {
- public static void main(String[] args) throws Exception {
- SpringApplication.run(Application.class, args);
- }
-}
diff --git a/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/config/BatchConfiguration.java b/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/config/BatchConfiguration.java
deleted file mode 100644
index dffc988..0000000
--- a/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/config/BatchConfiguration.java
+++ /dev/null
@@ -1,137 +0,0 @@
-package org.springframework.ingest.config;
-
-import java.io.File;
-
-import javax.sql.DataSource;
-
-import org.apache.commons.io.FileUtils;
-
-import org.springframework.batch.core.ExitStatus;
-import org.springframework.batch.core.Job;
-import org.springframework.batch.core.Step;
-import org.springframework.batch.core.StepExecution;
-import org.springframework.batch.core.StepExecutionListener;
-import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
-import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
-import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
-import org.springframework.batch.core.configuration.annotation.StepScope;
-import org.springframework.batch.core.launch.support.RunIdIncrementer;
-import org.springframework.batch.item.ItemProcessor;
-import org.springframework.batch.item.ItemStreamReader;
-import org.springframework.batch.item.ItemWriter;
-import org.springframework.batch.item.database.builder.JdbcBatchItemWriterBuilder;
-import org.springframework.batch.item.file.builder.FlatFileItemReaderBuilder;
-
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.boot.context.properties.EnableConfigurationProperties;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.core.io.FileSystemResource;
-import org.springframework.core.io.Resource;
-
-import org.springframework.ingest.domain.Person;
-import org.springframework.ingest.mapper.fieldset.PersonFieldSetMapper;
-import org.springframework.ingest.processor.PersonItemProcessor;
-import org.springframework.ingest.resource.RemoteResource;
-import org.springframework.ingest.resource.sftp.SftpRemoteResource;
-
-/**
- * Class used to configure the batch job related beans.
- *
- * @author Chris Schaefer
- */
-@Configuration
-@EnableBatchProcessing
-@EnableConfigurationProperties(BatchConfigurationProperties.class)
-public class BatchConfiguration {
- private final DataSource dataSource;
- private final JobBuilderFactory jobBuilderFactory;
- private final StepBuilderFactory stepBuilderFactory;
- private final BatchConfigurationProperties batchConfigurationProperties;
-
- @Autowired
- public BatchConfiguration(final DataSource dataSource, final JobBuilderFactory jobBuilderFactory,
- final StepBuilderFactory stepBuilderFactory,
- final BatchConfigurationProperties batchConfigurationProperties) {
- this.dataSource = dataSource;
- this.jobBuilderFactory = jobBuilderFactory;
- this.stepBuilderFactory = stepBuilderFactory;
- this.batchConfigurationProperties = batchConfigurationProperties;
- }
-
- @Bean
- @StepScope
- public StepExecutionListener ingestStepExecutionListener(@Value("#{jobParameters['remoteFilePath']}") String remoteFilePath,
- @Value("#{jobParameters['localFilePath']}") String localFilePath) {
- return new StepExecutionListener() {
- @Override
- public void beforeStep(StepExecution stepExecution) {
- try {
- Resource fetchedResource = remoteResource().getResource(remoteFilePath);
- FileUtils.copyInputStreamToFile(fetchedResource.getInputStream(), new File(localFilePath));
- }
- catch (Exception e) {
- throw new RuntimeException("Could not write remote file to local disk", e);
- }
- }
-
- @Override
- public ExitStatus afterStep(StepExecution stepExecution) {
- return null;
- }
- };
- }
-
- @Bean
- @StepScope
- public ItemStreamReader reader(@Value("#{jobParameters['localFilePath']}") String localFilePath) throws Exception {
- return new FlatFileItemReaderBuilder()
- .name("reader")
- .resource(new FileSystemResource(localFilePath))
- .delimited()
- .names(new String[] {"firstName", "lastName"})
- .fieldSetMapper(new PersonFieldSetMapper())
- .build();
- }
-
- @Bean
- public ItemProcessor processor() {
- return new PersonItemProcessor();
- }
-
- @Bean
- public ItemWriter writer() {
- return new JdbcBatchItemWriterBuilder()
- .beanMapped()
- .dataSource(this.dataSource)
- .sql("INSERT INTO people (first_name, last_name) VALUES (:firstName, :lastName)")
- .build();
- }
-
- @Bean
- public Job ingestJob() throws Exception {
- return jobBuilderFactory.get("ingestJob")
- .incrementer(new RunIdIncrementer())
- .flow(step1())
- .end()
- .build();
- }
-
- @Bean
- public Step step1() throws Exception {
- return stepBuilderFactory.get("ingest")
- .chunk(10)
- .reader(reader(null))
- .processor(processor())
- .writer(writer())
- .listener(ingestStepExecutionListener(null, null))
- .build();
- }
-
- @Bean
- public RemoteResource remoteResource() {
- return new SftpRemoteResource(batchConfigurationProperties.getSftpHost(), batchConfigurationProperties.getSftpPort(),
- batchConfigurationProperties.getSftpUsername(), batchConfigurationProperties.getSftpPassword());
- }
-}
diff --git a/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/config/BatchConfigurationProperties.java b/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/config/BatchConfigurationProperties.java
deleted file mode 100644
index b5db31f..0000000
--- a/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/config/BatchConfigurationProperties.java
+++ /dev/null
@@ -1,48 +0,0 @@
-package org.springframework.ingest.config;
-
-import org.springframework.boot.context.properties.ConfigurationProperties;
-
-/**
- * Configuration Properties for BatchConfiguration
- *
- * @author Chris Schaefer
- */
-@ConfigurationProperties
-public class BatchConfigurationProperties {
- private String sftpHost;
- private Integer sftpPort;
- private String sftpUsername;
- private String sftpPassword;
-
- public String getSftpHost() {
- return sftpHost;
- }
-
- public void setSftpHost(String sftpHost) {
- this.sftpHost = sftpHost;
- }
-
- public Integer getSftpPort() {
- return sftpPort;
- }
-
- public void setSftpPort(Integer sftpPort) {
- this.sftpPort = sftpPort;
- }
-
- public String getSftpUsername() {
- return sftpUsername;
- }
-
- public void setSftpUsername(String sftpUsername) {
- this.sftpUsername = sftpUsername;
- }
-
- public String getSftpPassword() {
- return sftpPassword;
- }
-
- public void setSftpPassword(String sftpPassword) {
- this.sftpPassword = sftpPassword;
- }
-}
diff --git a/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/domain/Person.java b/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/domain/Person.java
deleted file mode 100644
index edf03d9..0000000
--- a/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/domain/Person.java
+++ /dev/null
@@ -1,29 +0,0 @@
-package org.springframework.ingest.domain;
-
-/**
- * Domain object representing data about a Person.
- *
- * @author Chris Schaefer
- */
-public class Person {
- private final String firstName;
- private final String lastName;
-
- public Person(final String firstName, final String lastName) {
- this.firstName = firstName;
- this.lastName = lastName;
- }
-
- public String getFirstName() {
- return firstName;
- }
-
- public String getLastName() {
- return lastName;
- }
-
- @Override
- public String toString() {
- return "First name: " + firstName + " , last name: " + lastName;
- }
-}
diff --git a/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/mapper/fieldset/PersonFieldSetMapper.java b/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/mapper/fieldset/PersonFieldSetMapper.java
deleted file mode 100644
index 4b3f6cf..0000000
--- a/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/mapper/fieldset/PersonFieldSetMapper.java
+++ /dev/null
@@ -1,21 +0,0 @@
-package org.springframework.ingest.mapper.fieldset;
-
-import org.springframework.batch.item.file.mapping.FieldSetMapper;
-import org.springframework.batch.item.file.transform.FieldSet;
-
-import org.springframework.ingest.domain.Person;
-
-/**
- * Maps the provided FieldSet into a Person object.
- *
- * @author Chris Schaefer
- */
-public class PersonFieldSetMapper implements FieldSetMapper {
- @Override
- public Person mapFieldSet(FieldSet fieldSet) {
- String firstName = fieldSet.readString(0);
- String lastName = fieldSet.readString(1);
-
- return new Person(firstName, lastName);
- }
-}
diff --git a/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/processor/PersonItemProcessor.java b/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/processor/PersonItemProcessor.java
deleted file mode 100644
index 6d2802c..0000000
--- a/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/processor/PersonItemProcessor.java
+++ /dev/null
@@ -1,29 +0,0 @@
-package org.springframework.ingest.processor;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import org.springframework.batch.item.ItemProcessor;
-import org.springframework.ingest.domain.Person;
-
-/**
- * Processes the providing record, transforming the data into
- * uppercase characters.
- *
- * @author Chris Schaefer
- */
-public class PersonItemProcessor implements ItemProcessor {
- private static final Logger LOGGER = LoggerFactory.getLogger(PersonItemProcessor.class);
-
- @Override
- public Person process(Person person) throws Exception {
- String firstName = person.getFirstName().toUpperCase();
- String lastName = person.getLastName().toUpperCase();
-
- Person processedPerson = new Person(firstName, lastName);
-
- LOGGER.info("Processed: " + person + " into: " + processedPerson);
-
- return processedPerson;
- }
-}
diff --git a/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/resource/RemoteResource.java b/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/resource/RemoteResource.java
deleted file mode 100644
index 01da55e..0000000
--- a/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/resource/RemoteResource.java
+++ /dev/null
@@ -1,12 +0,0 @@
-package org.springframework.ingest.resource;
-
-import org.springframework.core.io.Resource;
-
-/**
- * Interface definition for remote Resource implementations.
- *
- * @author Chris Schaefer
- */
-public interface RemoteResource {
- Resource getResource(String resourceLocation);
-}
diff --git a/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/resource/sftp/SftpRemoteResource.java b/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/resource/sftp/SftpRemoteResource.java
deleted file mode 100644
index 2fea44b..0000000
--- a/batch/file-ingest-sftp-cf/src/main/java/org/springframework/ingest/resource/sftp/SftpRemoteResource.java
+++ /dev/null
@@ -1,81 +0,0 @@
-package org.springframework.ingest.resource.sftp;
-
-import java.io.InputStream;
-
-import org.apache.commons.io.IOUtils;
-
-import org.springframework.core.io.ByteArrayResource;
-import org.springframework.core.io.Resource;
-import org.springframework.ingest.resource.RemoteResource;
-import org.springframework.integration.file.remote.InputStreamCallback;
-import org.springframework.integration.file.remote.RemoteFileOperations;
-import org.springframework.integration.sftp.session.DefaultSftpSessionFactory;
-import org.springframework.integration.sftp.session.SftpRemoteFileTemplate;
-import org.springframework.util.Assert;
-
-/**
- * RemoteResource implementation utilizing a Spring Integration SftpRemoteFileTemplate
- * to connect and return a file as a Spring Resource.
- *
- * @author Chris Schaefer
- */
-public class SftpRemoteResource implements RemoteResource {
- private static final Integer DEFAULT_SFTP_PORT = 22;
- private static final String LOCALHOST = "127.0.0.1";
-
- private final String host;
- private final Integer port;
- private final String username;
- private final String password;
-
- public SftpRemoteResource(String host, Integer port, String username, String password) {
- Assert.hasText(username, "Username must be defined");
- Assert.hasText(password, "Password must be defined");
-
- this.host = host;
- this.port = port;
- this.username = username;
- this.password = password;
- }
-
- @Override
- public Resource getResource(String resourceLocation) {
- DefaultSftpSessionFactory sessionFactory = getSessionFactory();
- RemoteFileOperations remoteFileOperations = new SftpRemoteFileTemplate(sessionFactory);
-
- FileFetcher filefetcher = new FileFetcher();
- remoteFileOperations.get(resourceLocation, filefetcher);
-
- return new ByteArrayResource(filefetcher.getBytes());
- }
-
- private DefaultSftpSessionFactory getSessionFactory() {
- DefaultSftpSessionFactory sessionFactory = new DefaultSftpSessionFactory();
- sessionFactory.setHost(host != null ? host : LOCALHOST);
- sessionFactory.setPort(port != null ? port : DEFAULT_SFTP_PORT);
- sessionFactory.setUser(username);
- sessionFactory.setPassword(password);
- sessionFactory.setAllowUnknownKeys(true);
-
- return sessionFactory;
- }
-
-
- private static class FileFetcher implements InputStreamCallback {
- private byte[] bytes;
-
- @Override
- public void doWithInputStream(InputStream inputStream) {
- try {
- bytes = IOUtils.toByteArray(inputStream);
- }
- catch (Exception e) {
- throw new RuntimeException("Failed to convert InputStream to byte array", e);
- }
- }
-
- public byte[] getBytes() {
- return bytes;
- }
- }
-}
diff --git a/batch/file-ingest-sftp-cf/src/main/resources/application.properties b/batch/file-ingest-sftp-cf/src/main/resources/application.properties
deleted file mode 100644
index df2d585..0000000
--- a/batch/file-ingest-sftp-cf/src/main/resources/application.properties
+++ /dev/null
@@ -1,2 +0,0 @@
-spring.application.name=fileIngestSftp
-spring.datasource.initialization-mode=always
diff --git a/batch/file-ingest-sftp-cf/src/main/resources/schema-all.sql b/batch/file-ingest-sftp-cf/src/main/resources/schema-all.sql
deleted file mode 100644
index 870871d..0000000
--- a/batch/file-ingest-sftp-cf/src/main/resources/schema-all.sql
+++ /dev/null
@@ -1,6 +0,0 @@
-CREATE TABLE IF NOT EXISTS people (
- person_id MEDIUMINT NOT NULL AUTO_INCREMENT,
- first_name VARCHAR(20),
- last_name VARCHAR(20),
- PRIMARY KEY (person_id)
-);
diff --git a/batch/file-ingest-sftp-cf/src/test/java/org/springframework/ingest/config/BatchConfigurationTests.java b/batch/file-ingest-sftp-cf/src/test/java/org/springframework/ingest/config/BatchConfigurationTests.java
deleted file mode 100644
index 8a02f43..0000000
--- a/batch/file-ingest-sftp-cf/src/test/java/org/springframework/ingest/config/BatchConfigurationTests.java
+++ /dev/null
@@ -1,202 +0,0 @@
-package org.springframework.ingest.config;
-
-import org.junit.runner.RunWith;
-import org.springframework.batch.core.BatchStatus;
-import org.springframework.batch.core.Job;
-import org.springframework.batch.core.JobExecution;
-import org.springframework.batch.core.JobParameters;
-import org.springframework.batch.core.JobParametersBuilder;
-import org.springframework.batch.core.Step;
-import org.springframework.batch.core.launch.JobLauncher;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.context.properties.EnableConfigurationProperties;
-import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.context.annotation.AnnotationConfigApplicationContext;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.core.env.ConfigurableEnvironment;
-import org.springframework.core.env.MapPropertySource;
-import org.springframework.core.env.StandardEnvironment;
-import org.springframework.core.io.ResourceLoader;
-import org.springframework.jdbc.core.JdbcTemplate;
-import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseFactory;
-import org.springframework.jdbc.datasource.init.DatabasePopulatorUtils;
-import org.springframework.jdbc.datasource.init.ResourceDatabasePopulator;
-import org.springframework.test.annotation.DirtiesContext;
-import org.springframework.test.context.junit4.SpringRunner;
-import org.springframework.util.ClassUtils;
-
-import org.apache.commons.io.FileUtils;
-
-import org.apache.sshd.common.NamedFactory;
-import org.apache.sshd.common.file.virtualfs.VirtualFileSystemFactory;
-import org.apache.sshd.server.Command;
-import org.apache.sshd.server.SshServer;
-import org.apache.sshd.server.keyprovider.SimpleGeneratorHostKeyProvider;
-import org.apache.sshd.server.subsystem.sftp.SftpSubsystemFactory;
-
-import java.io.File;
-import java.util.Collections;
-import java.util.List;
-import java.util.Map;
-import java.util.HashMap;
-
-import javax.annotation.PostConstruct;
-import javax.sql.DataSource;
-
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-import org.junit.AfterClass;
-import org.junit.BeforeClass;
-import org.junit.ClassRule;
-import org.junit.rules.TemporaryFolder;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotNull;
-
-/**
- * BatchConfiguration test cases
- *
- * @author Chris Schaefer
- */
-@RunWith(SpringRunner.class)
-@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.NONE)
-@DirtiesContext
-@EnableConfigurationProperties(BatchConfigurationProperties.class)
-public class BatchConfigurationTests {
- private static int port;
- private static SshServer server;
- private static AnnotationConfigApplicationContext context;
-
- private static final String SFTP_USER = "user";
- private static final String SFTP_PASS = "pass";
- private static final String SFTP_HOST = "127.0.0.1";
- private static final String REMOTE_FILE = "people.csv";
- private static final String HOST_KEY_FILE = "hostkey.ser";
-
- @ClassRule
- public static final TemporaryFolder remoteTemporaryFolder = new TemporaryFolder();
-
- @BeforeClass
- public static void createServer() throws Exception {
- File createdFile = remoteTemporaryFolder.newFile(REMOTE_FILE);
- FileUtils.writeStringToFile(createdFile, "Jill,Doe\nJoe,Doe\nJustin,Doe\nJane,Doe\nJohn,Doe");
-
- server = SshServer.setUpDefaultServer();
- server.setPasswordAuthenticator((username, password, session) -> true);
- server.setPort(0);
- server.setKeyPairProvider(new SimpleGeneratorHostKeyProvider(new File(HOST_KEY_FILE)));
- server.setSubsystemFactories(Collections.>singletonList(new SftpSubsystemFactory()));
- server.setFileSystemFactory(new VirtualFileSystemFactory(remoteTemporaryFolder.getRoot().toPath()));
- server.start();
-
- port = server.getPort();
- }
-
- @AfterClass
- public static void stopServer() throws Exception {
- server.stop();
-
- File hostkey = new File(HOST_KEY_FILE);
-
- if (hostkey.exists()) {
- hostkey.delete();
- }
- }
-
- @Before
- public void createContext() {
- Map properties = new HashMap();
- properties.put("sftp_host", SFTP_HOST);
- properties.put("sftp_port", port);
- properties.put("sftp_username", SFTP_USER);
- properties.put("sftp_password", SFTP_PASS);
-
- ConfigurableEnvironment environment = new StandardEnvironment();
- environment.getPropertySources().addFirst(new MapPropertySource("sftpProperties", properties));
-
- context = new AnnotationConfigApplicationContext();
- context.register(BatchConfiguration.class, DataSourceConfiguration.class);
- context.setEnvironment(environment);
- context.refresh();
- }
-
- @After
- public void closeContext() {
- context.close();
- }
-
- @Test
- public void testBatchConfigurationSuccess() throws Exception {
- JobExecution jobExecution = testJob(REMOTE_FILE);
-
- assertEquals("Incorrect batch status", BatchStatus.COMPLETED, jobExecution.getStatus());
- assertEquals("Invalid number of step executions", 1, jobExecution.getStepExecutions().size());
- }
-
- @Test
- public void testBatchConfigurationFail() throws Exception {
- JobExecution jobExecution = testJob("missing-people-file.csv");
-
- assertEquals("Incorrect batch status", BatchStatus.FAILED, jobExecution.getStatus());
- }
-
- @Test
- public void testBatchDataProcessing() throws Exception {
- JobExecution jobExecution = testJob(REMOTE_FILE);
-
- assertEquals("Incorrect batch status", BatchStatus.COMPLETED, jobExecution.getStatus());
- assertEquals("Invalid number of step executions", 1, jobExecution.getStepExecutions().size());
-
- JdbcTemplate jdbcTemplate = new JdbcTemplate(context.getBean(DataSource.class));
- List