扩展jdbccursoritemreader时出现sql查询错误

mepcadol  于 2021-07-26  发布在  Java
关注(0)|答案(1)|浏览(421)

我有下面的itemreader类

  1. @Configuration
  2.     public class ReadingObjectItemReader extends JdbcCursorItemReader<Person> {
  4.         public DataSource getDataSource() { return dataSource; }        
  5.         @Resource
  6.         public void setDataSource(DataSource dataSource) { super.setDataSource(dataSource); }
  8.         @Autowired
  9.         DataSource dataSource;
  11.         @Bean
  12.         public JdbcCursorItemReader<Person> cursorReader() {
  13.             JdbcCursorItemReader<Person> databaseReader = new JdbcCursorItemReader<>();
  14.             databaseReader.setDataSource(dataSource);
  15.             databaseReader.setSql("select TOP(10) * from dbo.Person ");
  16.             databaseReader.setFetchSize(5);
  17.             databaseReader.setRowMapper(new BeanPropertyRowMapper<>(Person.class));
  18.             return databaseReader;
  19.         }
  20. }

当我运行我的代码库时，上面的代码作为itemreader，我得到

  1. Caused by: java.lang.IllegalArgumentException: The SQL query must be provided

以下是完整的堆栈跟踪：

  1. org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'readingObjectItemReader' defined in file [\demo-project\bin\main\com\spring-batch\test\config\ReadingObjectItemReader.class]: Invocation of init method failed; nested exception is java.lang.IllegalArgumentException: The SQL query must be provided
  2.     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1796) ~[spring-beans-5.2.6.RELEASE.jar:5.2.6.RELEASE]
  3.     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:595) ~[spring-beans-5.2.6.RELEASE.jar:5.2.6.RELEASE]
  4.     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:517) ~[spring-beans-5.2.6.RELEASE.jar:5.2.6.RELEASE]
  5.     at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:323) ~[spring-beans-5.2.6.RELEASE.jar:5.2.6.RELEASE]
  6.     at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:226) ~[spring-beans-5.2.6.RELEASE.jar:5.2.6.RELEASE]
  7.     at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:321) ~[spring-beans-5.2.6.RELEASE.jar:5.2.6.RELEASE]
  8.     at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:202) ~[spring-beans-5.2.6.RELEASE.jar:5.2.6.RELEASE]
  9.     at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:895) ~[spring-beans-5.2.6.RELEASE.jar:5.2.6.RELEASE]
  10.     at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:878) ~[spring-context-5.2.6.RELEASE.jar:5.2.6.RELEASE]
  11.     at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:550) ~[spring-context-5.2.6.RELEASE.jar:5.2.6.RELEASE]
  12.     at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:143) ~[spring-boot-2.3.1.BUILD-SNAPSHOT.jar:2.3.1.BUILD-SNAPSHOT]
  13.     at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:758) ~[spring-boot-2.3.1.BUILD-SNAPSHOT.jar:2.3.1.BUILD-SNAPSHOT]
  14.     at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:750) ~[spring-boot-2.3.1.BUILD-SNAPSHOT.jar:2.3.1.BUILD-SNAPSHOT]
  15.     at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:397) ~[spring-boot-2.3.1.BUILD-SNAPSHOT.jar:2.3.1.BUILD-SNAPSHOT]
  16.     at org.springframework.boot.SpringApplication.run(SpringApplication.java:315) ~[spring-boot-2.3.1.BUILD-SNAPSHOT.jar:2.3.1.BUILD-SNAPSHOT]
  17.     at org.springframework.boot.SpringApplication.run(SpringApplication.java:1237) ~[spring-boot-2.3.1.BUILD-SNAPSHOT.jar:2.3.1.BUILD-SNAPSHOT]
  18.     at org.springframework.boot.SpringApplication.run(SpringApplication.java:1226) ~[spring-boot-2.3.1.BUILD-SNAPSHOT.jar:2.3.1.BUILD-SNAPSHOT]
  19.     at gov.va.med.ccrs.pit.extract.CcrsPitextractApplication.main(CcrsPitextractApplication.java:12) ~[main/:na]
  20.     at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:na]
  21.     at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:na]
  22.     at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:na]
  23.     at java.base/java.lang.reflect.Method.invoke(Method.java:566) ~[na:na]
  24.     at org.springframework.boot.devtools.restart.RestartLauncher.run(RestartLauncher.java:49) ~[spring-boot-devtools-2.3.1.BUILD-SNAPSHOT.jar:2.3.1.BUILD-SNAPSHOT]
  25. Caused by: java.lang.IllegalArgumentException: The SQL query must be provided
  26.     at org.springframework.util.Assert.notNull(Assert.java:198) ~[spring-core-5.2.6.RELEASE.jar:5.2.6.RELEASE]
  27.     at org.springframework.batch.item.database.JdbcCursorItemReader.afterPropertiesSet(JdbcCursorItemReader.java:108) ~[spring-batch-infrastructure-4.2.2.RELEASE.jar:4.2.2.RELEASE]
  28.     at gov.va.med.ccrs.pit.extract.config.ReadingObjectItemReader.afterPropertiesSet(ReadingObjectItemReader.java:58) ~[main/:na]
  29.     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1855) ~[spring-beans-5.2.6.RELEASE.jar:5.2.6.RELEASE]
  30.     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1792) ~[spring-beans-5.2.6.RELEASE.jar:5.2.6.RELEASE]
  31.     ... 22 common frames omitted

有什么我应该加入这个代码工作。提前谢谢。

springspring-bootbatch-processingspring-batch

1条答案

按热度按时间
uemypmqf

uemypmqf1#

通过不扩展jdbccursoritemreader并从我定义步骤的类中传递数据源，我能够实现这一点。
在做了更正之后，课堂看起来是这样的：

  1. @Configuration
  2. public class ReadingObjectItemReader {
  4.     @Bean
  5.     ItemReader<Person> cursorReaderForDb(DataSource dataSource) {
  6.         String sql = "select TOP(10) * from dbo.Person ";
  7.         JdbcCursorItemReader<Person> cursor = new JdbcCursorItemReader<Person>();
  8.         cursor.setDataSource(dataSource);
  9.         cursor.setSql(sql);
  10.         cursor.setRowMapper(new BeanPropertyRowMapper<>(Person.class));
  11.         cursor.setFetchSize(10);
  12.         return cursor;
  13.     }
  14. }

我知道这是一种奇怪的行为。我仍然希望通过扩展jdbccursoritemreader来实现这一点。因此，任何建议，使其正确的是感谢。

展开查看全部
赞(0）分享  回复(0）举报  2021-07-26
我来回答

相关问题

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新问答

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com