์๋ ํฌ์คํ ์์ ์ด์ด์ง ๋ด์ฉ์ ๋๋ค.
[springBoot] spring batch simpleReader insert other table( feat. JPA)
์๋ ํฌ์คํ ์์ ์ด์ด์ง ๋ด์ฉ์ ๋๋ค. [springBoot] spring batch jpa simpleDbReader (feat. simple Reader) ์๋ ํฌ์คํ ์์ ์ด์ด์ง ๋ด์ฉ์ ๋๋ค. [springBoot] Simple Spring Batch Tasklet(feat. simple) ์คํ๋ง ๋ฐฐ์น๋ฅผ ์ด์ฉํ ์
yaga.tistory.com
๊ตฌ๋ถ์ ์๋ ํ ์คํธํ์ผ์ ๋ฐ์ดํฐ๋ฅผ ์ฝ์ด์ ๋ก๊ทธ ์ถ๋ ฅํ๋ ๋จ์ ์์
TextJob ๐
package com.lsy.sample.springbatchvideo.batch;
import com.lsy.sample.springbatchvideo.dto.OneDto;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.batch.core.Job;
import org.springframework.batch.core.Step;
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
import org.springframework.batch.item.file.FlatFileItemReader;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.ClassPathResource;
@Slf4j
@RequiredArgsConstructor
@Configuration
public class TextJob {
private final JobBuilderFactory jobBuilderFactory;
private final StepBuilderFactory stepBuilderFactory;
private static final int chunkSize = 5;
@Bean
public Job textjob1_batchBuild() {
return jobBuilderFactory.get("textJob1")
.start(textJob1_batchStep1())
.build();
}
@Bean
public Step textJob1_batchStep1() {
return stepBuilderFactory.get("testJob1_batchStep1")
.<OneDto, OneDto>chunk(chunkSize)
.reader(textJob1_FileReader())
.writer(OneDto -> OneDto.stream().forEach(i -> {
log.debug(i.toString());
}))
.build();
}
// text reader
@Bean
public FlatFileItemReader<OneDto> textJob1_FileReader() {
FlatFileItemReader<OneDto> flatFileItemReader = new FlatFileItemReader<>();
flatFileItemReader.setResource(new ClassPathResource("sample/textJob1_input.txt"));
flatFileItemReader.setLineMapper((line, lineNumber) -> new OneDto(lineNumber + " == " + line));
return flatFileItemReader;
}
}
๊ฐ์ธ ์คํฐ๋ ๊ธฐ๋ก์ ๋ฉ๋ชจํ๋ ๊ณต๊ฐ์ด๋ผ ํ๋ฆฐ์ ์ด ์์ ์ ์์ต๋๋ค.
ํ๋ฆฐ ์ ์์ ๊ฒฝ์ฐ ๋๊ธ ๋ถํ๋๋ฆฝ๋๋ค.
reference: https://www.youtube.com/watch?v=wy99cPHlMlA&list=PLogzC_RPf25HRSG9aO7qKrwbT-EecUMMR
๋ค์ ๋ด์ฉ
[springBoot] spring batch write to new file (feat. file)
์๋ ํฌ์คํ ์์ ์ด์ด์ง ๋ด์ฉ์ ๋๋ค. [springBoot] spring batch simpleTextReader ์๋ ํฌ์คํ ์์ ์ด์ด์ง ๋ด์ฉ์ ๋๋ค. [springBoot] spring batch simpleReader insert other table( feat. JPA) ์๋ ํฌ์คํ ์์ ์ด์ด์ง ๋ด์ฉ์
yaga.tistory.com
๋๊ธ