Initial commit

Author: OsoriAndOmori

.gitignore

@@ -0,0 +1,38 @@
+HELP.md
+.db-data
+.gradle
+build/
+!gradle/wrapper/gradle-wrapper.jar
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+bin/
+!**/src/main/**/bin/
+!**/src/test/**/bin/
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+out/
+!**/src/main/**/out/
+!**/src/test/**/out/
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+
+### VS Code ###
+.vscode/

application-batch/build.gradle

@@ -0,0 +1,31 @@
+plugins {
+    id 'org.springframework.boot' version '3.2.3'
+    id 'io.spring.dependency-management' version '1.1.4'
+    id 'java-library'
+}
+
+group = 'com.skt'
+version = '0.0.1-SNAPSHOT'
+sourceCompatibility = '17'
+
+repositories {
+    mavenCentral()
+}
+
+dependencies {
+    implementation 'org.springframework.boot:spring-boot-starter-batch'
+    implementation 'org.springframework.boot:spring-boot-starter-validation'
+    implementation project(':domain-mysql')
+    implementation project(':etc-yaml-importer')
+    testImplementation 'org.springframework.boot:spring-boot-starter-test'
+    testImplementation 'org.springframework.batch:spring-batch-test'
+
+    compileOnly 'org.projectlombok:lombok'
+    annotationProcessor 'org.projectlombok:lombok'
+    testCompileOnly 'org.projectlombok:lombok'
+    testAnnotationProcessor 'org.projectlombok:lombok'
+}
+
+tasks.named('test') {
+    useJUnitPlatform()
+}

application-batch/src/main/java/com/skt/applicationbatch/ApplicationBatchApplication.java

@@ -0,0 +1,13 @@
+package com.skt.applicationbatch;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class ApplicationBatchApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(ApplicationBatchApplication.class, args);
+    }
+
+}

application-batch/src/main/java/com/skt/applicationbatch/configure/BatchProcessConfig.java

@@ -0,0 +1,9 @@
+package com.skt.applicationbatch.configure;
+
+import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
+import org.springframework.context.annotation.Configuration;
+
+@EnableBatchProcessing
+@Configuration
+public class BatchProcessConfig {
+}

application-batch/src/main/java/com/skt/applicationbatch/job/SimpleJob.java

@@ -0,0 +1,42 @@
+package com.skt.applicationbatch.job;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.batch.core.Job;
+import org.springframework.batch.core.Step;
+import org.springframework.batch.core.job.builder.JobBuilder;
+import org.springframework.batch.core.repository.JobRepository;
+import org.springframework.batch.core.step.builder.StepBuilder;
+import org.springframework.batch.core.step.tasklet.Tasklet;
+import org.springframework.batch.repeat.RepeatStatus;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.transaction.PlatformTransactionManager;
+
+@Configuration
+@RequiredArgsConstructor
+public class SimpleJob {
+    private final JobRepository jobRepository;
+    private final PlatformTransactionManager transactionManager;
+
+    @Bean
+    public Job simpleJobBean() {
+        return new JobBuilder("simpleJob", jobRepository)
+                .start(simpleStepBean())
+                .build();
+    }
+
+    @Bean
+    public Step simpleStepBean() {
+        return new StepBuilder("simpleStep", jobRepository)
+                .tasklet(helloWorldTasklet(), transactionManager)
+                .build();
+    }
+
+    @Bean
+    public Tasklet helloWorldTasklet() {
+        return (contribution, chunkContext) -> {
+            System.out.println("Hello, Spring Batch!");
+            return RepeatStatus.FINISHED;
+        };
+    }
+}

application-batch/src/main/resources/application-local.yaml

@@ -0,0 +1,6 @@
+server:
+  port: 8080
+
+logging:
+  level:
+    root: debug

application-batch/src/main/resources/application.yaml

@@ -0,0 +1,6 @@
+spring:
+  profiles:
+    active: local
+#  batch:
+#    job:
+#      enabled: false

application-batch/src/test/java/com/skt/applicationbatch/JobTestUtils.java

@@ -0,0 +1,58 @@
+package com.skt.applicationbatch;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.batch.core.Job;
+import org.springframework.batch.core.JobExecution;
+import org.springframework.batch.core.StepExecution;
+import org.springframework.batch.core.launch.JobLauncher;
+import org.springframework.batch.core.repository.JobRepository;
+import org.springframework.batch.test.JobLauncherTestUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationContext;
+import org.springframework.core.env.ConfigurableEnvironment;
+import org.springframework.stereotype.Component;
+
+import java.util.Arrays;
+
+@Slf4j
+@Component
+public class JobTestUtils {
+    @Autowired
+    private ApplicationContext applicationContext;
+    @Autowired
+    private JobRepository jobRepository;
+    @Autowired
+    private JobLauncher jobLauncher;
+    @Autowired
+    private ConfigurableEnvironment env;
+
+    public JobLauncherTestUtils getJobTester(String jobName) {
+        Job job = applicationContext.getBean(jobName, Job.class);
+        JobLauncherTestUtils jobLauncherTestUtils = new JobLauncherTestUtils();
+        jobLauncherTestUtils.setJob(job);
+        jobLauncherTestUtils.setJobRepository(jobRepository);
+        jobLauncherTestUtils.setJobLauncher(jobLauncher);
+        return jobLauncherTestUtils;
+    }
+
+    public void loggingJobExecution(JobExecution jobExecution) {
+        log.info("active profiles : {}", Arrays.toString(env.getActiveProfiles()));
+
+        StringBuilder b = new StringBuilder();
+        b.append("Steps Information").append('\n');
+
+        int i = 1;
+
+        for (StepExecution step : jobExecution.getStepExecutions()) {
+            b.append("Step").append(i++).append(" name=").append(step.getStepName()).append("\n")
+                    .append("\tread:").append(step.getReadCount()).append('\n')
+                    .append("\tread skip:").append(step.getReadSkipCount()).append('\n')
+                    .append("\tproc skip:").append(step.getProcessSkipCount()).append('\n')
+                    .append("\tfilter:").append(step.getFilterCount()).append('\n')
+                    .append("\twrite:").append(step.getWriteCount()).append('\n')
+                    .append("\twrite skip:").append(step.getWriteSkipCount()).append('\n');
+        }
+
+        log.info(b.toString());
+    }
+}

application-batch/src/test/java/com/skt/applicationbatch/job/cursorvspaging/CursorJobConfigTest.java

@@ -0,0 +1,31 @@
+package com.skt.applicationbatch.job.cursorvspaging;
+
+import com.skt.applicationbatch.JobTestUtils;
+import org.junit.jupiter.api.Test;
+import org.springframework.batch.core.JobExecution;
+import org.springframework.batch.core.JobParametersBuilder;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@SpringBootTest
+class CursorJobConfigTest {
+    @Autowired
+    private JobTestUtils jobTestUtils;
+
+    @Test
+    public void testCursorJob() throws Exception {
+        JobParametersBuilder paramBuilder = new JobParametersBuilder();
+        paramBuilder.addLong("ts", System.currentTimeMillis());
+
+        Map<String, String> param = new HashMap<>();
+        param.forEach(paramBuilder::addString);
+
+        JobExecution jobExecution = jobTestUtils.getJobTester("cursorTestJob")
+                .launchJob(paramBuilder.toJobParameters());
+
+        jobTestUtils.loggingJobExecution(jobExecution);
+    }
+}

application-batch/src/test/java/com/skt/applicationbatch/job/cursorvspaging/PagingJobConfigTest.java

@@ -0,0 +1,31 @@
+package com.skt.applicationbatch.job.cursorvspaging;
+
+import com.skt.applicationbatch.JobTestUtils;
+import org.junit.jupiter.api.Test;
+import org.springframework.batch.core.JobExecution;
+import org.springframework.batch.core.JobParametersBuilder;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@SpringBootTest
+class PagingJobConfigTest {
+    @Autowired
+    private JobTestUtils jobTestUtils;
+
+    @Test
+    public void testPagingJob() throws Exception {
+        JobParametersBuilder paramBuilder = new JobParametersBuilder();
+        paramBuilder.addLong("ts", System.currentTimeMillis());
+
+        Map<String, String> param = new HashMap<>();
+        param.forEach(paramBuilder::addString);
+
+        JobExecution jobExecution = jobTestUtils.getJobTester("pagingTestJob")
+                .launchJob(paramBuilder.toJobParameters());
+
+        jobTestUtils.loggingJobExecution(jobExecution);
+    }
+}