Spring Batch 4.3 中的新增功能
Spring Batch 4.3 中的新增功能
此版本具有许多新功能、性能改进、 依赖项更新和 API 弃用。本节介绍的 重要变化。有关更改的完整列表,请参阅发行说明。
新功能
新的同步 ItemStreamWriter
类似于SynchronizedItemStreamReader
,此版本引入了SynchronizedItemStreamWriter
.此功能在多线程步骤中很有用
其中并发线程需要同步,以免覆盖彼此的写入。
命名查询的新 JpaQueryProvider
此版本引入了一个新的JpaNamedQueryProvider
旁边的JpaNativeQueryProvider
在以下情况下简化 JPA 命名查询的配置
使用JpaPagingItemReader
:
JpaPagingItemReader<Foo> reader = new JpaPagingItemReaderBuilder<Foo>()
.name("fooReader")
.queryProvider(new JpaNamedQueryProvider("allFoos", Foo.class))
// set other properties on the reader
.build();
新的 JpaCursorItemReader 实现
JPA 2.2 添加了将结果作为游标流式传输的功能,而不仅仅是分页。
此版本引入了一个新的 JPA 项目阅读器,它使用此功能来
stream 结果以基于光标的方式,类似于JdbcCursorItemReader
和HibernateCursorItemReader
.
新的 JobParametersIncrementer 实现
类似于RunIdIncrementer
,此版本添加了一个新的JobParametersIncrementer
即基于DataFieldMaxValueIncrementer
来自 Spring Framework。
Java 记录支持
此版本添加了对将 Java 记录用作面向块的步骤中的项的支持。
新增的RecordFieldSetMapper
支持从平面文件到以下内容的数据映射
Java 记录,如以下示例所示:
@Bean
public FlatFileItemReader<Person> itemReader() {
return new FlatFileItemReaderBuilder<Person>()
.name("personReader")
.resource(new FileSystemResource("persons.csv"))
.delimited()
.names("id", "name")
.fieldSetMapper(new RecordFieldSetMapper<>(Person.class))
.build();
}
在此示例中,Person
type 是定义如下的 Java 记录:
public record Person(int id, String name) { }
这FlatFileItemReader
使用新的RecordFieldSetMapper
映射数据来源
这persons.csv
文件到类型的记录Person
.
性能改进
在 RepositoryItemWriter 中使用批量写入
直到 4.2 版,才能使用CrudRepository#saveAll
在RepositoryItemWriter
,
需要扩展编写器并覆盖write(List)
.
在此版本中,RepositoryItemWriter
已更新为使用CrudRepository#saveAll
默认情况下。
依赖项更新
此版本将依赖的 Spring 项目更新到以下版本:
-
Spring 框架 5.3
-
春季数据 2020.0
-
Spring 集成 5.4
-
Spring AMQP 2.3
-
Spring for Apache Kafka 2.6
-
千分尺 1.5
弃用
弃用 API
以下是此版本中已弃用的 API 列表:
-
org.springframework.batch.core.repository.support.MapJobRepositoryFactoryBean
-
org.springframework.batch.core.explore.support.MapJobExplorerFactoryBean
-
org.springframework.batch.core.repository.dao.MapJobInstanceDao
-
org.springframework.batch.core.repository.dao.MapJobExecutionDao
-
org.springframework.batch.core.repository.dao.MapStepExecutionDao
-
org.springframework.batch.core.repository.dao.MapExecutionContextDao
-
org.springframework.batch.item.data.AbstractNeo4jItemReader
-
org.springframework.batch.item.file.transform.Alignment
-
org.springframework.batch.item.xml.StaxUtils
-
org.springframework.batch.core.launch.support.ScheduledJobParametersFactory
-
org.springframework.batch.item.file.MultiResourceItemReader#getCurrentResource()
-
org.springframework.batch.core.JobExecution#stop()
建议的替换可以在每个已弃用的 API 的 Javadoc 中找到。
弃用 SQLFire 支持支持
SQLFire 自 2014 年 11 月 1 日起处于 EOL 状态。此版本弃用了对使用 SQLFire 的支持 作为作业存储库,并计划在 5.0 版中将其删除。