Spring/spring-batch
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

BATCH-514:Additional small refactorings on Jdbc readers.

Browse Source
This commit is contained in:
lucasward
2008-03-27 04:37:58 +00:00
parent 2faea9d266
commit b876649cb9
3 changed files with 39 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
spring-batch-core/src/main/java/org/springframework/batch/core/resource/JobParametersPreparedStatementSetter.java → spring-batch-core/src/main/java/org/springframework/batch/core/resource/StepExecutionPreparedStatementSetter.java
View File

@@ -24,6 +24,7 @@ import org.springframework.batch.core.JobParameters;
import org.springframework.batch.core.StepExecution;
import org.springframework.batch.core.StepExecutionListener;
import org.springframework.batch.core.listener.StepExecutionListenerSupport;
import org.springframework.batch.item.ExecutionContext;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.jdbc.core.PreparedStatementSetter;
import org.springframework.jdbc.core.SqlTypeValue;
@@ -38,18 +39,23 @@ import org.springframework.util.Assert;
* @author Lucas Ward
*
*/
public class JobParametersPreparedStatementSetter extends StepExecutionListenerSupport implements
public class StepExecutionPreparedStatementSetter extends StepExecutionListenerSupport implements
PreparedStatementSetter, InitializingBean {
private List parameterKeys;
private JobParameters jobParameters;
private ExecutionContext executionContext;
public void setValues(PreparedStatement ps) throws SQLException {
Map parameters = jobParameters.getParameters();
for(int i = 0; i < parameterKeys.size(); i++){
Object arg = parameters.get(parameterKeys.get(i));
String parameterKey = parameterKeys.get(i).toString();
Object arg = executionContext.get(parameterKey);
if(arg == null){
throw new IllegalStateException("No job parameter found for with key of: [" + parameterKeys.get(i) + "]");
arg = parameters.get(parameterKey);
if(arg == null){
throw new IllegalStateException("No job parameter found for with key of: [" + parameterKeys.get(i) + "]");
}
}
StatementCreatorUtils.setParameterValue(ps, i + 1, SqlTypeValue.TYPE_UNKNOWN, arg);
}
@@ -57,6 +63,7 @@ public class JobParametersPreparedStatementSetter extends StepExecutionListenerS
public void beforeStep(StepExecution stepExecution) {
this.jobParameters = stepExecution.getJobParameters();
this.executionContext = stepExecution.getExecutionContext();
}
/**