springBatch文件批处理 springBatch从文件中读取、写入 对reader读取到的数据进行中间处理 springBatch从数据库中读取、写入 启动程序 从多个文件中读取数据 写入到多个文件

springBatch文件批处理
springBatch从文件中读取、写入
对reader读取到的数据进行中间处理
springBatch从数据库中读取、写入
启动程序
从多个文件中读取数据
写入到多个文件

使用FlatFileItemReader

a构建公共类,主要实现类

springBatch文件批处理
springBatch从文件中读取、写入
对reader读取到的数据进行中间处理
springBatch从数据库中读取、写入
启动程序
从多个文件中读取数据
写入到多个文件

b在配置类中新建方法,传入参数,添加注解@Configuration, @Bean

公共类中需要两个参数:(转换的类名,文件资源路径)

springBatch文件批处理
springBatch从文件中读取、写入
对reader读取到的数据进行中间处理
springBatch从数据库中读取、写入
启动程序
从多个文件中读取数据
写入到多个文件

使用FlatFileItemWriter

a构建公共类,主要实现类

springBatch文件批处理
springBatch从文件中读取、写入
对reader读取到的数据进行中间处理
springBatch从数据库中读取、写入
启动程序
从多个文件中读取数据
写入到多个文件

b在配置类中新建方法,传入参数,@Bean

公共类中需要两个参数:(转换的类名,文件资源路径)

 springBatch文件批处理
springBatch从文件中读取、写入
对reader读取到的数据进行中间处理
springBatch从数据库中读取、写入
启动程序
从多个文件中读取数据
写入到多个文件

对reader读取到的数据进行中间处理

自定义类,实现ItemProcessor

springBatch文件批处理
springBatch从文件中读取、写入
对reader读取到的数据进行中间处理
springBatch从数据库中读取、写入
启动程序
从多个文件中读取数据
写入到多个文件

springBatch从数据库中读取、写入

a使用JdbcCursorItemReader

在配置类中新建方法,@Bean

springBatch文件批处理
springBatch从文件中读取、写入
对reader读取到的数据进行中间处理
springBatch从数据库中读取、写入
启动程序
从多个文件中读取数据
写入到多个文件

b使用JdbcBatchItemWriter

在配置类中新建方法,@Bean

springBatch文件批处理
springBatch从文件中读取、写入
对reader读取到的数据进行中间处理
springBatch从数据库中读取、写入
启动程序
从多个文件中读取数据
写入到多个文件

  1. 配置文件

 springBatch文件批处理
springBatch从文件中读取、写入
对reader读取到的数据进行中间处理
springBatch从数据库中读取、写入
启动程序
从多个文件中读取数据
写入到多个文件

Chunk中的reader,writer属性分别是在配置类中创建的方法名

启动程序

a进入页面

b根据配置文件中job标签的id属性找到对应的job测试,点击管理进行

c找到对应磁盘查看数据是否写入到目标文件中

 springBatch文件批处理
springBatch从文件中读取、写入
对reader读取到的数据进行中间处理
springBatch从数据库中读取、写入
启动程序
从多个文件中读取数据
写入到多个文件

从多个文件中读取数据

使用 MultiResourceItemReader 实现

创建配置类

需要设置:代理方法(替代执行的方法)+ 资源文件集合

其他内容,与单个文件读取相同。

 springBatch文件批处理
springBatch从文件中读取、写入
对reader读取到的数据进行中间处理
springBatch从数据库中读取、写入
启动程序
从多个文件中读取数据
写入到多个文件

写入到多个文件

使用 ClassifierCompositeItemWriter 实现

设置的 setClassifier() 方法:进行区分不同数据根据条件,调用不同写入方法,写入到不同文件。

springBatch文件批处理
springBatch从文件中读取、写入
对reader读取到的数据进行中间处理
springBatch从数据库中读取、写入
启动程序
从多个文件中读取数据
写入到多个文件

需要注意:在配置文件中设置stream标签,ref属性的值分别是调用的写入方法名;否则程序会运行出错

springBatch文件批处理
springBatch从文件中读取、写入
对reader读取到的数据进行中间处理
springBatch从数据库中读取、写入
启动程序
从多个文件中读取数据
写入到多个文件

 springBatch文件批处理
springBatch从文件中读取、写入
对reader读取到的数据进行中间处理
springBatch从数据库中读取、写入
启动程序
从多个文件中读取数据
写入到多个文件