BATCH-407:Added repository factory to samples and created a factory for incrementers for that logic to obtain them could be unit tested. Also renamed SimpelJobRepositoryFactoryBean to just JobRepositoryFactoryBean
This commit is contained in:
@@ -62,36 +62,9 @@
|
||||
<bean id="lobHandler" class="${batch.lob.handler.class}"/>
|
||||
|
||||
<bean id="incrementerParent"
|
||||
class="${batch.database.incrementer.class}" abstract="true">
|
||||
class="${batch.database.incrementer.class}">
|
||||
<property name="dataSource" ref="dataSource" />
|
||||
</bean>
|
||||
|
||||
<bean id="jobIncrementer" parent="incrementerParent">
|
||||
<property name="incrementerName" value="BATCH_JOB_SEQ" />
|
||||
</bean>
|
||||
|
||||
<bean id="jobExecutionIncrementer" parent="incrementerParent">
|
||||
<property name="incrementerName"
|
||||
value="BATCH_JOB_EXECUTION_SEQ" />
|
||||
</bean>
|
||||
|
||||
<bean id="stepIncrementer" parent="incrementerParent">
|
||||
<property name="incrementerName" value="BATCH_STEP_SEQ" />
|
||||
</bean>
|
||||
|
||||
<bean id="stepExecutionIncrementer" parent="incrementerParent">
|
||||
<property name="incrementerName"
|
||||
value="BATCH_STEP_EXECUTION_SEQ" />
|
||||
</bean>
|
||||
|
||||
<bean id="partitionIncrementer" parent="incrementerParent">
|
||||
<property name="incrementerName" value="BATCH_PARTITION_SEQ" />
|
||||
</bean>
|
||||
|
||||
<bean id="partitionInstanceIncrementer"
|
||||
parent="incrementerParent">
|
||||
<property name="incrementerName"
|
||||
value="BATCH_PARTITION_EXECUTION_SEQ" />
|
||||
<property name="incrementerName" value="ID" />
|
||||
</bean>
|
||||
|
||||
<!--import resource="alt-data-source-context.xml" /-->
|
||||
|
||||
@@ -38,33 +38,10 @@
|
||||
<tx:method name="*" />
|
||||
</tx:attributes>
|
||||
</tx:advice>
|
||||
|
||||
|
||||
<bean id="jobRepository"
|
||||
class="org.springframework.batch.execution.repository.SimpleJobRepository">
|
||||
<constructor-arg ref="jobInstanceDao" />
|
||||
<constructor-arg ref="jobExecutionDao" />
|
||||
<constructor-arg ref="stepExecutionDao" />
|
||||
</bean>
|
||||
|
||||
<bean id="jobInstanceDao" lazy-init="true"
|
||||
class="org.springframework.batch.execution.repository.dao.JdbcJobInstanceDao">
|
||||
<property name="jdbcTemplate" ref="jdbcTemplate" />
|
||||
<property name="jobIncrementer" ref="jobIncrementer" />
|
||||
</bean>
|
||||
|
||||
<bean id="jobExecutionDao" lazy-init="true"
|
||||
class="org.springframework.batch.execution.repository.dao.JdbcJobExecutionDao">
|
||||
<property name="jdbcTemplate" ref="jdbcTemplate" />
|
||||
<property name="jobExecutionIncrementer"
|
||||
ref="jobExecutionIncrementer" />
|
||||
</bean>
|
||||
|
||||
<bean id="stepExecutionDao" lazy-init="true"
|
||||
class="org.springframework.batch.execution.repository.dao.JdbcStepExecutionDao">
|
||||
<property name="jdbcTemplate" ref="jdbcTemplate" />
|
||||
<property name="stepExecutionIncrementer"
|
||||
ref="stepExecutionIncrementer" />
|
||||
</bean>
|
||||
class="org.springframework.batch.execution.repository.JobRepositoryFactoryBean"
|
||||
p:databaseType="hsql" p:dataSource-ref="dataSource" />
|
||||
|
||||
<bean id="mapJobInstanceDao" lazy-init="true"
|
||||
class="org.springframework.batch.execution.repository.dao.MapJobInstanceDao" />
|
||||
|
||||
@@ -19,7 +19,7 @@ public class JdbcTradeWriterTests extends AbstractTransactionalDataSourceSpringC
|
||||
|
||||
JdbcTradeDao writer = new JdbcTradeDao();
|
||||
|
||||
AbstractDataFieldMaxValueIncrementer incrementer = (AbstractDataFieldMaxValueIncrementer)applicationContext.getBean("jobIncrementer");
|
||||
AbstractDataFieldMaxValueIncrementer incrementer = (AbstractDataFieldMaxValueIncrementer)applicationContext.getBean("incrementerParent");
|
||||
incrementer.setIncrementerName("TRADE_SEQ");
|
||||
|
||||
writer.setIncrementer(incrementer);
|
||||
|
||||
Reference in New Issue
Block a user