此版本仍在开发中,尚不被认为是稳定的。对于最新的稳定版本,请使用 Spring Batch 文档 5.2.2spring-doc.cadn.net.cn

防止状态持久性

默认情况下,所有ItemReaderItemWriter实现存储其当前 状态在ExecutionContext在提交之前。然而,这可能并不总是如此 期望的行为。例如,许多开发人员选择将他们的数据库读取器 “rerunnable”,使用进程指示器。将一列添加到输入数据中,以 指示是否已处理。当读取特定记录时(或 写入)处理后的标志从falsetrue.然后,SQL 语句可以 在where子句,例如where PROCESSED_IND = false, 从而确保在重新启动时仅返回未处理的记录。在 这种情况下,最好不要存储任何状态,比如当前行号、 因为它在重新启动时无关紧要。因此,所有读者和写入器都包括 'saveState' 属性。spring-doc.cadn.net.cn

以下 bean 定义显示了如何防止 Java 中的状态持久性:spring-doc.cadn.net.cn

Java 配置
@Bean
public JdbcCursorItemReader playerSummarizationSource(DataSource dataSource) {
	return new JdbcCursorItemReaderBuilder<PlayerSummary>()
				.dataSource(dataSource)
				.rowMapper(new PlayerSummaryMapper())
				.saveState(false)
				.sql("SELECT games.player_id, games.year_no, SUM(COMPLETES),"
				  + "SUM(ATTEMPTS), SUM(PASSING_YARDS), SUM(PASSING_TD),"
				  + "SUM(INTERCEPTIONS), SUM(RUSHES), SUM(RUSH_YARDS),"
				  + "SUM(RECEPTIONS), SUM(RECEPTIONS_YARDS), SUM(TOTAL_TD)"
				  + "from games, players where players.player_id ="
				  + "games.player_id group by games.player_id, games.year_no")
				.build();

}

以下 Bean 定义显示了如何防止 XML 中的状态持久性:spring-doc.cadn.net.cn

XML 配置
<bean id="playerSummarizationSource" class="org.spr...JdbcCursorItemReader">
    <property name="dataSource" ref="dataSource" />
    <property name="rowMapper">
        <bean class="org.springframework.batch.samples.PlayerSummaryMapper" />
    </property>
    <property name="saveState" value="false" />
    <property name="sql">
        <value>
            SELECT games.player_id, games.year_no, SUM(COMPLETES),
            SUM(ATTEMPTS), SUM(PASSING_YARDS), SUM(PASSING_TD),
            SUM(INTERCEPTIONS), SUM(RUSHES), SUM(RUSH_YARDS),
            SUM(RECEPTIONS), SUM(RECEPTIONS_YARDS), SUM(TOTAL_TD)
            from games, players where players.player_id =
            games.player_id group by games.player_id, games.year_no
        </value>
    </property>
</bean>

ItemReader上面配置的不会在ExecutionContext为 它参与的任何处决。spring-doc.cadn.net.cn