44 lines
1.5 KiB
Java
44 lines
1.5 KiB
Java
package com.baeldung.batchtesting;
|
|
|
|
import org.springframework.batch.core.Job;
|
|
import org.springframework.batch.core.JobParametersBuilder;
|
|
import org.springframework.batch.core.launch.JobLauncher;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Qualifier;
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
import org.springframework.boot.CommandLineRunner;
|
|
import org.springframework.boot.SpringApplication;
|
|
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
|
import org.springframework.context.annotation.PropertySource;
|
|
|
|
@SpringBootApplication
|
|
@PropertySource("classpath:batchtesting/application.properties")
|
|
public class SpringBatchApplication implements CommandLineRunner {
|
|
|
|
@Autowired
|
|
private JobLauncher jobLauncher;
|
|
|
|
@Autowired
|
|
@Qualifier("transformBooksRecords")
|
|
private Job transformBooksRecordsJob;
|
|
|
|
@Value("${file.input}")
|
|
private String input;
|
|
|
|
@Value("${file.output}")
|
|
private String output;
|
|
|
|
public static void main(String[] args) {
|
|
SpringApplication.run(SpringBatchApplication.class, args);
|
|
}
|
|
|
|
@Override
|
|
public void run(String... args) throws Exception {
|
|
JobParametersBuilder paramsBuilder = new JobParametersBuilder();
|
|
paramsBuilder.addString("file.input", input);
|
|
paramsBuilder.addString("file.output", output);
|
|
jobLauncher.run(transformBooksRecordsJob, paramsBuilder.toJobParameters());
|
|
}
|
|
|
|
}
|