问题描述
#Update-我想出了解决方案，给出了答案，但保持此线程开放，以防万一任何人想分享更多见解
我是Spring Boot的新手，发布之前我已经在这里和其他来源上搜索了此问题，找不到解决方案。 我正在尝试从Oracle DB，ItemReader（批处理）读取记录，
错误堆栈：
org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'jobInvokerController': Unsatisfied dependency expressed through field 'processJob'; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'processJob' defined in class path resource [com/amitpar/springBootBatch/config/BatchConfig.class]: Bean instantiation via factory method Failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.batch.core.Job]: Factory method 'processJob' threw exception; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'orderStep1' defined in class path resource [com/amitpar/springBootBatch/config/BatchConfig.class]: Bean instantiation via factory method Failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.batch.core.Step]: Factory method 'orderStep1' threw exception; nested exception is java.lang.IllegalArgumentException: Property 'dataSource' is required
at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:643) ~[spring-beans-5.2.8.RELEASE.jar:5.2.8.RELEASE]
at org.springframework.beans.factory.annotation.InjectionMetadata.inject(InjectionMetadata.java:130) ~[spring-beans-5.2.8.RELEASE.jar:5.2.8.RELEASE]
at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcessproperties(AutowiredAnnotationBeanPostProcessor.java:399) ~[spring-beans-5.2.8.RELEASE.jar:5.2.8.RELEASE]
at org.springframework.beans.factory.support.AbstractAutowireCapablebeanfactory.populateBean(AbstractAutowireCapablebeanfactory.java:1420) ~[spring-beans-5.2.8.RELEASE.jar:5.2.8.RELEASE]
at org.springframework.beans.factory.support.AbstractAutowireCapablebeanfactory.doCreateBean(AbstractAutowireCapablebeanfactory.java:593) ~[spring-beans-5.2.8.RELEASE.jar:5.2.8.RELEASE]
at org.springframework.beans.factory.support.AbstractAutowireCapablebeanfactory.createBean(AbstractAutowireCapablebeanfactory.java:516) ~[spring-beans-5.2.8.RELEASE.jar:5.2.8.RELEASE]
at org.springframework.beans.factory.support.Abstractbeanfactory.lambda$doGetBean$0(Abstractbeanfactory.java:324) ~[spring-beans-5.2.8.RELEASE.jar:5.2.8.RELEASE]
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:226) ~[spring-beans-5.2.8.RELEASE.jar:5.2.8.RELEASE]
at org.springframework.beans.factory.support.Abstractbeanfactory.doGetBean(Abstractbeanfactory.java:322) ~[spring-beans-5.2.8.RELEASE.jar:5.2.8.RELEASE]
at org.springframework.beans.factory.support.Abstractbeanfactory.getBean(Abstractbeanfactory.java:202) ~[spring-beans-5.2.8.RELEASE.jar:5.2.8.RELEASE]
at org.springframework.beans.factory.support.DefaultListablebeanfactory.preInstantiateSingletons(DefaultListablebeanfactory.java:897) ~[spring-beans-5.2.8.RELEASE.jar:5.2.8.RELEASE]
at org.springframework.context.support.AbstractApplicationContext.finishbeanfactoryInitialization(AbstractApplicationContext.java:879) ~[spring-context-5.2.8.RELEASE.jar:5.2.8.RELEASE]
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:551) ~[spring-context-5.2.8.RELEASE.jar:5.2.8.RELEASE]
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:758) ~[spring-boot-2.3.3.RELEASE.jar:2.3.3.RELEASE]
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:750) ~[spring-boot-2.3.3.RELEASE.jar:2.3.3.RELEASE]
at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:397) ~[spring-boot-2.3.3.RELEASE.jar:2.3.3.RELEASE]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:315) ~[spring-boot-2.3.3.RELEASE.jar:2.3.3.RELEASE]
at org.springframework.boot.test.context.SpringBootContextLoader.loadContext(SpringBootContextLoader.java:120) [spring-boot-test-2.3.3.RELEASE.jar:2.3.3.RELEASE]
at
[ERROR] contextLoads Time elapsed: 0.003 s <<< ERROR!
java.lang.IllegalStateException: Failed to load ApplicationContext
Caused by: org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'jobInvokerController': Unsatisfied dependency expressed through field 'processJob'; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'processJob' defined in class path resource [com/amitpar/springBootBatch/config/BatchConfig.class]: Bean instantiation via factory method Failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.batch.core.Job]: Factory method 'processJob' threw exception; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'orderStep1' defined in class path resource [com/amitpar/springBootBatch/config/BatchConfig.class]: Bean instantiation via factory method Failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.batch.core.Step]: Factory method 'orderStep1' threw exception; nested exception is java.lang.IllegalArgumentException: Property 'dataSource' is required
Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'processJob' defined in class path resource [com/amitpar/springBootBatch/config/BatchConfig.class]: Bean instantiation via factory method Failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.batch.core.Job]: Factory method 'processJob' threw exception; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'orderStep1' defined in class path resource [com/amitpar/springBootBatch/config/BatchConfig.class]: Bean instantiation via factory method Failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.batch.core.Step]: Factory method 'orderStep1' threw exception; nested exception is java.lang.IllegalArgumentException: Property 'dataSource' is required
Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.batch.core.Job]: Factory method 'processJob' threw exception; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'orderStep1' defined in class path resource [com/amitpar/springBootBatch/config/BatchConfig.class]: Bean instantiation via factory method Failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.batch.core.Step]: Factory method 'orderStep1' threw exception; nested exception is java.lang.IllegalArgumentException: Property 'dataSource' is required
Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'orderStep1' defined in class path resource [com/amitpar/springBootBatch/config/BatchConfig.class]: Bean instantiation via factory method Failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.batch.core.Step]: Factory method 'orderStep1' threw exception; nested exception is java.lang.IllegalArgumentException: Property 'dataSource' is required
Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.batch.core.Step]: Factory method 'orderStep1' threw exception; nested exception is java.lang.IllegalArgumentException: Property 'dataSource' is required
Caused by: java.lang.IllegalArgumentException: Property 'dataSource' is required
下面是我通过参考各种指南进行的设置，
-application.properties
#Oracle connection
spring.datasource.username=user
spring.datasource.password=pass
spring.datasource.url=jdbc:oracle:thin:@//server:1521/instance
spring.datasource.driver-class-name=oracle.jdbc.driver.OracleDriver
spring.jpa.hibernate.ddl-auto=create-drop
spring.batch.job.enabled=false
--- OracleConfiguration.java
@Configuration
@ConfigurationProperties("spring.datasource")
@Component
public class OracleConfiguration {
@NonNull
private String username;
@NonNull
private String password;
@NonNull
private String url;
public void setUsername(String username) {
this.username = username;
}
public void setPassword(String password) {
this.password = password;
}
public void setUrl(String url) {
this.url = url;
}
@Bean(name="DataSource")
public DataSource dataSource() throws sqlException {
OracleDataSource dataSource = new OracleDataSource();
dataSource.setUser(username);
dataSource.setPassword(password);
dataSource.setURL(url);
dataSource.setImplicitCachingEnabled(true);
dataSource.setFastConnectionFailoverEnabled(true);
return dataSource;
}
}
-尝试在Reader.java类中使用
@Autowired
public DataSource dataSource;
JdbcTemplate jdbcTemplate=new JdbcTemplate(dataSource);
-BatchConfig.java
@Autowired
public JobBuilderFactory jobBuilderFactory;
@Autowired
public StepBuilderFactory stepBuilderFactory;
@Bean
public Job processJob() {
System.out.println("#AMIT,in process job,creating file");
return jobBuilderFactory.get("processJob")
.incrementer(new RunIdIncrementer()).listener(listener())
.flow(orderStep1())
.end()
.build();
}
@Bean
public Step orderStep1() {
System.out.println("#AMIT,in orderStep1");
return stepBuilderFactory.get("orderStep1").<SubscriberInfo,SubscriberInfo> chunk(5)
.reader( new Reader())
.processor(new Processor())
.writer( new Writer())
.build();
}
-更新- 首先，正如我所期望的，将ItemReader放在同一类中，在SAME类中使用JdbcCursorItemReader进行构建，在同一类中连接DataSource，它可以正常工作 2.其次，如果需要使用MVC样式的单独类，则在构造读取器类时，无需在实际的read（）重写方法n中连接jdbcTemplate，jdbcTemplate最后以某种方式由spring容器实例化，spring可以正确处理事务过程不管我们调用read（）方法有多少，因此每次调用结果时我们都不必担心
-----解决方案1 ----
BatchConfig.java
@Qualifier("Zandu")
public DataSource dataSource;
@Bean
public JdbcCursorItemReader<SubscriberInfo> itemReader() {
System.out.println("#AMIT_2 creating jdbc itemwriter bean");
return new JdbcCursorItemReaderBuilder<SubscriberInfo>()
.dataSource(dataSource)
.sql(" select customer_id,subscriber_no from subscriber where sys_creation_date > to_date('20200101','YYYYMMDD') and rownum < 11")
.rowMapper(new subscriberRowMapper())
.name("subscriberReader")
.build();
}
-解决方案2 ----
BatchConfig.java
@Bean
public Reader reader() {
System.out.println("#AMIT in Batch config create bean reader");
return new Reader();
}
Reader.java
public class Reader implements ItemReader<SubscriberInfo> {
@Autowired
@Qualifier("Zandu")
DataSource dataSourceVar;
.
.
.
@Override
public SubscriberInfo read()
throws Exception,UnexpectedInputException,ParseException,NonTransientResourceException {
jdbcTemplate=new JdbcTemplate(dataSourceVar);
subscriberInfoList = jdbcTemplate.query(QUERY_FIND_SUBSCRIBER,new subscriberRowMapper());
System.out.println("#AMIT IN most important read method *********** ");
if(count<subscriberInfoList.size()) {
System.out.println("Reading count="+count);
return subscriberInfoList.get(count++);
}
else {
count=0;
}
return null;
}
}
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）