单步批处理作业启动器 (Single Step Batch Job Starter) | Spring Cloud Task3.1.2-SNAPSHOT中文文档|Spring官方文档|SpringBoot 教程|Spring中文网

此版本仍在开发中，尚未被视为稳定版本。最新的稳定版请使用 spring-cloud-task 3.1.1！

本节介绍如何使用入门包含在 Spring Cloud Task 中。此启动器允许您使用配置定义一个、一个或一个完整的单步 Spring Batch。有关 Spring Batch 及其功能的更多信息，请参阅 Spring Batch 文档。JobStepItemReaderItemWriterJob

若要获取 Maven 的入门版本，请将以下内容添加到您的构建中：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-single-step-batch-job</artifactId>
    <version>2.3.0</version>
</dependency>

要获取 Gradle 的入门版，请将以下内容添加到您的构建中：

compile "org.springframework.cloud:spring-cloud-starter-single-step-batch-job:2.3.0"

定义作业

您可以使用启动器来定义小至 an 或 an 或 full 等于 full 。在本节中，我们将定义需要定义哪些属性才能配置 .ItemReaderItemWriterJobJob

性能

首先，初学者提供了一组属性，可让您通过一个步骤配置作业的基础知识：

表 1.作业属性
财产	类型	默认值	描述
`spring.batch.job.jobName`	`String`	`null`	作业的名称。
`spring.batch.job.stepName`	`String`	`null`	步骤的名称。
`spring.batch.job.chunkSize`	`Integer`	`null`	每个事务要处理的项目数。

配置上述属性后，您就拥有了一个具有单个基于块的步骤的作业。这个基于块的步骤读取、处理和写入实例作为项目。但是，该步骤尚未执行任何操作。您需要配置一个、可选的，并给它一些事情做。配置一个其中，您可以使用属性并配置已提供的选项之一自动配置，或者您可以使用标准 Spring 配置配置自己的配置机制。Map<String, Object>ItemReaderItemProcessorItemWriter

如果配置自己的类型，则输入和输出类型必须与步骤中的其他类型匹配。此启动器中的实现和实现都使用 a 作为输入项和输出项。ItemReaderItemWriterMap<String, Object>

表 1.作业属性
财产	类型	默认值	描述
`spring.batch.job.jobName`	`String`	`null`	作业的名称。
`spring.batch.job.stepName`	`String`	`null`	步骤的名称。
`spring.batch.job.chunkSize`	`Integer`	`null`	每个事务要处理的项目数。

ItemReader 实现的自动配置

此启动器为四种不同的实现提供自动配置：、、和。在本节中，我们将概述如何使用提供的自动配置。ItemReaderAmqpItemReaderFlatFileItemReaderJdbcCursorItemReaderKafkaItemReader

AmqpItemReader

您可以使用 .这此实现的自动配置依赖于两组配置。首先是 .您可以自行配置或使用 Spring Boot 提供的自动配置。请参阅 Spring Boot AMQP 文档。配置后，可以启用批处理功能来支持它通过设置以下属性：AmqpItemReaderItemReaderAmqpTemplateAmqpTemplate

表 2. 性能`AmqpItemReader`
财产	类型	默认值	描述
`spring.batch.job.amqpitemreader.enabled`	`boolean`	`false`	如果，将执行自动配置。`true`
`spring.batch.job.amqpitemreader.jsonConverterEnabled`	`boolean`	`true`	指示是否应注册以分析消息。`Jackson2JsonMessageConverter`

有关详细信息，请参阅 AmqpItemReader 文档。

FlatFileItemReader

FlatFileItemReader允许您从平面文件（如 CSV）中读取数据和其他文件格式）。若要读取文件，可以提供一些组件自己通过正常的 Spring 配置（、、、或）。您还可以使用用于配置读取器的以下属性：LineTokenizerRecordSeparatorPolicyFieldSetMapperLineMapperSkippedLinesCallback

表 3. 性能`FlatFileItemReader`
财产	类型	默认值	描述
`spring.batch.job.flatfileitemreader.saveState`	`boolean`	`true`	确定是否应保存状态以供重新启动。
`spring.batch.job.flatfileitemreader.name`	`String`	`null`	用于在中提供唯一键的名称。`ExecutionContext`
`spring.batch.job.flatfileitemreader.maxItemcount`	`int`	`Integer.MAX_VALUE`	要从文件中读取的最大项目数。
`spring.batch.job.flatfileitemreader.currentItemCount`	`int`	0	已读取的项目数。在重新启动时使用。
`spring.batch.job.flatfileitemreader.comments`	`List<String>`	空列表	指示文件中注释行（要忽略的行）的字符串列表。
`spring.batch.job.flatfileitemreader.resource`	`Resource`	`null`	要读取的资源。
`spring.batch.job.flatfileitemreader.strict`	`boolean`	`true`	如果设置为，则在未找到资源时，读取器将引发异常。`true`
`spring.batch.job.flatfileitemreader.encoding`	`String`	`FlatFileItemReader.DEFAULT_CHARSET`	读取文件时要使用的编码。
`spring.batch.job.flatfileitemreader.linesToSkip`	`int`	0	指示在文件开头要跳过的行数。
`spring.batch.job.flatfileitemreader.delimited`	`boolean`	`false`	指示文件是否为带分隔符的文件（CSV 和其他格式）。此属性中只有一个，或者可以同时存在。`spring.batch.job.flatfileitemreader.fixedLengthtrue`
`spring.batch.job.flatfileitemreader.delimiter`	`String`	`DelimitedLineTokenizer.DELIMITER_COMMA`	如果读取分隔文件，则指示要分析的分隔符。
`spring.batch.job.flatfileitemreader.quoteCharacter`	`char`	`DelimitedLineTokenizer.DEFAULT_QUOTE_CHARACTER`	用于确定用于引用值的字符。
`spring.batch.job.flatfileitemreader.includedFields`	`List<Integer>`	空列表	用于确定要包含在项目中的记录中的哪些字段的索引列表。
`spring.batch.job.flatfileitemreader.fixedLength`	`boolean`	`false`	指示是否按列号分析文件的记录。此属性中只有一个，或者可以同时存在。`spring.batch.job.flatfileitemreader.delimitedtrue`
`spring.batch.job.flatfileitemreader.ranges`	`List<Range>`	空列表	用于分析固定宽度记录的列范围列表。请参阅 Range 文档。
`spring.batch.job.flatfileitemreader.names`	`String []`	`null`	从记录中解析的每个字段的名称列表。这些名称是从此返回的 in 项中的键。`Map<String, Object>ItemReader`
`spring.batch.job.flatfileitemreader.parsingStrict`	`boolean`	`true`	如果设置为，则无法映射字段，则映射失败。`true`

请参阅 FlatFileItemReader 文档。

JdbcCursorItemReader

对关系数据库运行查询并循环访问生成的游标（）以提供生成的项。此自动配置允许您提供 a 和 /或 a 或两者。你还可以使用以下属性来配置：JdbcCursorItemReaderResultSetPreparedStatementSetterRowMapperJdbcCursorItemReader

表 4. 性能`JdbcCursorItemReader`
财产	类型	默认值	描述
`spring.batch.job.jdbccursoritemreader.saveState`	`boolean`	`true`	确定是否应保存状态以供重新启动。
`spring.batch.job.jdbccursoritemreader.name`	`String`	`null`	用于在中提供唯一键的名称。`ExecutionContext`
`spring.batch.job.jdbccursoritemreader.maxItemcount`	`int`	`Integer.MAX_VALUE`	要从文件中读取的最大项目数。
`spring.batch.job.jdbccursoritemreader.currentItemCount`	`int`	0	已读取的项目数。在重新启动时使用。
`spring.batch.job.jdbccursoritemreader.fetchSize`	`int`		向驱动程序提示，指示每次调用数据库系统要检索多少条记录。为了获得最佳性能，您通常希望将其设置为与块大小匹配。
`spring.batch.job.jdbccursoritemreader.maxRows`	`int`		要从数据库中读取的最大项数。
`spring.batch.job.jdbccursoritemreader.queryTimeout`	`int`		查询超时的毫秒数。
`spring.batch.job.jdbccursoritemreader.ignoreWarnings`	`boolean`	`true`	确定读取器在处理时是否应忽略 SQL 警告。
`spring.batch.job.jdbccursoritemreader.verifyCursorPosition`	`boolean`	`true`	指示是否应在每次读取后验证光标的位置，以验证光标是否未前进。`RowMapper`
`spring.batch.job.jdbccursoritemreader.driverSupportsAbsolute`	`boolean`	`false`	指示驱动程序是否支持光标的绝对定位。
`spring.batch.job.jdbccursoritemreader.useSharedExtendedConnection`	`boolean`	`false`	指示连接是否与其他处理共享（因此是事务的一部分）。
`spring.batch.job.jdbccursoritemreader.sql`	`String`	`null`	要从中读取的 SQL 查询。

还可以使用以下属性专门为读取器指定 JDBC 数据源： .性能JdbcCursorItemReader

财产类型默认值描述

财产	类型	默认值	描述
`spring.batch.job.jdbccursoritemreader.datasource.enable`	`boolean`	`false`	确定是否应启用。`JdbcCursorItemReaderDataSource`
`jdbccursoritemreader.datasource.url`	`String`	`null`	数据库的 JDBC URL。
`jdbccursoritemreader.datasource.username`	`String`	`null`	数据库的登录用户名。
`jdbccursoritemreader.datasource.password`	`String`	`null`	数据库的登录密码。
`jdbccursoritemreader.datasource.driver-class-name`	`String`	`null`	JDBC 驱动程序的完全限定名称。

spring.batch.job.jdbccursoritemreader.datasource.enable

boolean

false

确定是否应启用。JdbcCursorItemReaderDataSource

jdbccursoritemreader.datasource.url

String

null

数据库的 JDBC URL。

jdbccursoritemreader.datasource.username

String

null

数据库的登录用户名。

jdbccursoritemreader.datasource.password

String

null

数据库的登录密码。

jdbccursoritemreader.datasource.driver-class-name

String

null

JDBC 驱动程序的完全限定名称。

如果未指定，则将使用 default。DataSourceJDBCCursorItemReaderjdbccursoritemreader_datasource

请参阅 JdbcCursorItemReader 文档。

KafkaItemReader

从 Kafka 主题引入数据分区非常有用，而且正是可以执行的操作。要配置，两件的配置是必需的。首先，使用 Spring Boot 的 Kafka 配置 Kafka 自动配置是必需的（请参阅 Spring Boot Kafka 文档）。从 Spring Boot 配置 Kafka 属性后，可以通过设置以下属性来配置 Kafka 属性：KafkaItemReaderKafkaItemReaderKafkaItemReader

表 5. 性能`KafkaItemReader`
财产	类型	默认值	描述
`spring.batch.job.kafkaitemreader.name`	`String`	`null`	用于在中提供唯一键的名称。`ExecutionContext`
`spring.batch.job.kafkaitemreader.topic`	`String`	`null`	要从中读取的主题的名称。
`spring.batch.job.kafkaitemreader.partitions`	`List<Integer>`	空列表	要从中读取的分区索引列表。
`spring.batch.job.kafkaitemreader.pollTimeOutInSeconds`	`long`	30	操作超时。`poll()`
`spring.batch.job.kafkaitemreader.saveState`	`boolean`	`true`	确定是否应保存状态以供重新启动。

请参阅 KafkaItemReader 文档。

原生编译

单步批处理的优点是，它允许您在使用 JVM 时动态选择要在运行时使用的读取器和写入器 Bean。但是，使用本机编译时，必须在生成时（而不是运行时）确定读取器和写入器。以下示例执行此操作：

<plugin>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-maven-plugin</artifactId>
    <executions>
        <execution>
            <id>process-aot</id>
            <goals>
                <goal>process-aot</goal>
            </goals>
            <configuration>
                <jvmArguments>
                    -Dspring.batch.job.flatfileitemreader.name=fooReader
                    -Dspring.batch.job.flatfileitemwriter.name=fooWriter
                </jvmArguments>
            </configuration>
        </execution>
    </executions>
</plugin>

表 2. 性能`AmqpItemReader`
财产	类型	默认值	描述
`spring.batch.job.amqpitemreader.enabled`	`boolean`	`false`	如果，将执行自动配置。`true`
`spring.batch.job.amqpitemreader.jsonConverterEnabled`	`boolean`	`true`	指示是否应注册以分析消息。`Jackson2JsonMessageConverter`

表 3. 性能`FlatFileItemReader`
财产	类型	默认值	描述
`spring.batch.job.flatfileitemreader.saveState`	`boolean`	`true`	确定是否应保存状态以供重新启动。
`spring.batch.job.flatfileitemreader.name`	`String`	`null`	用于在中提供唯一键的名称。`ExecutionContext`
`spring.batch.job.flatfileitemreader.maxItemcount`	`int`	`Integer.MAX_VALUE`	要从文件中读取的最大项目数。
`spring.batch.job.flatfileitemreader.currentItemCount`	`int`	0	已读取的项目数。在重新启动时使用。
`spring.batch.job.flatfileitemreader.comments`	`List<String>`	空列表	指示文件中注释行（要忽略的行）的字符串列表。
`spring.batch.job.flatfileitemreader.resource`	`Resource`	`null`	要读取的资源。
`spring.batch.job.flatfileitemreader.strict`	`boolean`	`true`	如果设置为，则在未找到资源时，读取器将引发异常。`true`
`spring.batch.job.flatfileitemreader.encoding`	`String`	`FlatFileItemReader.DEFAULT_CHARSET`	读取文件时要使用的编码。
`spring.batch.job.flatfileitemreader.linesToSkip`	`int`	0	指示在文件开头要跳过的行数。
`spring.batch.job.flatfileitemreader.delimited`	`boolean`	`false`	指示文件是否为带分隔符的文件（CSV 和其他格式）。此属性中只有一个，或者可以同时存在。`spring.batch.job.flatfileitemreader.fixedLengthtrue`
`spring.batch.job.flatfileitemreader.delimiter`	`String`	`DelimitedLineTokenizer.DELIMITER_COMMA`	如果读取分隔文件，则指示要分析的分隔符。
`spring.batch.job.flatfileitemreader.quoteCharacter`	`char`	`DelimitedLineTokenizer.DEFAULT_QUOTE_CHARACTER`	用于确定用于引用值的字符。
`spring.batch.job.flatfileitemreader.includedFields`	`List<Integer>`	空列表	用于确定要包含在项目中的记录中的哪些字段的索引列表。
`spring.batch.job.flatfileitemreader.fixedLength`	`boolean`	`false`	指示是否按列号分析文件的记录。此属性中只有一个，或者可以同时存在。`spring.batch.job.flatfileitemreader.delimitedtrue`
`spring.batch.job.flatfileitemreader.ranges`	`List<Range>`	空列表	用于分析固定宽度记录的列范围列表。请参阅 Range 文档。
`spring.batch.job.flatfileitemreader.names`	`String []`	`null`	从记录中解析的每个字段的名称列表。这些名称是从此返回的 in 项中的键。`Map<String, Object>ItemReader`
`spring.batch.job.flatfileitemreader.parsingStrict`	`boolean`	`true`	如果设置为，则无法映射字段，则映射失败。`true`

表 4. 性能`JdbcCursorItemReader`
财产	类型	默认值	描述
`spring.batch.job.jdbccursoritemreader.saveState`	`boolean`	`true`	确定是否应保存状态以供重新启动。
`spring.batch.job.jdbccursoritemreader.name`	`String`	`null`	用于在中提供唯一键的名称。`ExecutionContext`
`spring.batch.job.jdbccursoritemreader.maxItemcount`	`int`	`Integer.MAX_VALUE`	要从文件中读取的最大项目数。
`spring.batch.job.jdbccursoritemreader.currentItemCount`	`int`	0	已读取的项目数。在重新启动时使用。
`spring.batch.job.jdbccursoritemreader.fetchSize`	`int`		向驱动程序提示，指示每次调用数据库系统要检索多少条记录。为了获得最佳性能，您通常希望将其设置为与块大小匹配。
`spring.batch.job.jdbccursoritemreader.maxRows`	`int`		要从数据库中读取的最大项数。
`spring.batch.job.jdbccursoritemreader.queryTimeout`	`int`		查询超时的毫秒数。
`spring.batch.job.jdbccursoritemreader.ignoreWarnings`	`boolean`	`true`	确定读取器在处理时是否应忽略 SQL 警告。
`spring.batch.job.jdbccursoritemreader.verifyCursorPosition`	`boolean`	`true`	指示是否应在每次读取后验证光标的位置，以验证光标是否未前进。`RowMapper`
`spring.batch.job.jdbccursoritemreader.driverSupportsAbsolute`	`boolean`	`false`	指示驱动程序是否支持光标的绝对定位。
`spring.batch.job.jdbccursoritemreader.useSharedExtendedConnection`	`boolean`	`false`	指示连接是否与其他处理共享（因此是事务的一部分）。
`spring.batch.job.jdbccursoritemreader.sql`	`String`	`null`	要从中读取的 SQL 查询。

财产类型默认值描述

财产	类型	默认值	描述
`spring.batch.job.jdbccursoritemreader.datasource.enable`	`boolean`	`false`	确定是否应启用。`JdbcCursorItemReaderDataSource`
`jdbccursoritemreader.datasource.url`	`String`	`null`	数据库的 JDBC URL。
`jdbccursoritemreader.datasource.username`	`String`	`null`	数据库的登录用户名。
`jdbccursoritemreader.datasource.password`	`String`	`null`	数据库的登录密码。
`jdbccursoritemreader.datasource.driver-class-name`	`String`	`null`	JDBC 驱动程序的完全限定名称。

spring.batch.job.jdbccursoritemreader.datasource.enable

boolean

false

确定是否应启用。JdbcCursorItemReaderDataSource

jdbccursoritemreader.datasource.url

String

null

数据库的 JDBC URL。

jdbccursoritemreader.datasource.username

String

null

数据库的登录用户名。

jdbccursoritemreader.datasource.password

String

null

数据库的登录密码。

jdbccursoritemreader.datasource.driver-class-name

String

null

JDBC 驱动程序的完全限定名称。

如果未指定，则将使用 default。DataSourceJDBCCursorItemReaderjdbccursoritemreader_datasource

表 5. 性能`KafkaItemReader`
财产	类型	默认值	描述
`spring.batch.job.kafkaitemreader.name`	`String`	`null`	用于在中提供唯一键的名称。`ExecutionContext`
`spring.batch.job.kafkaitemreader.topic`	`String`	`null`	要从中读取的主题的名称。
`spring.batch.job.kafkaitemreader.partitions`	`List<Integer>`	空列表	要从中读取的分区索引列表。
`spring.batch.job.kafkaitemreader.pollTimeOutInSeconds`	`long`	30	操作超时。`poll()`
`spring.batch.job.kafkaitemreader.saveState`	`boolean`	`true`	确定是否应保存状态以供重新启动。

ItemProcessor 配置

单步批处理作业自动配置接受 if 在 .如果找到正确类型的（），它是自动接线的进入步骤。ItemProcessorApplicationContextItemProcessor<Map<String, Object>, Map<String, Object>>

ItemWriter 实现的自动配置

此启动器为以下实现提供自动配置匹配支持的实现：、、和。本节介绍如何使用自动配置来配置受支持的 .ItemWriterItemReaderAmqpItemWriterFlatFileItemWriterJdbcItemWriterKafkaItemWriterItemWriter

AmqpItemWriter

要写入 RabbitMQ 队列，您需要两组配置。首先，您需要一个 .最简单的方法是使用 Spring Boot 的 RabbitMQ 自动配置。请参阅 Spring Boot AMQP 文档。AmqpTemplate

配置后，可以通过设置以下属性：AmqpTemplateAmqpItemWriter

表 6. 性能`AmqpItemWriter`
财产	类型	默认值	描述
`spring.batch.job.amqpitemwriter.enabled`	`boolean`	`false`	如果，则运行自动配置。`true`
`spring.batch.job.amqpitemwriter.jsonConverterEnabled`	`boolean`	`true`	指示是否应注册以转换邮件。`Jackson2JsonMessageConverter`

FlatFileItemWriter

要将文件写入作为步骤的输出，您可以配置 . 自动配置接受已显式配置的组件（如、、或）和已通过设置指定的以下属性来配置的组件：FlatFileItemWriterLineAggregatorFieldExtractorFlatFileHeaderCallbackFlatFileFooterCallback

表 7. 性能`FlatFileItemWriter`
财产	类型	默认值	描述
`spring.batch.job.flatfileitemwriter.resource`	`Resource`	`null`	要读取的资源。
`spring.batch.job.flatfileitemwriter.delimited`	`boolean`	`false`	指示输出文件是否为分隔文件。如果，则必须是。`truespring.batch.job.flatfileitemwriter.formattedfalse`
`spring.batch.job.flatfileitemwriter.formatted`	`boolean`	`false`	指示输出文件是否为格式化文件。如果，则必须是。`truespring.batch.job.flatfileitemwriter.delimitedfalse`
`spring.batch.job.flatfileitemwriter.format`	`String`	`null`	用于生成格式化文件输出的格式。格式设置是通过使用来执行的。`String.format`
`spring.batch.job.flatfileitemwriter.locale`	`Locale`	`Locale.getDefault()`	生成文件时要使用的。`Locale`
`spring.batch.job.flatfileitemwriter.maximumLength`	`int`	0	记录的最大长度。如果为 0，则大小不受限制。
`spring.batch.job.flatfileitemwriter.minimumLength`	`int`	0	最小记录长度。
`spring.batch.job.flatfileitemwriter.delimiter`	`String`	`,`	用于分隔分隔文件中的字段。`String`
`spring.batch.job.flatfileitemwriter.encoding`	`String`	`FlatFileItemReader.DEFAULT_CHARSET`	写入文件时要使用的编码。
`spring.batch.job.flatfileitemwriter.forceSync`	`boolean`	`false`	指示是否应在刷新时将文件强制同步到磁盘。
`spring.batch.job.flatfileitemwriter.names`	`String []`	`null`	从记录中解析的每个字段的名称列表。这些名称是 for this 接收到的项目中的键。`Map<String, Object>ItemWriter`
`spring.batch.job.flatfileitemwriter.append`	`boolean`	`false`	指示如果找到输出文件，是否应追加文件。
`spring.batch.job.flatfileitemwriter.lineSeparator`	`String`	`FlatFileItemWriter.DEFAULT_LINE_SEPARATOR`	用于分隔输出文件中的行。`String`
`spring.batch.job.flatfileitemwriter.name`	`String`	`null`	用于在中提供唯一键的名称。`ExecutionContext`
`spring.batch.job.flatfileitemwriter.saveState`	`boolean`	`true`	确定是否应保存状态以供重新启动。
`spring.batch.job.flatfileitemwriter.shouldDeleteIfEmpty`	`boolean`	`false`	如果设置为，则在作业完成时删除空文件（没有输出）。`true`
`spring.batch.job.flatfileitemwriter.shouldDeleteIfExists`	`boolean`	`true`	如果设置为并且找到输出文件应位于的位置的文件，则在步骤开始之前将其删除。`true`
`spring.batch.job.flatfileitemwriter.transactional`	`boolean`	`FlatFileItemWriter.DEFAULT_TRANSACTIONAL`	指示读取器是否为事务队列（指示读取的项目在失败时返回到队列）。

请参阅 FlatFileItemWriter 文档。

JdbcBatchItemWriter

要将步骤的输出写入关系数据库，此入门器提供了以下功能自动配置 .通过自动配置，您可以提供 own 或和通过设置以下属性来配置选项：JdbcBatchItemWriterItemPreparedStatementSetterItemSqlParameterSourceProvider

表 8. 性能`JdbcBatchItemWriter`
财产	类型	默认值	描述
`spring.batch.job.jdbcbatchitemwriter.name`	`String`	`null`	用于在中提供唯一键的名称。`ExecutionContext`
`spring.batch.job.jdbcbatchitemwriter.sql`	`String`	`null`	用于插入每个项的 SQL。
`spring.batch.job.jdbcbatchitemwriter.assertUpdates`	`boolean`	`true`	是否验证每个插入是否都会导致至少一条记录的更新。

还可以使用以下属性专门为编写器指定 JDBC DataSource： .性能JdbcBatchItemWriter

财产类型默认值描述

财产	类型	默认值	描述
`spring.batch.job.jdbcbatchitemwriter.datasource.enable`	`boolean`	`false`	确定是否应启用。`JdbcCursorItemReaderDataSource`
`jdbcbatchitemwriter.datasource.url`	`String`	`null`	数据库的 JDBC URL。
`jdbcbatchitemwriter.datasource.username`	`String`	`null`	数据库的登录用户名。
`jdbcbatchitemwriter.datasource.password`	`String`	`null`	数据库的登录密码。
`jdbcbatchitemreader.datasource.driver-class-name`	`String`	`null`	JDBC 驱动程序的完全限定名称。

spring.batch.job.jdbcbatchitemwriter.datasource.enable

boolean

false

确定是否应启用。JdbcCursorItemReaderDataSource

jdbcbatchitemwriter.datasource.url

String

null

数据库的 JDBC URL。

jdbcbatchitemwriter.datasource.username

String

null

数据库的登录用户名。

jdbcbatchitemwriter.datasource.password

String

null

数据库的登录密码。

jdbcbatchitemreader.datasource.driver-class-name

String

null

JDBC 驱动程序的完全限定名称。

如果未指定，则将使用 default。DataSourceJdbcBatchItemWriterjdbcbatchitemwriter_datasource

请参阅 JdbcBatchItemWriter 文档。

KafkaItemWriter

要将步骤输出写入 Kafka 主题，您需要 .这个开胃菜通过使用两个位置的设施为 A 提供自动配置。第一个是 Spring Boot 的 Kafka 自动配置。（请参阅 Spring Boot Kafka 文档。其次，此启动器允许您在编写器上配置两个属性。KafkaItemWriterKafkaItemWriter

表 9. 性能`KafkaItemWriter`
财产	类型	默认值	描述
`spring.batch.job.kafkaitemwriter.topic`	`String`	`null`	要编写的 Kafka 主题。
`spring.batch.job.kafkaitemwriter.delete`	`boolean`	`false`	传递给编写器的项目是否全部作为删除事件发送到主题。

有关的配置选项的更多信息，请参阅 KafkaItemWiter 文档。KafkaItemWriter

春季 AOT

将 Spring AOT 与 Single Step Batch Starter 一起使用时，必须将读取器和编译时的 writer name 属性（除非您为 reader 和 /or writer 创建 bean）。为此，您必须包括要用作的读取器和编写器的名称以及 boot maven 插件或 gradle 插件中的参数或环境变量。例如，如果您希望在 Maven 中启用 and 它如下所示：FlatFileItemReaderFlatFileItemWriter

    <plugin>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-maven-plugin</artifactId>
        <executions>
            <execution>
            <id>process-aot</id>
            <goals>
                <goal>process-aot</goal>
            </goals>
            </execution>
        </executions>
        <configuration>
            <arguments>
                <argument>--spring.batch.job.flatfileitemreader.name=foobar</argument>
                <argument>--spring.batch.job.flatfileitemwriter.name=fooWriter</argument>
            </arguments>
        </configuration>
    </plugin>

表 6. 性能`AmqpItemWriter`
财产	类型	默认值	描述
`spring.batch.job.amqpitemwriter.enabled`	`boolean`	`false`	如果，则运行自动配置。`true`
`spring.batch.job.amqpitemwriter.jsonConverterEnabled`	`boolean`	`true`	指示是否应注册以转换邮件。`Jackson2JsonMessageConverter`

表 7. 性能`FlatFileItemWriter`
财产	类型	默认值	描述
`spring.batch.job.flatfileitemwriter.resource`	`Resource`	`null`	要读取的资源。
`spring.batch.job.flatfileitemwriter.delimited`	`boolean`	`false`	指示输出文件是否为分隔文件。如果，则必须是。`truespring.batch.job.flatfileitemwriter.formattedfalse`
`spring.batch.job.flatfileitemwriter.formatted`	`boolean`	`false`	指示输出文件是否为格式化文件。如果，则必须是。`truespring.batch.job.flatfileitemwriter.delimitedfalse`
`spring.batch.job.flatfileitemwriter.format`	`String`	`null`	用于生成格式化文件输出的格式。格式设置是通过使用来执行的。`String.format`
`spring.batch.job.flatfileitemwriter.locale`	`Locale`	`Locale.getDefault()`	生成文件时要使用的。`Locale`
`spring.batch.job.flatfileitemwriter.maximumLength`	`int`	0	记录的最大长度。如果为 0，则大小不受限制。
`spring.batch.job.flatfileitemwriter.minimumLength`	`int`	0	最小记录长度。
`spring.batch.job.flatfileitemwriter.delimiter`	`String`	`,`	用于分隔分隔文件中的字段。`String`
`spring.batch.job.flatfileitemwriter.encoding`	`String`	`FlatFileItemReader.DEFAULT_CHARSET`	写入文件时要使用的编码。
`spring.batch.job.flatfileitemwriter.forceSync`	`boolean`	`false`	指示是否应在刷新时将文件强制同步到磁盘。
`spring.batch.job.flatfileitemwriter.names`	`String []`	`null`	从记录中解析的每个字段的名称列表。这些名称是 for this 接收到的项目中的键。`Map<String, Object>ItemWriter`
`spring.batch.job.flatfileitemwriter.append`	`boolean`	`false`	指示如果找到输出文件，是否应追加文件。
`spring.batch.job.flatfileitemwriter.lineSeparator`	`String`	`FlatFileItemWriter.DEFAULT_LINE_SEPARATOR`	用于分隔输出文件中的行。`String`
`spring.batch.job.flatfileitemwriter.name`	`String`	`null`	用于在中提供唯一键的名称。`ExecutionContext`
`spring.batch.job.flatfileitemwriter.saveState`	`boolean`	`true`	确定是否应保存状态以供重新启动。
`spring.batch.job.flatfileitemwriter.shouldDeleteIfEmpty`	`boolean`	`false`	如果设置为，则在作业完成时删除空文件（没有输出）。`true`
`spring.batch.job.flatfileitemwriter.shouldDeleteIfExists`	`boolean`	`true`	如果设置为并且找到输出文件应位于的位置的文件，则在步骤开始之前将其删除。`true`
`spring.batch.job.flatfileitemwriter.transactional`	`boolean`	`FlatFileItemWriter.DEFAULT_TRANSACTIONAL`	指示读取器是否为事务队列（指示读取的项目在失败时返回到队列）。

表 8. 性能`JdbcBatchItemWriter`
财产	类型	默认值	描述
`spring.batch.job.jdbcbatchitemwriter.name`	`String`	`null`	用于在中提供唯一键的名称。`ExecutionContext`
`spring.batch.job.jdbcbatchitemwriter.sql`	`String`	`null`	用于插入每个项的 SQL。
`spring.batch.job.jdbcbatchitemwriter.assertUpdates`	`boolean`	`true`	是否验证每个插入是否都会导致至少一条记录的更新。

财产类型默认值描述

财产	类型	默认值	描述
`spring.batch.job.jdbcbatchitemwriter.datasource.enable`	`boolean`	`false`	确定是否应启用。`JdbcCursorItemReaderDataSource`
`jdbcbatchitemwriter.datasource.url`	`String`	`null`	数据库的 JDBC URL。
`jdbcbatchitemwriter.datasource.username`	`String`	`null`	数据库的登录用户名。
`jdbcbatchitemwriter.datasource.password`	`String`	`null`	数据库的登录密码。
`jdbcbatchitemreader.datasource.driver-class-name`	`String`	`null`	JDBC 驱动程序的完全限定名称。

spring.batch.job.jdbcbatchitemwriter.datasource.enable

boolean

false

确定是否应启用。JdbcCursorItemReaderDataSource

jdbcbatchitemwriter.datasource.url

String

null

数据库的 JDBC URL。

jdbcbatchitemwriter.datasource.username

String

null

数据库的登录用户名。

jdbcbatchitemwriter.datasource.password

String

null

数据库的登录密码。

jdbcbatchitemreader.datasource.driver-class-name

String

null

JDBC 驱动程序的完全限定名称。

如果未指定，则将使用 default。DataSourceJdbcBatchItemWriterjdbcbatchitemwriter_datasource

表 9. 性能`KafkaItemWriter`
财产	类型	默认值	描述
`spring.batch.job.kafkaitemwriter.topic`	`String`	`null`	要编写的 Kafka 主题。
`spring.batch.job.kafkaitemwriter.delete`	`boolean`	`false`	传递给编写器的项目是否全部作为删除事件发送到主题。