Skip to content

Commit d385740

Browse files
update to use a map based jobrepository
1 parent ed57c63 commit d385740

File tree

6 files changed

+48
-6
lines changed

6 files changed

+48
-6
lines changed
Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
package com.codenotfound.batch.job;
2+
3+
import javax.sql.DataSource;
4+
import org.springframework.batch.core.configuration.annotation.DefaultBatchConfigurer;
5+
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
6+
import org.springframework.context.annotation.Configuration;
7+
8+
@Configuration
9+
@EnableBatchProcessing
10+
public class BatchConfig extends DefaultBatchConfigurer {
11+
12+
@Override
13+
public void setDataSource(DataSource dataSource) {
14+
// initialize will use a Map based JobRepository (instead of database)
15+
}
16+
}

spring-batch-capitalize-names/src/main/java/com/codenotfound/batch/job/CapitalizeNamesJobConfig.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@
22

33
import org.springframework.batch.core.Job;
44
import org.springframework.batch.core.Step;
5-
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
65
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
76
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
87
import org.springframework.batch.item.file.FlatFileItemReader;
@@ -16,7 +15,6 @@
1615
import com.codenotfound.model.Person;
1716

1817
@Configuration
19-
@EnableBatchProcessing
2018
public class CapitalizeNamesJobConfig {
2119

2220
@Bean
Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
package com.codenotfound.batch.job;
2+
3+
import javax.sql.DataSource;
4+
import org.springframework.batch.core.configuration.annotation.DefaultBatchConfigurer;
5+
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
6+
import org.springframework.context.annotation.Configuration;
7+
8+
@Configuration
9+
@EnableBatchProcessing
10+
public class BatchConfig extends DefaultBatchConfigurer {
11+
12+
@Override
13+
public void setDataSource(DataSource dataSource) {
14+
// initialize will use a Map based JobRepository (instead of database)
15+
}
16+
}

spring-batch-hello-world/src/main/java/com/codenotfound/batch/job/HelloWorldJobConfig.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@
22

33
import org.springframework.batch.core.Job;
44
import org.springframework.batch.core.Step;
5-
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
65
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
76
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
87
import org.springframework.batch.item.file.FlatFileItemReader;
@@ -17,7 +16,6 @@
1716
import com.codenotfound.model.Person;
1817

1918
@Configuration
20-
@EnableBatchProcessing
2119
public class HelloWorldJobConfig {
2220

2321
@Bean
Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
package com.codenotfound.batch.job;
2+
3+
import javax.sql.DataSource;
4+
import org.springframework.batch.core.configuration.annotation.DefaultBatchConfigurer;
5+
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
6+
import org.springframework.context.annotation.Configuration;
7+
8+
@Configuration
9+
@EnableBatchProcessing
10+
public class BatchConfig extends DefaultBatchConfigurer {
11+
12+
@Override
13+
public void setDataSource(DataSource dataSource) {
14+
// initialize will use a Map based JobRepository (instead of database)
15+
}
16+
}

spring-batch-tasklet/src/main/java/com/codenotfound/batch/job/CapitalizeNamesJobConfig.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@
55
import org.slf4j.LoggerFactory;
66
import org.springframework.batch.core.Job;
77
import org.springframework.batch.core.Step;
8-
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
98
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
109
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
1110
import org.springframework.batch.item.file.FlatFileItemReader;
@@ -23,7 +22,6 @@
2322
import com.codenotfound.model.Person;
2423

2524
@Configuration
26-
@EnableBatchProcessing
2725
public class CapitalizeNamesJobConfig {
2826

2927
private static final Logger LOGGER = LoggerFactory.getLogger(CapitalizeNamesJobConfig.class);

0 commit comments

Comments
 (0)