Edijun

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-tomcat</artifactId>
        <scope>provided</scope>
    </dependency>

Edijun

public class Product {
	private String id;
	private String name;
	private Integer price;
	private String description;

	public Product(String id, String name, Integer price, String description) {
		super();
		this.id = id;
		this.name = name;

Edijun

@Bean
	public FlatFileItemReader<Product> csvProductReader() {
		FlatFileItemReader<Product> reader = new FlatFileItemReader<Product>();
		reader.setResource(new ClassPathResource("products.csv"));
		reader.setLineMapper(new DefaultLineMapper<Product>() {
			{
				setLineTokenizer(new DelimitedLineTokenizer() {
					{
						setNames(new String[] { "id", "name", "price", "description" });
					}

Edijun

@Bean
ItemProcessor<Product, Product> csvProductProcessor() {
  return new ProductProcessor();
}

Edijun

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.batch.item.ItemProcessor;

import id.edijun.example.springbatch.model.Product;

public class ProductProcessor implements ItemProcessor<Product, Product> {
  private static final Logger log = LoggerFactory.getLogger(ProductProcessor.class);
  
	@Override

Edijun

@Bean
  public JdbcBatchItemWriter<Product> csvProductWriter() {
    JdbcBatchItemWriter<Product> csvProductWriter = new JdbcBatchItemWriter<Product>();
    csvProductWriter.setItemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<Product>());
    csvProductWriter.setSql("INSERT INTO product (id, name, price, description) VALUES (:id, :name, :price, :description)");
    csvProductWriter.setDataSource(dataSource);
    
    return csvProductWriter;
}

Edijun

@Bean
public Step csvFileToDatabaseStep() {
  return stepBuilderFactory
    .get("csvFileToDatabaseStep")
    .<Product, Product>chunk(1)
    .reader(csvProductReader())
    .processor(csvProductProcessor())
    .writer(csvProductWriter())
    .build();
}

Edijun

@Bean
Job csvFileToDatabaseJob(JobCompletionNotificationListener listener) {
  return jobBuilderFactory
    .get("csvFileToDatabaseJob")
    .incrementer(new RunIdIncrementer()).listener(listener)
    .flow(csvFileToDatabaseStep())
    .end().build();
}

Edijun

@Override
public void setDataSource(DataSource dataSource) {
  // override to do not set datasource even if a datasource exist.
  // initialize will use a Map based JobRepository (instead of database)
}

Edijun

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import org.springframework.batch.core.BatchStatus;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.listener.JobExecutionListenerSupport;