如何解决org.springframework.beans.BeanInstantiationException,无法使用Oracle DataSource
#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 举报,一经查实,本站将立刻删除。