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

BATCH-220: Updated sample jobs to use 'chunkedStep'

Browse Source
This commit is contained in:
lucasward
2008-02-19 05:55:43 +00:00
parent 786f756ba2
commit d7b9cf9d92
13 changed files with 50 additions and 47 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-batch-samples/src/main/resources/jobs/compositeProcessorSampleJob.xml
View File

@@ -12,7 +12,7 @@
<bean id="compositeProcessorJob" parent="simpleJob">
<property name="steps">
<bean id="step1" parent="simpleStep">
<bean id="step1" parent="chunkedStep">
<property name="itemReader">
<bean
class="org.springframework.batch.item.reader.ValidatingItemReader">

2
spring-batch-samples/src/main/resources/jobs/delegatingJob.xml
View File

@@ -23,7 +23,7 @@
<bean id="jobConfiguration" parent="simpleJob">
<property name="steps">
<bean id="step1" parent="simpleStep">
<bean id="step1" parent="chunkedStep">
<property name="itemReader">
<bean
class="org.springframework.batch.item.reader.ItemReaderAdapter">

2
spring-batch-samples/src/main/resources/jobs/fixedLengthImportJob.xml
View File

@@ -14,7 +14,7 @@
<bean id="fixedLengthImportJob" parent="simpleJob">
<property name="steps">
<bean id="step1" parent="simpleStep">
<bean id="step1" parent="chunkedStep">
<property name="itemReader">
<bean
class="org.springframework.batch.item.reader.ValidatingItemReader">

12
spring-batch-samples/src/main/resources/jobs/footballJob.xml
View File

@@ -16,8 +16,8 @@
<property name="startLimit" value="100" />
<property name="steps">
<list>
<bean id="playerload" parent="simpleStep">
<property name="commitInterval" value="1"></property>
<bean id="playerload" parent="chunkedStep">
<property name="chunkSize" value="1"></property>
<property name="startLimit" value="100" />
<property name="allowStartIfComplete" value="false" />
<property name="itemReader"
@@ -35,8 +35,8 @@
</bean>
</property>
</bean>
<bean id="gameLoad" parent="simpleStep">
<property name="commitInterval" value="1" />
<bean id="gameLoad" parent="chunkedStep">
<property name="chunkSize" value="1" />
<property name="startLimit" value="100" />
<property name="itemReader"
ref="gameFileItemReader" />
@@ -48,8 +48,8 @@
</bean>
</property>
</bean>
<bean id="playerSummarization" parent="simpleStep">
<property name="commitInterval" value="1" />
<bean id="playerSummarization" parent="chunkedStep">
<property name="chunkSize" value="1" />
<property name="startLimit" value="100" />
<property name="itemReader"
ref="playerSummarizationSource" />

2
spring-batch-samples/src/main/resources/jobs/ibatisJob.xml
View File

@@ -16,7 +16,7 @@
<bean id="ibatisJob" parent="simpleJob">
<property name="steps">
<bean id="step1" parent="simpleStep">
<bean id="step1" parent="chunkedStep">
<property name="itemReader" ref="ibatisItemReader" />
<property name="itemWriter">
<bean

2
spring-batch-samples/src/main/resources/jobs/multilineJob.xml
View File

@@ -12,7 +12,7 @@
<bean id="multilineJob" parent="simpleJob">
<property name="steps">
<bean id="step1" parent="simpleStep">
<bean id="step1" parent="chunkedStep">
<property name="itemReader">
<bean
class="org.springframework.batch.item.reader.AggregateItemReader">

2
spring-batch-samples/src/main/resources/jobs/multilineOrderJob.xml
View File

@@ -15,7 +15,7 @@
<bean id="multilineOrderJob" parent="simpleJob">
<property name="steps">
<bean id="step1" parent="simpleStep">
<bean id="step1" parent="chunkedStep">
<property name="itemReader">
<bean class="org.springframework.batch.sample.item.reader.OrderItemReader">
<property name="itemReader" ref="fileInputTemplate" />

4
spring-batch-samples/src/main/resources/jobs/restartSample.xml
View File

@@ -15,7 +15,7 @@
<bean id="restartSampleJob" parent="simpleJob">
<property name="steps">
<bean id="step1" parent="simpleStep">
<bean id="step1" parent="chunkedStep">
<property name="itemReader">
<bean
class="org.springframework.batch.item.reader.ValidatingItemReader">
@@ -30,7 +30,7 @@
<property name="dao" ref="tradeDao" />
</bean>
</property>
<property name="commitInterval" value="2" />
<property name="chunkSize" value="2" />
</bean>
</property>
</bean>

56
spring-batch-samples/src/main/resources/jobs/rollbackJob.xml
View File

@@ -17,44 +17,46 @@
<bean id="tradeJob" parent="simpleJob">
<property name="steps">
<list>
<bean id="step1" parent="repeatOperationsStep">
<property name="chunkOperations">
<bean id="step1" parent="chunkedStep">
<property name="retryPolicy">
<bean class="org.springframework.batch.retry.policy.SimpleRetryPolicy" />
</property>
<property name="chunker">
<bean
class="org.springframework.batch.repeat.support.RepeatTemplate">
<property name="completionPolicy">
class="org.springframework.batch.execution.step.simple.ItemChunker">
<constructor-arg>
<bean
class="org.springframework.batch.repeat.policy.SimpleCompletionPolicy">
<property name="chunkSize"
value="50" />
class="org.springframework.batch.item.reader.ValidatingItemReader">
<property name="itemReader"
ref="fileInputTemplate" />
<property name="validator"
ref="tradeValidator" />
</bean>
</constructor-arg>
<property name="itemSkipPolicy">
<bean
class="org.springframework.batch.execution.step.simple.LimitCheckingItemSkipPolicy">
<constructor-arg value="5" />
</bean>
</property>
</bean>
</property>
<property name="stepOperations">
<property name="dechunker">
<bean
class="org.springframework.batch.repeat.support.RepeatTemplate">
<property name="exceptionHandler">
class="org.springframework.batch.execution.step.simple.ItemDechunker">
<constructor-arg>
<bean
class="org.springframework.batch.repeat.exception.handler.SimpleLimitExceptionHandler"
p:limit="5" p:type="java.lang.Exception" />
class="org.springframework.batch.sample.item.writer.TradeWriter"
p:dao-ref="tradeDao" p:failure="3" />
</constructor-arg>
<property name="itemSkipPolicy">
<bean
class="org.springframework.batch.execution.step.simple.LimitCheckingItemSkipPolicy">
<constructor-arg value="5" />
</bean>
</property>
</bean>
</property>
<property name="itemReader">
<bean
class="org.springframework.batch.item.reader.ValidatingItemReader">
<property name="itemReader"
ref="fileInputTemplate" />
<property name="validator"
ref="tradeValidator" />
</bean>
</property>
<property name="itemWriter">
<bean
class="org.springframework.batch.sample.item.writer.TradeWriter"
p:dao-ref="tradeDao" p:failure="3" />
</property>
<property name="jobRepository" ref="jobRepository" />
</bean>
<bean id="step2" parent="simpleStep">
<property name="itemReader"

8
spring-batch-samples/src/main/resources/jobs/tradeJob.xml
View File

@@ -16,7 +16,7 @@
<bean id="tradeJob" parent="simpleJob">
<property name="steps">
<list>
<bean id="step1" parent="simpleStep">
<bean id="step1" parent="chunkedStep">
<property name="itemReader">
<bean
class="org.springframework.batch.item.reader.ValidatingItemReader">
@@ -32,7 +32,7 @@
p:dao-ref="tradeDao" />
</property>
</bean>
<bean id="step2" parent="simpleStep">
<bean id="step2" parent="chunkedStep">
<property name="itemReader" ref="tradeSqlItemReader" />
<property name="itemWriter">
<bean
@@ -40,7 +40,7 @@
p:dao-ref="customerDao" />
</property>
</bean>
<bean id="step3" parent="simpleStep">
<bean id="step3" parent="chunkedStep">
<property name="itemReader" ref="customerSqlItemReader" />
<property name="itemWriter">
<bean
@@ -69,7 +69,7 @@
<bean id="customerSqlItemReader" class="org.springframework.batch.io.cursor.JdbcCursorItemReader"
scope="step">
<aop:scoped-proxy />
<property name="dataSource" ref="dataSource" />
<property name="dataSource" ref="dataSource" />
<property name="sql"
value="SELECT id, name, credit FROM customer " />
<property name="mapper">

2
spring-batch-samples/src/main/resources/jobs/xmlStaxJob.xml
View File

@@ -16,7 +16,7 @@
<bean id="xmlStaxJob" parent="simpleJob">
<property name="steps">
<bean id="step1" parent="simpleStep">
<bean id="step1" parent="chunkedStep">
<property name="itemReader">
<bean
class="org.springframework.batch.io.xml.StaxEventItemReader"

1
spring-batch-samples/src/main/resources/simple-container-definition.xml
View File

@@ -128,6 +128,7 @@
<constructor-arg ref="transactionManager" />
</bean>
</property>
<property name="chunkSize" value="1" />
</bean>
<bean id="repeatOperationsStep" parent="abstractStep"

2
spring-batch-samples/src/test/java/org/springframework/batch/sample/RollbackJobFunctionalTests.java
View File

@@ -29,7 +29,7 @@ public class RollbackJobFunctionalTests extends AbstractValidatingBatchLauncherT
protected void validatePostConditions() throws Exception {
int after = jdbcTemplate.queryForInt("SELECT COUNT(*) from TRADE");
assertEquals(before+4, after);
assertEquals(before+5, after);
}