1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17 package org.springframework.batch.core.explore.support;
18
19 import org.springframework.batch.core.repository.dao.ExecutionContextDao;
20 import org.springframework.batch.core.repository.dao.JobExecutionDao;
21 import org.springframework.batch.core.repository.dao.JobInstanceDao;
22 import org.springframework.batch.core.repository.dao.StepExecutionDao;
23 import org.springframework.batch.core.repository.support.MapJobRepositoryFactoryBean;
24 import org.springframework.beans.factory.FactoryBean;
25 import org.springframework.beans.factory.InitializingBean;
26 import org.springframework.util.Assert;
27
28
29
30
31
32
33
34
35 public class MapJobExplorerFactoryBean extends AbstractJobExplorerFactoryBean implements InitializingBean {
36
37 private MapJobRepositoryFactoryBean repositoryFactory;
38
39
40
41
42
43
44 public MapJobExplorerFactoryBean(MapJobRepositoryFactoryBean repositoryFactory) {
45 this.repositoryFactory = repositoryFactory;
46 }
47
48
49
50
51
52 public MapJobExplorerFactoryBean() {
53 }
54
55
56
57
58
59
60 public void setRepositoryFactory(MapJobRepositoryFactoryBean repositoryFactory) {
61 this.repositoryFactory = repositoryFactory;
62 }
63
64
65
66
67
68 @Override
69 public void afterPropertiesSet() throws Exception {
70 Assert.state(repositoryFactory != null, "A MapJobRepositoryFactoryBean must be provided");
71 repositoryFactory.afterPropertiesSet();
72 }
73
74 @Override
75 protected JobExecutionDao createJobExecutionDao() throws Exception {
76 return repositoryFactory.getJobExecutionDao();
77 }
78
79 @Override
80 protected JobInstanceDao createJobInstanceDao() throws Exception {
81 return repositoryFactory.getJobInstanceDao();
82 }
83
84 @Override
85 protected StepExecutionDao createStepExecutionDao() throws Exception {
86 return repositoryFactory.getStepExecutionDao();
87 }
88
89 @Override
90 protected ExecutionContextDao createExecutionContextDao() throws Exception {
91 return repositoryFactory.getExecutionContextDao();
92 }
93
94 @Override
95 public Object getObject() throws Exception {
96 return new SimpleJobExplorer(createJobInstanceDao(), createJobExecutionDao(), createStepExecutionDao(),
97 createExecutionContextDao());
98 }
99
100 }