java-在JdbcCursorItemReader中将作业参数用作准备好的语句参数

前端之家收集整理的这篇文章主要介绍了java-在JdbcCursorItemReader中将作业参数用作准备好的语句参数 前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

我有一个作业必须使用不同的作业参数运行多次.我想设置一个JdbcCursorItemReader来执行作业查询,itemReader的配置如下:

  1. <bean id="tpsItemReader"
  2. class="org.springframework.batch.item.database.JdbcCursorItemReader">
  3. <property name="dataSource" ref="myDataSource"/>
  4. <property name="sql" value="#{sqlQueries['tps.findStuffforSomeSubset']}"/>
  5. <property name="preparedStatementSetter">
  6. <bean class="com.initech.reports.tps.ParameterSetter">
  7. <!-- can't hardcode this,I want a job parameter here -->
  8. <constructor-arg value="A"/>
  9. </bean>
  10. </property>
  11. <property name="rowMapper">
  12. <bean class="com.initech.reports.tps.CustomerRowMapper"/>
  13. </property>
  14. </bean>

作业配置如下:

  1. <batch:job id="tpsReportJob">
  2. <batch:step id="tpsReportJob.generateReport">
  3. <batch:tasklet>
  4. <batch:chunk reader="tpsItemReader"
  5. processor="tpsItemProcessor"
  6. writer="tpsItemWriter" commit-interval="100000"/>
  7. </batch:tasklet>
  8. </batch:step>
  9. </batch:job>

parameterSetter非常小:

  1. package com.initech.reports.tps;
  2. import java.sql.PreparedStatement;
  3. import java.sql.sqlException;
  4. import org.springframework.jdbc.core.PreparedStatementSetter;
  5. public class ParameterSetter implements PreparedStatementSetter {
  6. private final String x;
  7. public ParameterSetter(String x) {this.x = x;}
  8. @Override
  9. public void setValues(PreparedStatement ps) throws sqlException {
  10. ps.setString(1,x);
  11. }
  12. }

这是使用spring-batch 2.1.8.

如何将job参数放入查询中?

我想我接近了,我尝试将参数设置器配置更改为:

  1. <bean class="com.initech.reports.tps.ParameterSetter">
  2. <constructor-arg value="#{jobParameters['myParam']}"/>
  3. </bean>

但是我得到这个错误

  1. Caused by: org.springframework.expression.spel.SpelEvaluationException: EL1008E:(pos 0): Field or property 'jobParameters' cannot be found on object of type 'org.springframework.beans.factory.config.BeanExpressionContext'
  2. at org.springframework.expression.spel.ast.PropertyOrFieldReference.readProperty(PropertyOrFieldReference.java:208)
  3. at org.springframework.expression.spel.ast.PropertyOrFieldReference.getValueInternal(PropertyOrFieldReference.java:72)
  4. at org.springframework.expression.spel.ast.CompoundExpression.getValueInternal(CompoundExpression.java:52)
  5. at org.springframework.expression.spel.ast.SpelNodeImpl.getValue(SpelNodeImpl.java:93)
  6. at org.springframework.expression.spel.standard.SpelExpression.getValue(SpelExpression.java:88)
  7. at org.springframework.context.expression.StandardBeanExpressionResolver.evaluate(StandardBeanExpressionResolver.java:139)
  8. ... 51 more

我发现a very similar question,它与这个之间的区别是我没有要注释的阅读器类,我只有xml条目,因为我想避免不得不创建自己的itemReader. (我可以尝试重写jdbcCursorItemReader类,以便能够对其进行注释…)

最佳答案
所要做的就是将scope属性添加到parameterSetter类上:

  1. <bean class="com.initech.reports.tps.ParameterSetter"
  2. scope="step">
  3. <constructor-arg value="#{jobParameters['myParam']}"/>
  4. </bean>

猜你在找的Spring相关文章